Save rating to database

2 files changed, 18 insertions, 11 deletions

diff --git a/src/main/Analyzor.java b/src/main/Analyzor.java
index 831231a..8f11186 100644
--- a/src/main/Analyzor.java
+++ b/src/main/Analyzor.java
@@ -5,6 +5,8 @@
  */

 package main;

 

+import database.NamedPreparedStatement;

+import database.QueryUtils;

 import java.io.File;

 import java.io.FileNotFoundException;

 import java.sql.Connection;

@@ -28,6 +30,7 @@ public class Analyzor {
     

     //the resultset of the query or the import

     ResultSet data;

+    Connection connection;

     

     //reads the lexicons

     void readLexicon() throws FileNotFoundException{

@@ -61,12 +64,15 @@ public class Analyzor {
         

         PreparedStatement statement;

         

-        try (Connection connection = Main.cb.create()){

+        try {

+            connection = Main.cb.create();

             statement = connection.prepareStatement(query);

             data = statement.executeQuery();

+            

+            

         }

         catch(SQLException ex){

-            System.err.println("could not make a connection with the database");

+            System.err.println("could not make a connection with the database"+ex);

         }

     }

 

@@ -74,10 +80,7 @@ public class Analyzor {
     //this is just a base version

     void sentimentAnalysis() {

         

-        if(data == null){

-            System.err.print("no dataset available: query first");

-            return;

-        }

+        

         

         try{

             readLexicon();

@@ -113,9 +116,12 @@ public class Analyzor {
                         positiverate += bimap.get(pair);

                     }

                 }

-                

-                //prints the rate

-                System.out.println(text + ": " + (int) (positiverate * 10));

+                NamedPreparedStatement m_insertRating;

+                m_insertRating = new NamedPreparedStatement(connection, QueryUtils.insertRating);

+                QueryUtils.setInsertParams(m_insertRating, data.getLong("tweetid"),data.getString("brand"), (int)(positiverate * 10));

+                m_insertRating.executeUpdate();

+                //don't print the rate

+                //System.out.println(text + ": " + (int) (positiverate * 10));

             }

         } catch (SQLException ex) {

             System.err.println("text not found");

diff --git a/src/main/FarmShell.java b/src/main/FarmShell.java
index c41ad6b..daab973 100644
--- a/src/main/FarmShell.java
+++ b/src/main/FarmShell.java
@@ -67,8 +67,7 @@ public class FarmShell {
      * otherwise.

      */

     public boolean execute(String[] args) {

-        //make a new Analyzor

-        analyzor = new Analyzor();

+        

 

         try {

             Command command = Command.fromString(args[0]);

@@ -140,6 +139,8 @@ public class FarmShell {
         }

         switch (command) {

             case query:

+                //make a new Analyzor

+                analyzor = new Analyzor();

                 analyzor.Query(params[0]);

                 break;

             case filterbots: