diff options
Diffstat (limited to 'src/database/QueryUtils.java')
-rw-r--r-- | src/database/QueryUtils.java | 40 |
1 files changed, 40 insertions, 0 deletions
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"));*/ + } +} |