diff options
Diffstat (limited to 'src/database')
-rw-r--r-- | src/database/NamedPreparedStatement.java | 11 | ||||
-rw-r--r-- | src/database/QueryUtils.java | 8 |
2 files changed, 15 insertions, 4 deletions
diff --git a/src/database/NamedPreparedStatement.java b/src/database/NamedPreparedStatement.java index ebb775b..9305d32 100644 --- a/src/database/NamedPreparedStatement.java +++ b/src/database/NamedPreparedStatement.java @@ -2,6 +2,7 @@ package database; import java.sql.Connection; import java.sql.PreparedStatement; +import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.sql.Types; @@ -104,4 +105,14 @@ public class NamedPreparedStatement { throw ex; } } + + public ResultSet executeQuery() throws SQLException { + try { + return getStmt().executeQuery(); + } catch (SQLException ex) { + System.err.println("Query error: " + ex.getMessage()); + System.err.println(stmt); + throw ex; + } + } } diff --git a/src/database/QueryUtils.java b/src/database/QueryUtils.java index 2cc6fd6..b95903f 100644 --- a/src/database/QueryUtils.java +++ b/src/database/QueryUtils.java @@ -1,7 +1,6 @@ package database; import java.sql.SQLException; -import java.util.Locale; /** * Utilities to create queries. @@ -9,8 +8,9 @@ import java.util.Locale; * @author Maurice Laveaux */ public class QueryUtils { - public final static String insertRating - = buildQuery("mentionsbrand", new String[]{"tweetid","brand"},"tweetid","brand", "rating"); + + public final static String insertRating + = buildQuery("mentionsbrand", new String[]{"tweetid", "brand"}, "tweetid", "brand", "rating"); public final static String insertProfile = buildQuery("twitteruser", new String[]{"userid"}, "userid", "displayname", "timezone", "tweetcount", "followercount", @@ -96,7 +96,7 @@ public class QueryUtils { statement.setLong("tweetid", tweetid); statement.setInt("rating", rating); statement.setString("brand", brand); - + } public static void setInsertBrandParams(NamedPreparedStatement brandStmt, |