Two different inputs (file and stdin).

	* DataFiller fills the database with given input.

1 files changed, 43 insertions, 0 deletions

diff --git a/src/main/DataFiller.java b/src/main/DataFiller.java
new file mode 100644
index 0000000..461bd21
--- /dev/null
+++ b/src/main/DataFiller.java
@@ -0,0 +1,43 @@
+package main;
+
+import database.DBConnection;
+import database.DBQuery;
+import database.QueryUtils;
+import org.json.JSONObject;
+
+/**
+ * Process that incoming tweets and fill the database.
+ *
+ * @author Maurice Laveaux
+ */
+public class DataFiller implements ResultListener {
+
+    /**
+     * The main database connection to fill.
+     */
+    private final DBConnection m_connection;
+
+    /**
+     * A single insert tweet that can be used often.
+     */
+    private DBQuery m_insertTweet;
+
+    /**
+     * Create the datafiller object.
+     *
+     * @param connection The database connection to use.
+     */
+    public DataFiller(DBConnection connection) {
+        m_insertTweet = QueryUtils.insertTweet();
+
+        m_connection = connection;
+        m_connection.prepare(m_insertTweet);
+    }
+
+    @Override
+    public void tweetReceived(JSONObject tweet) {
+        QueryUtils.setInsertParams(m_insertTweet, tweet);
+        
+        m_insertTweet.execute();        
+    }
+}