gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.core.tools.importinfo;
   2
   3
   4 import org.apache.commons.io.FileUtils;
   5 import org.openecomp.core.tools.exportinfo.ExportDataCommand;
   6 import org.openecomp.core.tools.util.Utils;
   7 import org.openecomp.core.tools.util.ZipUtils;
   8 import org.openecomp.core.zusammen.impl.CassandraConnectionInitializer;
   9 import org.openecomp.sdc.logging.api.Logger;
  10 import org.openecomp.sdc.logging.api.LoggerFactory;
  11
  12 import java.io.IOException;
  13 import java.nio.file.Files;
  14 import java.nio.file.Path;
  15 import java.nio.file.Paths;
  16 import java.util.stream.Stream;
  17
  18 public class ImportDataCommand {
  19
  20     private static final Logger logger = LoggerFactory.getLogger(ImportDataCommand.class);
  21
  22     public static void execute(String uploadFile) {
  23         try {
  24             CassandraConnectionInitializer.setCassandraConnectionPropertiesToSystem();
  25             Path outputFolder = Paths.get(ImportProperties.ROOT_DIRECTORY);
  26             ExportDataCommand.initDir(outputFolder); //clear old imports.
  27             ZipUtils.unzip(Paths.get(uploadFile), outputFolder);
  28             try( Stream<Path> files = Files.list(outputFolder)) {
  29                 files.forEach(new ImportSingleTable()::importFile);
  30             }
  31             FileUtils.forceDelete(outputFolder.toFile()); // leaves directory clean
  32         } catch (IOException e) {
  33             Utils.logError(logger, e);
  34         }
  35     }
  36 }