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

   1 package org.openecomp.core.tools.Commands.importdata;
   2
   3 import com.amdocs.zusammen.datatypes.SessionContext;
   4 import com.amdocs.zusammen.datatypes.item.Item;
   5 import com.amdocs.zusammen.plugin.statestore.cassandra.dao.ItemDao;
   6 import com.amdocs.zusammen.plugin.statestore.cassandra.dao.ItemDaoFactory;
   7 import org.openecomp.core.utilities.json.JsonUtil;
   8 import org.openecomp.sdc.logging.api.Logger;
   9 import org.openecomp.sdc.logging.api.LoggerFactory;
  10
  11 import java.io.File;
  12 import java.nio.file.Files;
  13 import java.nio.file.Path;
  14 import java.nio.file.Paths;
  15
  16 import static org.openecomp.core.tools.Commands.exportdata.ImportProperties.JSON_POSTFIX;
  17
  18 public class ItemImport {
  19     private static final Logger logger = LoggerFactory.getLogger(ItemImport.class);
  20
  21     public void loadPath(SessionContext sessionContext, Path itemDir, String itemName) {
  22         try {
  23             Path itemPath = Paths.get(itemDir.toString() + File.separator + itemName + JSON_POSTFIX);
  24             if (!Files.exists(itemPath)) {
  25                 return;
  26             }
  27             String itemJson = new String(Files.readAllBytes(itemPath));
  28             if (itemJson.trim().isEmpty()) {
  29                 return;
  30             }
  31             Item item = JsonUtil.json2Object(itemJson, Item.class);
  32             ItemDao itemDao = getItemDao(sessionContext);
  33             itemDao.create(sessionContext, item.getId(), item.getInfo(), item.getCreationTime());
  34             logger.info("Item Created :"+item.getInfo().getName()+" , "+item.getId());
  35             System.out.println("Item Created :"+item.getInfo().getName()+" , "+item.getId());
  36         } catch (Exception ex) {
  37             logger.error(ex.getMessage(), ex);
  38         }
  39     }
  40
  41     private ItemDao getItemDao(SessionContext context) {
  42         return ItemDaoFactory.getInstance().createInterface(context);
  43     }
  44 }