move duplicated code in sql storage

Author: HSGamer

storage/simple/src/main/java/me/hsgamer/topper/storage/simple/supplier/MySqlStorageSupplier.java

@@ -3,10 +3,7 @@
 import me.hsgamer.hscore.database.Setting;
 import me.hsgamer.hscore.database.client.sql.java.JavaSqlClient;
 import me.hsgamer.hscore.database.driver.mysql.MySqlDriver;
-import me.hsgamer.hscore.logger.common.LogLevel;
 
-import java.sql.Connection;
-import java.sql.SQLException;
 import java.util.Collections;
 import java.util.List;
 import java.util.function.Consumer;
@@ -21,19 +18,8 @@ public MySqlStorageSupplier(Consumer<Setting> databaseSettingConsumer) {
     }
 
     @Override
-    protected Connection getConnection() throws SQLException {
-        Connection connection = client.getConnection();
-        connection.setAutoCommit(false);
-        return connection;
-    }
-
-    @Override
-    protected void flushConnection(Connection connection) {
-        try {
-            connection.close();
-        } catch (SQLException e) {
-            logger.log(LogLevel.ERROR, "Failed to close connection", e);
-        }
+    public JavaSqlClient getClient() {
+        return client;
     }
 
     @Override

storage/simple/src/main/java/me/hsgamer/topper/storage/simple/supplier/SqlStorageSupplier.java

@@ -1,6 +1,7 @@
 package me.hsgamer.topper.storage.simple.supplier;
 
 import me.hsgamer.hscore.database.client.sql.BatchBuilder;
+import me.hsgamer.hscore.database.client.sql.SqlClient;
 import me.hsgamer.hscore.database.client.sql.StatementBuilder;
 import me.hsgamer.hscore.logger.common.LogLevel;
 import me.hsgamer.hscore.logger.common.Logger;
@@ -16,14 +17,26 @@
 public abstract class SqlStorageSupplier implements DataStorageSupplier {
     protected final Logger logger = LoggerProvider.getLogger(getClass());
 
-    protected abstract Connection getConnection() throws SQLException;
-
-    protected abstract void flushConnection(Connection connection);
+    protected abstract SqlClient<?> getClient();
 
     protected abstract List<String> toSaveStatement(String name, String[] keyColumns, String[] valueColumns);
 
     protected abstract List<Object[]> toSaveValues(Object[] keys, Object[] values);
 
+    private Connection getConnection() throws SQLException {
+        Connection connection = getClient().getConnection();
+        connection.setAutoCommit(false);
+        return connection;
+    }
+
+    private void flushConnection(Connection connection) {
+        try {
+            connection.close();
+        } catch (SQLException e) {
+            logger.log(LogLevel.ERROR, "Failed to close connection", e);
+        }
+    }
+
     @Override
     public <K, V> DataStorage<K, V> getStorage(String name, ValueConverter<K> keyConverter, ValueConverter<V> valueConverter) {
         return new DataStorage<K, V>() {

storage/simple/src/main/java/me/hsgamer/topper/storage/simple/supplier/SqliteStorageSupplier.java

@@ -3,11 +3,8 @@
 import me.hsgamer.hscore.database.Setting;
 import me.hsgamer.hscore.database.client.sql.java.JavaSqlClient;
 import me.hsgamer.hscore.database.driver.sqlite.SqliteFileDriver;
-import me.hsgamer.hscore.logger.common.LogLevel;
 
 import java.io.File;
-import java.sql.Connection;
-import java.sql.SQLException;
 import java.util.Arrays;
 import java.util.List;
 import java.util.function.Consumer;
@@ -22,19 +19,8 @@ public SqliteStorageSupplier(Consumer<Setting> databaseSettingConsumer, File bas
     }
 
     @Override
-    protected Connection getConnection() throws SQLException {
-        Connection connection = client.getConnection();
-        connection.setAutoCommit(false);
-        return connection;
-    }
-
-    @Override
-    protected void flushConnection(Connection connection) {
-        try {
-            connection.close();
-        } catch (SQLException e) {
-            logger.log(LogLevel.ERROR, "Failed to close connection", e);
-        }
+    public JavaSqlClient getClient() {
+        return client;
     }
 
     @Override