From 7688805217f71eba913a644a4d1d38a394dd7d76 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Tue, 29 Dec 2015 01:27:20 +0300
Subject: push: fix sql loading in listeners

---
 src/main/java/com/juick/CrosspostComponent.java | 3 +++
 src/main/java/com/juick/PushComponent.java      | 3 +++
 2 files changed, 6 insertions(+)

(limited to 'src/main/java/com/juick')

diff --git a/src/main/java/com/juick/CrosspostComponent.java b/src/main/java/com/juick/CrosspostComponent.java
index 1df68493..f6d830ec 100644
--- a/src/main/java/com/juick/CrosspostComponent.java
+++ b/src/main/java/com/juick/CrosspostComponent.java
@@ -125,11 +125,14 @@ public class CrosspostComponent implements ServletContextListener,  Stream.Strea
 
     public void setupSql(String host, String username, String password, String database) {
         try {
+            Class.forName("com.mysql.jdbc.Driver");
             sql = DriverManager.getConnection(
                     String.format("jdbc:mysql://%s/%s?autoReconnect=true&user=%s&password=%s",
                             host, database, username, password));
         } catch (SQLException e) {
             logger.log(Level.SEVERE, e.getMessage(), e);
+        } catch (ClassNotFoundException e) {
+            logger.log(Level.SEVERE, e.getMessage(), e);
         }
     }
 
diff --git a/src/main/java/com/juick/PushComponent.java b/src/main/java/com/juick/PushComponent.java
index a813f1a2..7b6c90ec 100644
--- a/src/main/java/com/juick/PushComponent.java
+++ b/src/main/java/com/juick/PushComponent.java
@@ -125,11 +125,14 @@ public class PushComponent implements ServletContextListener, Stream.StreamListe
 
     public void setupSql(String host, String username, String password, String database) {
         try {
+            Class.forName("com.mysql.jdbc.Driver");
             sql = DriverManager.getConnection(
                     String.format("jdbc:mysql://%s/%s?autoReconnect=true&user=%s&password=%s",
                             host, database, username, password));
         } catch (SQLException e) {
             logger.log(Level.SEVERE, e.getMessage(), e);
+        } catch (ClassNotFoundException e) {
+            logger.log(Level.SEVERE, e.getMessage(), e);
         }
     }
 
-- 
cgit v1.2.3