diff options
Diffstat (limited to 'openecomp-be/lib/openecomp-sdc-model-lib/openecomp-sdc-model-impl/src/main/java/org/openecomp/sdc/model/impl/EnrichedServiceTemplateDaoCassandraImpl.java')
-rw-r--r-- | openecomp-be/lib/openecomp-sdc-model-lib/openecomp-sdc-model-impl/src/main/java/org/openecomp/sdc/model/impl/EnrichedServiceTemplateDaoCassandraImpl.java | 147 |
1 files changed, 147 insertions, 0 deletions
diff --git a/openecomp-be/lib/openecomp-sdc-model-lib/openecomp-sdc-model-impl/src/main/java/org/openecomp/sdc/model/impl/EnrichedServiceTemplateDaoCassandraImpl.java b/openecomp-be/lib/openecomp-sdc-model-lib/openecomp-sdc-model-impl/src/main/java/org/openecomp/sdc/model/impl/EnrichedServiceTemplateDaoCassandraImpl.java new file mode 100644 index 0000000000..f0d4b56204 --- /dev/null +++ b/openecomp-be/lib/openecomp-sdc-model-lib/openecomp-sdc-model-impl/src/main/java/org/openecomp/sdc/model/impl/EnrichedServiceTemplateDaoCassandraImpl.java @@ -0,0 +1,147 @@ +/*- + * ============LICENSE_START======================================================= + * SDC + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.openecomp.sdc.model.impl; + +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 org.openecomp.core.model.dao.EnrichedServiceTemplateDao; +import org.openecomp.core.model.types.EnrichedServiceTemplateEntity; +import org.openecomp.core.model.types.ServiceTemplate; +import org.openecomp.core.nosqldb.api.NoSqlDb; +import org.openecomp.core.nosqldb.factory.NoSqlDbFactory; +import org.openecomp.sdc.versioning.VersioningManagerFactory; +import org.openecomp.sdc.versioning.dao.types.Version; +import org.openecomp.sdc.versioning.types.VersionableEntityMetadata; + +import java.util.Collection; +import java.util.List; +import java.util.stream.Collectors; + +public class EnrichedServiceTemplateDaoCassandraImpl implements EnrichedServiceTemplateDao { + + private static final NoSqlDb noSqlDb = NoSqlDbFactory.getInstance().createInterface(); + private static final Mapper<EnrichedServiceTemplateEntity> mapper = + noSqlDb.getMappingManager().mapper(EnrichedServiceTemplateEntity.class); + private static final VspServiceTemplateAccessor accessor = + noSqlDb.getMappingManager().createAccessor(VspServiceTemplateAccessor.class); + private static final UDTMapper<Version> versionMapper = + noSqlDb.getMappingManager().udtMapper(Version.class); + + @Override + public void registerVersioning(String versionableEntityType) { + VersioningManagerFactory.getInstance().createInterface() + .register(versionableEntityType, new VersionableEntityMetadata( + mapper.getTableMetadata().getName(), + mapper.getTableMetadata().getPartitionKey().get(0).getName(), + mapper.getTableMetadata().getPartitionKey().get(1).getName())); + } + + @Override + public Collection<ServiceTemplate> list(String vspId, Version version) { + + List<EnrichedServiceTemplateEntity> entityList = accessor.list(vspId, version).all(); + return entityList.stream().map(entity -> entity.getServiceTemplate()) + .collect(Collectors.toList()); + } + + @Override + public void create(ServiceTemplate entity) { + EnrichedServiceTemplateEntity vspEnrichedServiceTemplateEntity = + new EnrichedServiceTemplateEntity(entity); + mapper.save(vspEnrichedServiceTemplateEntity); + } + + @Override + public void update(ServiceTemplate entity) { + EnrichedServiceTemplateEntity vspEnrichedServiceTemplateEntity = + new EnrichedServiceTemplateEntity(entity); + mapper.save(vspEnrichedServiceTemplateEntity); + } + + @Override + public ServiceTemplate get(String vspId, Version version) { + return (mapper.get(getKeys(vspId, version))).getServiceTemplate(); + } + + @Override + public void delete(String vspId, Version version) { + mapper.delete(vspId, version); + } + + + @Override + public Object[] getKeys(String vspId, Version version) { + return new Object[]{vspId, versionMapper.toUDT(version)}; + } + + @Override + public ServiceTemplate getTemplateInfo(String vspId, Version version, String name) { + EnrichedServiceTemplateEntity enrichedServiceTemplateEntity = + accessor.getTemplateInfo(vspId, versionMapper.toUDT(version), name).one(); + if (enrichedServiceTemplateEntity == null) { + return null; + } + return enrichedServiceTemplateEntity.getServiceTemplate(); + } + + @Override + public String getBase(String vspId, Version version) { + Result<EnrichedServiceTemplateEntity> element = + accessor.getBase(vspId, versionMapper.toUDT(version)); + if (element != null) { + EnrichedServiceTemplateEntity vspEnrichedServiceTemplateEntity = element.one(); + if (vspEnrichedServiceTemplateEntity != null) { + return element.one().getBaseName(); + } + } + return null; + } + + + @Accessor + interface VspServiceTemplateAccessor { + + @Query( + "SELECT vsp_id, version, name, base_name ,content_data FROM vsp_enriched_service_template") + Result<EnrichedServiceTemplateEntity> listAll(); + + @Query( + "SELECT vsp_id, version, name, base_name ,content_data FROM vsp_enriched_service_template " + + "where vsp_id=? and version=?") + Result<EnrichedServiceTemplateEntity> list(String vspId, Version version); + + + @Query( + "SELECT vsp_id, version, name, base_name ,content_data FROM vsp_enriched_service_template " + + "where vsp_id=? and version=? and name=?") + Result<EnrichedServiceTemplateEntity> getTemplateInfo(String vspId, UDTValue version, + String name); + + @Query( + "SELECT vsp_id, version, name, base_name FROM vsp_enriched_service_template " + + "where vsp_id=? and version=?") + Result<EnrichedServiceTemplateEntity> getBase(String vspId, UDTValue version); + } +} |