From 2f203acc7f28afce9e704cf27fd59d11e28ec2d5 Mon Sep 17 00:00:00 2001 From: Maurice Laveaux Date: Wed, 7 May 2014 12:31:49 +0200 Subject: Added classes to refactor the database code. * DBConnection creates a persistent conn. * DBQuery resolves and executes queries. * QueryUtils creates sql query text. --- src/database/QueryUtils.java | 40 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 40 insertions(+) create mode 100644 src/database/QueryUtils.java (limited to 'src/database/QueryUtils.java') diff --git a/src/database/QueryUtils.java b/src/database/QueryUtils.java new file mode 100644 index 0000000..a120d1c --- /dev/null +++ b/src/database/QueryUtils.java @@ -0,0 +1,40 @@ +package database; + +import org.json.JSONObject; + +/** + * Utilities to create queries. + * + * @author Maurice Laveaux + */ +public class QueryUtils { + + /** + * Create an insert tweet. + * + * @return A valid database query. + */ + public static DBQuery insertProfile() { + String query = "INSERT INTO twitteruser (userid,displayname,timezone,tweetcount," + + "followercount,followedcount,location) " + + "SELECT ?, ?, ?, ?, ?, ?, ? " + + "WHERE NOT EXISTS " + + "(SELECT * FROM twitteruser WHERE userid= ? )"; + return new DBQuery(query); + } + + public static DBQuery insertTweet() { + String query = "INSERT INTO tweet (tweetid,createdat,favcount,retweetcount,text) " + + "SELECT ?, ?, ?, ?, ? WHERE NOT EXISTS (SELECT * FROM tweet WHERE tweetid= ? )"; + return new DBQuery(query); + } + + public static void setInsertParams(DBQuery query, JSONObject tweet) { + /*query.getPrepared().setLong(1, tweet.getLong("id")); + pst.setString(2, tweet.getString("created_at")); + pst.setLong(3, tweet.getLong("favorite_count")); + pst.setLong(4, tweet.getLong("retweet_count")); + pst.setString(5, tweet.getString("text")); + pst.setLong(6, tweet.getLong("id"));*/ + } +} -- cgit v1.2.1