gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.core.tools.Commands.importdata;
   2
   3 import com.amdocs.zusammen.datatypes.SessionContext;
   4 import org.openecomp.core.tools.store.VersionInfoCassandraLoader;
   5 import org.openecomp.core.utilities.json.JsonUtil;
   6 import org.openecomp.sdc.logging.api.Logger;
   7 import org.openecomp.sdc.logging.api.LoggerFactory;
   8 import org.openecomp.sdc.versioning.dao.types.VersionInfoEntity;
   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_INFO_FILE_PREFIX;
  17
  18 public class VersionInfoImport {
  19     private static final Logger logger = LoggerFactory.getLogger(VersionInfoImport.class);
  20
  21     public void loadPath(SessionContext sessionContext, Path itemPath, String itemId) {
  22         try {
  23              Path versionInfoFilePath = Paths.get(itemPath.toString() + separator + VERSION_INFO_FILE_PREFIX
  24                     + itemId + JSON_POSTFIX);
  25             if (!Files.exists(versionInfoFilePath)) {
  26                 return;
  27             }
  28             String versionInfoJson = new String(Files.readAllBytes(versionInfoFilePath));
  29             if (versionInfoJson.trim().isEmpty()) {
  30                 return;
  31             }
  32             VersionInfoEntity versionInfoEntity = JsonUtil.json2Object(versionInfoJson, VersionInfoEntity.class);
  33             VersionInfoCassandraLoader versionInfoCassandraLoader = new VersionInfoCassandraLoader();
  34             versionInfoCassandraLoader.insertVersionInfo(versionInfoEntity);
  35         } catch (Exception ex) {
  36             logger.error(ex.getMessage(), ex);
  37         }
  38     }
  39
  40
  41 }