diff options
Diffstat (limited to 'openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/cassandra/VersionDaoImpl.java')
-rw-r--r-- | openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/cassandra/VersionDaoImpl.java | 185 |
1 files changed, 0 insertions, 185 deletions
diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/cassandra/VersionDaoImpl.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/cassandra/VersionDaoImpl.java deleted file mode 100644 index bba2ddf267..0000000000 --- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/cassandra/VersionDaoImpl.java +++ /dev/null @@ -1,185 +0,0 @@ -package org.openecomp.core.zusammen.plugin.dao.impl.cassandra; - -import com.amdocs.zusammen.datatypes.Id; -import com.amdocs.zusammen.datatypes.SessionContext; -import com.datastax.driver.core.ResultSet; -import com.datastax.driver.core.Row; -import com.datastax.driver.mapping.annotations.Accessor; -import com.datastax.driver.mapping.annotations.Query; -import org.openecomp.core.zusammen.plugin.dao.VersionDao; -import org.openecomp.core.zusammen.plugin.dao.types.VersionEntity; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.Date; -import java.util.List; -import java.util.Map; -import java.util.Optional; -import java.util.stream.Collectors; - -import static java.util.stream.Collectors.toMap; - -public class VersionDaoImpl implements VersionDao { - - @Override - public void create(SessionContext context, String space, Id itemId, VersionEntity version) { - String baseVersion = version.getBaseId() != null ? version.getBaseId().toString() : null; - - getAccessor(context) - .create(space, itemId.toString(), version.getId().toString(), - baseVersion, - version.getCreationTime(), version.getModificationTime()); - - } - - @Override - public void delete(SessionContext context, String space, Id itemId, Id versionId) { - - getAccessor(context).delete(space, itemId.toString(), versionId.toString()); - } - - @Override - public void updateModificationTime(SessionContext context, String space, Id itemId, - Id versionId, Date modificationTime) { - getAccessor(context) - .updateModificationTime(modificationTime, space, itemId.toString(), versionId.toString()); - } - - - @Override - public Collection<VersionEntity> list(SessionContext context, String space, Id itemId) { - List<Row> rows = getAccessor(context).list(space, itemId.toString()).all(); - return rows == null ? new ArrayList<>() : - rows.stream().map(VersionDaoImpl::convertToVersionEntity).collect(Collectors.toList()); - } - - - @Override - public Optional<VersionEntity> get(SessionContext context, String space, Id itemId, - Id versionId) { - Row row; - - row = getAccessor(context).get(space, itemId.toString(), versionId.toString()).one(); - - - return row == null ? Optional.empty() : Optional.of(convertToVersionEntity(row)); - } - - @Override - public boolean checkHealth(SessionContext context) { - return getAccessor(context).checkHealth().getColumnDefinitions() - .contains(VersionField.VERSION_ID); - } - - @Override - public void createVersionElements(SessionContext context, String space, Id itemId, - Id versionId, Id revisionId, Map<Id, Id> versionElementIds, - Date publishTime, String message) { - Map<String, String> elementIds = versionElementIds==null?null:versionElementIds. - entrySet(). - stream(). - collect(toMap((Map.Entry<Id, Id>entry)->entry.getKey().getValue(), - (Map.Entry<Id, Id>entry)->entry.getValue().getValue())); - - getVersionElementsAccessor(context).create(space,itemId.toString(),versionId.toString(), - revisionId.getValue(),elementIds,publishTime,message,context.getUser().getUserName()); - } - - - private static VersionEntity convertToVersionEntity(Row row) { - - /*Id revisionId = row.getColumnDefinitions().contains("revision_id")?new Id(row.getString - (VersionField.REVISION_ID)):null;*/ - - VersionEntity version = new VersionEntity(new Id(row.getString(VersionField.VERSION_ID))); - return enrichVersionEntity(version, row); - } - - static VersionEntity enrichVersionEntity(VersionEntity version, Row row) { - version.setBaseId(new Id(row.getString(VersionField.BASE_VERSION_ID))); - version.setCreationTime(row.getDate(VersionField.CREATION_TIME)); - version.setModificationTime(row.getDate(VersionField.MODIFICATION_TIME)); - return version; - } - - private VersionAccessor getAccessor(SessionContext context) { - return CassandraDaoUtils.getAccessor(context, VersionAccessor.class); - } - - private VersionElementsAccessor getVersionElementsAccessor(SessionContext context) { - return CassandraDaoUtils.getAccessor(context, VersionElementsAccessor.class); - } - - @Accessor - interface VersionAccessor { - - @Query( - "INSERT INTO version (space, item_id, version_id, base_version_id, " + - "creation_time, " + - "modification_time) " + - "VALUES (?, ?, ?, ?, ?, ?)") - void create(String space, String itemId, String versionId, String baseVersionId, - Date creationTime, Date modificationTime); - - @Query("UPDATE version SET modification_time=? WHERE space=? AND item_id=? AND version_id=? ") - void updateModificationTime(Date modificationTime, String space, String itemId, - String versionId); - - @Query("DELETE FROM version WHERE space=? AND item_id=? AND version_id=? ") - void delete(String space, String itemId, String versionId); - - @Query("SELECT version_id, base_version_id, creation_time, modification_time " + - "FROM version WHERE space=? AND item_id=? AND version_id=? ") - ResultSet get(String space, String itemId, String versionId); - - /*@Query("SELECT version_id, base_version_id, creation_time, modification_time " + - "FROM version WHERE space=? AND item_id=? AND version_id=? ") - ResultSet get(String space, String itemId, String versionId);*/ - - - @Query("SELECT version_id, base_version_id, creation_time, modification_time " + - "FROM version WHERE space=? AND item_id=?") - ResultSet list(String space, String itemId); - - @Query("SELECT version_id FROM version LIMIT 1") - ResultSet checkHealth(); - } - - private static final class VersionField { - private static final String VERSION_ID = "version_id"; - private static final String BASE_VERSION_ID = "base_version_id"; - private static final String CREATION_TIME = "creation_time"; - private static final String MODIFICATION_TIME = "modification_time"; - //private static final String REVISION_ID = "revision_id"; - } - - @Accessor - interface VersionElementsAccessor { - - @Query("INSERT INTO version_elements (space,item_id,version_id,revision_id,element_ids," + - "publish_time,message,user) " + - "VALUES (?,?,?,?,?,?,?,?)") - void create(String space, - String itemId, - String versionId, - String versionRevisionId, - Map<String,String> elementIds, - Date publishTime, - String message, - String user); - - - - } - - /* public static final class VersionElementsField { - private static final String SPACE = "space"; - private static final String ITEM_ID = "item_id"; - private static final String VERSION_ID = "version_id"; - private static final String ELEMENT_IDS = "element_ids"; - private static final String REVISION_ID = "revision_id"; - - }*/ - - -} |