bug修改

src/main/java/com/ihooyah/flume/sink/DAOClass.java

@@ -5,7 +5,6 @@ import org.apache.flume.Event;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
 import java.sql.*;
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -77,8 +76,8 @@ public class DAOClass {
         }
     }
 
-    public void createConnection(String driver, String db_url, String user, String password) throws IOException {
-        if (this.connection == null) {
+    public void createConnection(String driver, String db_url, String user, String password) throws SQLException {
+        if (this.connection == null || this.connection.isClosed() || this.connection.isValid(1)) {
             try {
                 Class.forName(driver);
                 this.connection = DriverManager.getConnection(db_url, user, password);