diff --git a/07/src/de/dis2017/Main.java b/07/src/de/dis2017/Main.java index 2b2af12..57c52e1 100644 --- a/07/src/de/dis2017/Main.java +++ b/07/src/de/dis2017/Main.java @@ -25,18 +25,21 @@ public class Main { */ public static void main(String[] args) { _orm = new ORM(); + System.out.println("Begin Extract process.."); extract(); load(); } private static void extract() { + System.out.println("Load product dimension data from database.."); _articles = _orm.getArticles(); Map articleNames = new HashMap<>(); for (Article article : _articles) { articleNames.put(article.get_name(), article.get_articleID()); } + System.out.println("Load location dimension data from database.."); _shops = _orm.getShops(); Map shopNames = new HashMap<>(); for (Shop shop : _shops) { @@ -44,8 +47,14 @@ public class Main { } try { + System.out.println("Scan the CSV file.."); List> csvEntries = CSVScanner.scan("sales.csv"); + System.out.println("Finish Extract process"); List sales = new ArrayList<>(); + System.out.println("Begin Transform process.."); + System.out.println("Transform each CSV row into one Sale object.."); + System.out.println("..and create one Date object for each date (multiple Sale objects share one such " + + "object).."); for (List row : csvEntries) { Sale sale = new Sale(); String date = row.get(0); @@ -62,21 +71,29 @@ public class Main { sales.add(sale); } _sales = sales; + System.out.println("Finish Transform process."); } catch (FileNotFoundException e) { e.printStackTrace(); } + System.out.println("Retrieve all Date objects which were created during Transform"); _dates = Date.getDates(); } private static void load() { + System.out.println("Begin Load process.."); _orm.setAutoCommit(false); + System.out.println("Write product dimension data to database.."); _orm.createArticles(_articles); + System.out.println("Write date dimension data to database.."); _orm.createDates(_dates); + System.out.println("Write location dimension data to database.."); _orm.createShops(_shops); + System.out.println("Write sales (fact) data to database.."); _orm.createSales(_sales); _orm.commit(); _orm.setAutoCommit(true); + System.out.println("Finish Load process"); } }