From cab0c6a184f307002264c9fc66afe42d4e188bed Mon Sep 17 00:00:00 2001
From: Jim Martens <github@2martens.de>
Date: Mon, 26 Jun 2017 17:58:45 +0200
Subject: [PATCH] Added ORM

Signed-off-by: Jim Martens <github@2martens.de>
---
 07/src/de/dis2017/data/db/ORM.java | 55 ++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 07/src/de/dis2017/data/db/ORM.java

diff --git a/07/src/de/dis2017/data/db/ORM.java b/07/src/de/dis2017/data/db/ORM.java
new file mode 100644
index 0000000..d65e4c6
--- /dev/null
+++ b/07/src/de/dis2017/data/db/ORM.java
@@ -0,0 +1,55 @@
+package de.dis2017.data.db;
+
+import de.dis2017.data.Article;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class ORM {
+    private Connection _connection;
+    
+    /**
+     * Initializes the ORM.
+     */
+    public ORM() {
+        DB2ConnectionManager _dbManager = DB2ConnectionManager.getInstance();
+        _connection = _dbManager.getConnection();
+    }
+    
+    public List<Article> getArticles()
+    {
+        List<Article> articles = new ArrayList<>();
+        String                selectSQL = "SELECT a.articleID, a.name AS name, pg.name AS productGroup, " +
+                                          "pf.name AS productFamily, pc.name AS productCategory " +
+                                          "FROM DB2INST1.ARTICLEID AS a, DB2INST1.PRODUCTGROUPID AS pg," +
+                                          "DB2INST1.PRODUCTFAMILYID AS pf, DB2INST1.PRODUCTCATEGORYID AS pc " +
+                                          "WHERE a.PRODUCTGROUPID = pg.PRODUCTGROUPID " +
+                                          "AND pg.PRODUCTFAMILYID = pf.PRODUCTFAMILYID " +
+                                          "AND pf.PRODUCTCATEGORYID = pc.PRODUCTCATEGORYID ";
+        try {
+            PreparedStatement pstmt = _connection.prepareStatement(selectSQL);
+            ResultSet         rs    = pstmt.executeQuery();
+    
+            while (rs.next()) {
+                Article article = new Article();
+                article.set_articleID(rs.getInt("articleID"));
+                article.set_name(rs.getString("name"));
+                article.set_productGroup(rs.getString("productGroup"));
+                article.set_productFamily(rs.getString("productFamily"));
+                article.set_productCategory(rs.getString("productCategory"));
+                articles.add(article);
+            }
+            
+            rs.close();
+            pstmt.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        
+        return articles;
+    }
+}