1 files changed, 42 insertions, 0 deletions
diff --git a/openecomp-be/tools/zusammen-tools/src/main/java/org/openecomp/core/tools/Commands/importdata/ItemImport.java b/openecomp-be/tools/zusammen-tools/src/main/java/org/openecomp/core/tools/Commands/importdata/ItemImport.java
new file mode 100644
index 0000000000..c7042743c2
--- /dev/null
+++ b/openecomp-be/tools/zusammen-tools/src/main/java/org/openecomp/core/tools/Commands/importdata/ItemImport.java
@@ -0,0 +1,42 @@
+package org.openecomp.core.tools.Commands.importdata;
+
+import com.amdocs.zusammen.datatypes.SessionContext;
+import com.amdocs.zusammen.datatypes.item.Item;
+import com.amdocs.zusammen.plugin.statestore.cassandra.dao.ItemDao;
+import com.amdocs.zusammen.plugin.statestore.cassandra.dao.ItemDaoFactory;
+import org.openecomp.core.utilities.json.JsonUtil;
+import org.openecomp.sdc.logging.api.Logger;
+import org.openecomp.sdc.logging.api.LoggerFactory;
+
+import java.io.File;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+import static org.openecomp.core.tools.Commands.exportdata.ImportProperties.JSON_POSTFIX;
+
+public class ItemImport {
+    private static final Logger logger = LoggerFactory.getLogger(ItemImport.class);
+
+    public void loadPath(SessionContext sessionContext, Path itemDir, String itemName) {
+        try {
+            Path itemPath = Paths.get(itemDir.toString() + File.separator + itemName + JSON_POSTFIX);
+            if (!Files.exists(itemPath)) {
+                return;
+            }
+            String itemJson = new String(Files.readAllBytes(itemPath));
+            if (itemJson == null || itemJson.trim().isEmpty()) {
+                return;
+            }
+            Item item = JsonUtil.json2Object(itemJson, Item.class);
+            ItemDao itemDao = getItemDao(sessionContext);
+            itemDao.create(sessionContext, item.getId(), item.getInfo(), item.getCreationTime());
+        } catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+        }
+    }
+
+    private ItemDao getItemDao(SessionContext context) {
+        return ItemDaoFactory.getInstance().createInterface(context);
+    }
+}