1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/*
* Copyright © 2016-2018 European Support Limited
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.openecomp.sdc.vendorsoftwareproduct.dao.impl;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.UDTValue;
import com.datastax.driver.mapping.Mapper;
import com.datastax.driver.mapping.Result;
import com.datastax.driver.mapping.UDTMapper;
import com.datastax.driver.mapping.annotations.Accessor;
import com.datastax.driver.mapping.annotations.Query;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import org.openecomp.core.dao.impl.CassandraBaseDao;
import org.openecomp.core.nosqldb.api.NoSqlDb;
import org.openecomp.core.nosqldb.factory.NoSqlDbFactory;
import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants;
import org.openecomp.sdc.vendorsoftwareproduct.dao.ComputeDao;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComputeEntity;
import org.openecomp.sdc.versioning.ActionVersioningManagerFactory;
import org.openecomp.sdc.versioning.dao.types.Version;
import org.openecomp.sdc.versioning.types.UniqueValueMetadata;
import org.openecomp.sdc.versioning.types.VersionableEntityMetadata;
public class ComputeDaoCassandraImpl extends CassandraBaseDao<ComputeEntity> implements
ComputeDao {
private static final NoSqlDb noSqlDb = NoSqlDbFactory.getInstance().createInterface();
private static final Mapper<ComputeEntity> mapper =
noSqlDb.getMappingManager().mapper(ComputeEntity.class);
private static final ComputeAccessor accessor =
noSqlDb.getMappingManager().createAccessor(ComputeDaoCassandraImpl.ComputeAccessor.class);
private static final UDTMapper<Version> versionMapper =
noSqlDb.getMappingManager().udtMapper(Version.class);
@Override
public void registerVersioning(String versionableEntityType) {
VersionableEntityMetadata metadata = new VersionableEntityMetadata(
mapper.getTableMetadata().getName(),
mapper.getTableMetadata().getPartitionKey().get(0).getName(),
mapper.getTableMetadata().getPartitionKey().get(1).getName());
metadata.setUniqueValuesMetadata(Collections.singletonList(new UniqueValueMetadata(
VendorSoftwareProductConstants.UniqueValues.COMPUTE_NAME,
Arrays.asList("vsp_id", "version", "component_id", "name"))));
ActionVersioningManagerFactory.getInstance().createInterface()
.register(versionableEntityType, metadata);
}
@Override
public Collection<ComputeEntity> list(ComputeEntity entity) {
return accessor.listByComponentId(entity.getVspId(),
versionMapper.toUDT(entity.getVersion()), entity.getComponentId()).all();
}
@Override
protected Mapper<ComputeEntity> getMapper() {
return mapper;
}
@Override
protected Object[] getKeys(ComputeEntity entity) {
return new Object[]{entity.getVspId(), versionMapper.toUDT(entity.getVersion()),
entity.getComponentId(), entity.getId()};
}
@Override
public Collection<ComputeEntity> listByVsp(String vspId, Version version) {
return accessor.listByVspId(vspId, versionMapper.toUDT(version)).all();
}
@Override
public void update(ComputeEntity entity) {
accessor.updateCompositionData(entity.getCompositionData(), entity.getVspId(), versionMapper
.toUDT(entity.getVersion()), entity.getComponentId(), entity.getId());
}
@Override
public void updateQuestionnaireData(String vspId, Version version, String componentId,
String computeId, String questionnaireData) {
accessor.updateQuestionnaireData(questionnaireData, vspId, versionMapper.toUDT(version),
componentId, computeId);
}
@Override
public void deleteAll(String vspId, Version version) {
accessor.deleteAll(vspId, version);
}
@Override
public ComputeEntity getQuestionnaireData(String vspId, Version version, String componentId,
String computeId) {
return null;
}
@Accessor
interface ComputeAccessor {
@Query("select * from vsp_component_compute where vsp_id=? and version=? and component_id=?")
Result<ComputeEntity> listByComponentId(String vspId, UDTValue version, String componentId);
@Query("select * from vsp_component_compute where vsp_id=? and version=?")
Result<ComputeEntity> listByVspId(String vspId, UDTValue version);
@Query("update vsp_component_compute set composition_data=? where vsp_id=? and version=?"
+ " and component_id=? and compute_id=?")
ResultSet updateCompositionData(String compositionData, String vspId, UDTValue version,
String componentId, String computeId);
@Query("update vsp_component_compute set questionnaire_data=? where vsp_id=? and version=?"
+ " and component_id=? and compute_id=?")
ResultSet updateQuestionnaireData(String questionnaireData, String vspId, UDTValue version,
String componentId, String computeId);
@Query("delete from vsp_component_compute where vsp_id=? and version=?")
ResultSet deleteAll(String vspId, Version version);
}
}
|
