openecomp-be/tools/zusammen-tools/src/main/java/org/openecomp/core/tools/Commands/importdata/VersionImport.java

   1 package org.openecomp.core.tools.Commands.importdata;
   2
   3 import com.amdocs.zusammen.datatypes.SessionContext;
   4 import org.openecomp.core.tools.store.VersionCassandraLoader;
   5 import org.openecomp.core.tools.store.zusammen.datatypes.VersionEntity;
   6 import org.openecomp.core.utilities.json.JsonUtil;
   7 import org.openecomp.sdc.logging.api.Logger;
   8 import org.openecomp.sdc.logging.api.LoggerFactory;
   9
  10 import java.nio.file.Files;
  11 import java.nio.file.Path;
  12 import java.nio.file.Paths;
  13
  14 import static java.io.File.separator;
  15 import static org.openecomp.core.tools.Commands.exportdata.ImportProperties.JSON_POSTFIX;
  16 import static org.openecomp.core.tools.Commands.exportdata.ImportProperties.VERSION_FILE_PREFIX;
  17
  18 public class VersionImport {
  19     private static final Logger logger = LoggerFactory.getLogger(VersionImport.class);
  20
  21     public void loadPath(SessionContext sessionContext, Path versionDir , String versionId){
  22         try {
  23             Path versionPath = Paths.get(versionDir.toString() + separator + VERSION_FILE_PREFIX
  24                     + versionId + JSON_POSTFIX);
  25             if (!Files.exists(versionPath)) {
  26                 return;
  27             }
  28             String versionJson = new String(Files.readAllBytes(versionPath));
  29             if (versionJson.trim().isEmpty()) {
  30                 return;
  31             }
  32             VersionEntity versionEntity = JsonUtil.json2Object(versionJson, VersionEntity.class);
  33             VersionCassandraLoader versionCassandraLoader = new VersionCassandraLoader();
  34             versionCassandraLoader.insertVersion(versionEntity);
  35         } catch (Exception ex) {
  36             logger.error(ex.getMessage(), ex);
  37         }
  38     }
  39
  40
  41 }