Add reconnect to ConnectionProvider#getConnection method if Connection#isValid is false

db/src/main/java/net/zhira/varioutil/sql/AbstractProvider.java

@@ -4,14 +4,19 @@ import java.sql.Connection;
 import java.sql.SQLException;
 
 abstract class AbstractProvider implements ConnectionProvider {
-    private final Connection connection;
+    private Connection connection;
 
-    AbstractProvider(Connection connection) {
+    abstract Connection establishConnection();
-        this.connection = connection;
-    }
 
     @Override
     public Connection getConnection() {
+        try {
+            if (connection == null || !connection.isValid(1)) {
+                connection = establishConnection();
+            }
+        } catch (SQLException e) {
+            throw new SqlException(e);
+        }
         return connection;
     }
 

db/src/main/java/net/zhira/varioutil/sql/H2Provider.java

@@ -2,8 +2,21 @@ package net.zhira.varioutil.sql;
 
 import net.zhira.varioutil.util.SqlUtils;
 
+import java.sql.Connection;
+
 public class H2Provider extends AbstractProvider {
+    private final String path;
+    private final String username;
+    private final String password;
+
     public H2Provider(String path, String username, String password) {
-        super(SqlUtils.createH2Connection(path, username, password));
+        this.path = path;
+        this.username = username;
+        this.password = password;
+    }
+
+    @Override
+    Connection establishConnection() {
+        return SqlUtils.createH2Connection(path, username, password);
     }
 }

db/src/main/java/net/zhira/varioutil/sql/MysqlProvider.java

@@ -2,8 +2,24 @@ package net.zhira.varioutil.sql;
 
 import net.zhira.varioutil.util.SqlUtils;
 
+import java.sql.Connection;
+
 public class MysqlProvider extends AbstractProvider {
+    private final String address;
+    private final String dbname;
+    private final String username;
+    private final String password;
+    private final boolean ssl;
+
     public MysqlProvider(String address, String dbname, String username, String password, boolean ssl) {
-        super(SqlUtils.createMysqlConnection(address, dbname, username, password, ssl));
+        this.address = address;
+        this.dbname = dbname;
+        this.username = username;
+        this.password = password;
+        this.ssl = ssl;
+    }
+
+    Connection establishConnection() {
+        return SqlUtils.createMysqlConnection(address, dbname, username, password, ssl);
     }
 }

db/src/main/java/net/zhira/varioutil/sql/SqlAdapter.java

@@ -86,5 +86,4 @@ public final class SqlAdapter implements AutoCloseable {
         }
         provider = ConnectionProvider.CLOSED;
     }
-
 }

db/src/main/java/net/zhira/varioutil/sql/SqliteProvider.java

@@ -2,8 +2,17 @@ package net.zhira.varioutil.sql;
 
 import net.zhira.varioutil.util.SqlUtils;
 
+import java.sql.Connection;
+
 public class SqliteProvider extends AbstractProvider {
+    private final String path;
+
     public SqliteProvider(String path) {
-        super(SqlUtils.createSqliteConnection(path));
+        this.path = path;
+    }
+
+    @Override
+    Connection establishConnection() {
+        return SqlUtils.createSqliteConnection(path);
     }
 }