diff options
author | Peter Wu <peter@lekensteyn.nl> | 2014-05-10 19:47:48 +0200 |
---|---|---|
committer | Peter Wu <peter@lekensteyn.nl> | 2014-05-10 19:47:48 +0200 |
commit | 84917e8789b9eece2b5ddc2353c3ddcc32a4301e (patch) | |
tree | 6c7fec7ab49135d4d826c22364a539c5d283fdf3 | |
parent | 82e095b443ca60603cf7261e73f41d5bfdb0ae56 (diff) | |
download | Datafiller-84917e8789b9eece2b5ddc2353c3ddcc32a4301e.tar.gz |
Fix tweetUrl, userUrl table names, fix retweets
-rw-r--r-- | src/database/QueryUtils.java | 4 | ||||
-rw-r--r-- | src/main/DataFiller.java | 5 |
2 files changed, 7 insertions, 2 deletions
diff --git a/src/database/QueryUtils.java b/src/database/QueryUtils.java index 4f87428..678df8c 100644 --- a/src/database/QueryUtils.java +++ b/src/database/QueryUtils.java @@ -28,10 +28,10 @@ public class QueryUtils { = buildQuery("hashtag", null, "tweetid", "hashtag"); public final static String insertUserUrl - = buildQuery("url", null, "userid", "url"); + = buildQuery("userUrl", null, "userid", "url"); public final static String insertTweetUrl - = buildQuery("url", null, "tweetid", "url"); + = buildQuery("tweetUrl", null, "tweetid", "url"); public final static String insertMentions = buildQuery("mentionsuser", null, "tweetid", "userid"); diff --git a/src/main/DataFiller.java b/src/main/DataFiller.java index 8a010d0..f62bbac 100644 --- a/src/main/DataFiller.java +++ b/src/main/DataFiller.java @@ -52,6 +52,11 @@ public class DataFiller { } public void processTweet(Tweet tweet) throws SQLException { + // process retweets first because of the foreign key. + if (tweet.retweeted_status != null) { + processTweet(tweet.retweeted_status); + } + // ensure that the user and tweet are known before adding relations QueryUtils.setInsertParams(m_insertTweet, m_insertProfile, tweet); m_insertProfile.executeUpdate(); |