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