diff options
Diffstat (limited to 'openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/PackageInfoDaoImpl.java')
1 files changed, 20 insertions, 3 deletions
diff --git a/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/PackageInfoDaoImpl.java b/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/PackageInfoDaoImpl.java index 9b7b81fe52..37917284e0 100644 --- a/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/PackageInfoDaoImpl.java +++ b/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/PackageInfoDaoImpl.java @@ -20,6 +20,7 @@ package org.openecomp.sdc.vendorsoftwareproduct.dao.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; @@ -28,10 +29,13 @@ import com.datastax.driver.mapping.annotations.Query; 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.common.utils.CommonUtil; +import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage; import org.openecomp.sdc.vendorsoftwareproduct.dao.PackageInfoDao; import org.openecomp.sdc.vendorsoftwareproduct.dao.type.PackageInfo; import org.openecomp.sdc.versioning.dao.types.Version; +import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Collection; import java.util.List; @@ -46,6 +50,8 @@ public class PackageInfoDaoImpl extends CassandraBaseDao<PackageInfo> implements private static final UDTMapper<Version> versionMapper = noSqlDb.getMappingManager().udtMapper(Version.class); + private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage(); + @Override protected Mapper<PackageInfo> getMapper() { return mapper; @@ -63,6 +69,8 @@ public class PackageInfoDaoImpl extends CassandraBaseDao<PackageInfo> implements @Override public List<PackageInfo> listByCategory(String category, String subCategory) { + + mdcDataDebugMessage.debugEntryMessage(null, null); Result<PackageInfo> packages = accessor.listInfo(); List<PackageInfo> filteredPackages = new ArrayList<>(); @@ -79,7 +87,7 @@ public class PackageInfoDaoImpl extends CassandraBaseDao<PackageInfo> implements filteredPackages.add(packageInfo); } } - + mdcDataDebugMessage.debugExitMessage(null, null); return filteredPackages; } @@ -88,16 +96,25 @@ public class PackageInfoDaoImpl extends CassandraBaseDao<PackageInfo> implements accessor.deleteRowTranslateContent(vspId, version); } + @Override + public void updateTranslatedContent(String vspId, Version version, ByteBuffer translateContent){ + accessor.updateTranslateContent(translateContent, vspId, versionMapper.toUDT(version)); + } + @Accessor interface PackageInfoAccessor { @Query( - "SELECT vsp_id,version,display_name,vsp_name,vsp_description,vendor_name,category," - + "sub_category,vendor_release,package_checksum,package_type FROM package_details") + "SELECT vsp_id,version,display_name,vsp_name,vsp_description,vendor_name,category" + + " ,sub_category, vendor_release,package_checksum,package_type FROM package_details") Result<PackageInfo> listInfo(); @Query("DELETE TRANSLATE_CONTENT FROM package_details WHERE vsp_id=? and version=?") Result<PackageInfo> deleteRowTranslateContent(String vspId, Version version); + @Query("UPDATE package_details set translate_content = ? where vsp_id = ? and version = ?") + Result<PackageInfo> updateTranslateContent(ByteBuffer translateContent, String vspId, + UDTValue version); + } } |