summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/main/Main.java32
1 files changed, 14 insertions, 18 deletions
diff --git a/src/main/Main.java b/src/main/Main.java
index 7ea6bc3..5338003 100644
--- a/src/main/Main.java
+++ b/src/main/Main.java
@@ -117,27 +117,23 @@ public class Main implements Callable<Boolean> {
/* create the object that fills the database */
DataFiller filler = new DataFiller(connection);
while ((tweet = reader.getTweet()) != null) {
- try {
- filler.processTweet(tweet);
- ++tweetNo;
- } catch (JsonParseException ex) {
- if (tweet != null) {
- System.err.println("Faulty tweet " + tweetNo + ": " + tweet);
- }
- Logger.getLogger(Main.class.getName()).log(Level.SEVERE,
- "Tweet read error", ex);
- } catch (SQLException ex) {
- if (tweet != null) {
- System.err.println("Faulty tweet " + tweetNo + ": " + tweet);
- }
- Logger.getLogger(Main.class.getName()).log(Level.SEVERE,
- "DB error", ex);
- }
+ filler.processTweet(tweet);
+ ++tweetNo;
}
return true;
+ } catch (JsonParseException ex) {
+ if (tweet != null) {
+ System.err.println("Faulty tweet " + tweetNo + ": " + tweet);
+ }
+ Logger.getLogger(Main.class.getName()).log(Level.SEVERE,
+ "Tweet read error", ex);
} catch (SQLException ex) {
- Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
- }
+ if (tweet != null) {
+ System.err.println("Faulty tweet " + tweetNo + ": " + tweet);
+ }
+ Logger.getLogger(Main.class.getName()).log(Level.SEVERE,
+ "DB error", ex);
+ }
return false;
}