1 package org.openecomp.core.tools.Commands.importdata;
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;
10 import java.nio.file.Files;
11 import java.nio.file.Path;
12 import java.nio.file.Paths;
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;
18 public class VersionImport {
19 private static final Logger logger = LoggerFactory.getLogger(VersionImport.class);
21 public void loadPath(SessionContext sessionContext, Path versionDir , String versionId){
23 Path versionPath = Paths.get(versionDir.toString() + separator + VERSION_FILE_PREFIX
24 + versionId + JSON_POSTFIX);
25 if (!Files.exists(versionPath)) {
28 String versionJson = new String(Files.readAllBytes(versionPath));
29 if (versionJson.trim().isEmpty()) {
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);