1 files changed, 17 insertions, 17 deletions

diff --git a/src/main/DataFiller.java b/src/main/DataFiller.java
index a65a032..6e1ba9d 100644
--- a/src/main/DataFiller.java
+++ b/src/main/DataFiller.java
@@ -1,8 +1,8 @@
 package main;
 
 import data.Tweet;
-import database.DBConnection;
 import database.QueryUtils;
+import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 import java.util.ArrayList;
@@ -20,57 +20,57 @@ public class DataFiller {
     /**
      * The main database connection to fill.
      */
-    private final DBConnection m_connection;
+    private final Connection m_connection;
 
     /**
      * A single insert tweet that can be used.
      */
-    private PreparedStatement m_insertTweet;
+    private final PreparedStatement m_insertTweet;
 
     /**
      * A single insert profiles that can be used.
      */
-    private PreparedStatement m_insertProfile;
+    private final PreparedStatement m_insertProfile;
     /**
      * A single insert ispostedby that can be used.
      */
-    private PreparedStatement m_insertPosted;
+    private final PreparedStatement m_insertPosted;
 
     /**
      * A single insert brand that can be used.
      */
-    private PreparedStatement m_insertBrand;
+    private final PreparedStatement m_insertBrand;
 
     /**
      * A single insert hashtag that can be used.
      */
-    private PreparedStatement m_insertHash;
+    private final PreparedStatement m_insertHash;
 
     /**
      * A single insert url that can be used.
      */
-    private PreparedStatement m_insertUrl;
+    private final PreparedStatement m_insertUrl;
 
     /**
      * A single insert url that can be used.
      */
-    private PreparedStatement m_insertMentions;
+    private final PreparedStatement m_insertMentions;
 
     /**
      * Create the datafiller object.
      *
      * @param connection The database connection to use.
      */
-    public DataFiller(DBConnection connection) {
+    public DataFiller(Connection connection) {
         try {
             m_connection = connection;
-            m_insertTweet = m_connection.create(QueryUtils.insertTweet());
-            m_insertProfile = m_connection.create(QueryUtils.insertProfile());
-            m_insertPosted = m_connection.create(QueryUtils.insertPosted());
-            m_insertBrand = m_connection.create(QueryUtils.insertBrand());
-            m_insertHash = m_connection.create(QueryUtils.insertHash());
-            m_insertUrl = m_connection.create(QueryUtils.insertUrl());
-            m_insertMentions = m_connection.create(QueryUtils.insertMentions());
+            m_insertTweet = m_connection.prepareStatement(QueryUtils.insertTweet());
+            m_insertProfile = m_connection.prepareStatement(QueryUtils.insertProfile());
+            m_insertPosted = m_connection.prepareStatement(QueryUtils.insertPosted());
+            m_insertBrand = m_connection.prepareStatement(QueryUtils.insertBrand());
+            m_insertHash = m_connection.prepareStatement(QueryUtils.insertHash());
+            m_insertUrl = m_connection.prepareStatement(QueryUtils.insertUrl());
+            m_insertMentions = m_connection.prepareStatement(QueryUtils.insertMentions());
 
         } catch (SQLException ex) {
             throw new RuntimeException(ex.getMessage());