aboutsummaryrefslogtreecommitdiffstats
path: root/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1806/SdcArchiveMigration.java
diff options
context:
space:
mode:
Diffstat (limited to 'asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1806/SdcArchiveMigration.java')
-rw-r--r--asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1806/SdcArchiveMigration.java96
1 files changed, 0 insertions, 96 deletions
diff --git a/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1806/SdcArchiveMigration.java b/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1806/SdcArchiveMigration.java
deleted file mode 100644
index ea1541ef8d..0000000000
--- a/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1806/SdcArchiveMigration.java
+++ /dev/null
@@ -1,96 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * SDC
- * ================================================================================
- * Copyright (C) 2019 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.asdctool.migration.tasks.mig1806;
-
-import fj.data.Either;
-import org.openecomp.sdc.asdctool.migration.core.DBVersion;
-import org.openecomp.sdc.asdctool.migration.core.task.Migration;
-import org.openecomp.sdc.asdctool.migration.core.task.MigrationResult;
-import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
-import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
-import org.openecomp.sdc.be.dao.jsongraph.JanusGraphDao;
-import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
-import org.openecomp.sdc.be.dao.jsongraph.utils.IdBuilderUtils;
-import org.openecomp.sdc.be.datatypes.enums.GraphPropertyEnum;
-import org.openecomp.sdc.common.log.wrappers.Logger;
-import org.springframework.stereotype.Component;
-
-import java.math.BigInteger;
-
-@Component
-public class SdcArchiveMigration implements Migration {
- private static final Logger logger = Logger.getLogger(SdcArchiveMigration.class);
-
- private JanusGraphDao janusGraphDao;
-
- public SdcArchiveMigration(JanusGraphDao janusGraphDao) {
- this.janusGraphDao = janusGraphDao;
- }
-
- @Override
- public String description() {
- return "add archive node for archiving/restoring components ";
- }
-
- @Override
- public DBVersion getVersion() {
- return DBVersion.from(BigInteger.valueOf(1806), BigInteger.valueOf(0));
- }
-
- @Override
- public MigrationResult migrate() {
- JanusGraphOperationStatus status = null;
- try {
- status = getOrCreateArchiveRoot();
- return status == JanusGraphOperationStatus.OK ? MigrationResult.success() : MigrationResult.error("failed to create archive root node. error: " + status);
- } finally {
- commitOrRollBack(status);
- }
- }
-
- private void commitOrRollBack(JanusGraphOperationStatus status) {
- if (status == JanusGraphOperationStatus.OK) {
- janusGraphDao.commit();
- } else {
- janusGraphDao.rollback();
- }
- }
-
- private JanusGraphOperationStatus getOrCreateArchiveRoot() {
- logger.info("creating or getting catalog archive vertex");
- return janusGraphDao.getVertexByLabel(VertexTypeEnum.ARCHIVE_ROOT)
- .either(v -> JanusGraphOperationStatus.OK, s -> this.createRootArchiveVertex());
- }
-
- private JanusGraphOperationStatus createRootArchiveVertex() {
- GraphVertex archiveRootVertex = new GraphVertex(VertexTypeEnum.ARCHIVE_ROOT);
- archiveRootVertex.setUniqueId(IdBuilderUtils.generateUniqueId());
- archiveRootVertex.addMetadataProperty(GraphPropertyEnum.LABEL, VertexTypeEnum.ARCHIVE_ROOT);
- archiveRootVertex.addMetadataProperty(GraphPropertyEnum.UNIQUE_ID, archiveRootVertex.getUniqueId());
-
- logger.info("Creating root archive vertex {}", archiveRootVertex.getUniqueId());
-
- final Either<GraphVertex, JanusGraphOperationStatus> vertexE = janusGraphDao.createVertex(archiveRootVertex);
-
- return vertexE.isLeft() ? JanusGraphOperationStatus.OK : vertexE.right().value();
- }
-
-}