Revert "try connection per transaction on SQLite"

This reverts commit bab3ea3.

Author: HSGamer

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

@@ -7,13 +7,14 @@
 
 import java.io.File;
 import java.sql.Connection;
-import java.sql.SQLException;
 import java.util.Arrays;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Consumer;
 
 public class SqliteStorageSupplier extends SqlStorageSupplier {
     private final JavaSqlClient client;
+    private final AtomicReference<Connection> connectionReference = new AtomicReference<>();
 
     public SqliteStorageSupplier(Consumer<Setting> databaseSettingConsumer, File baseHolder) {
         Setting setting = Setting.create(new SqliteFileDriver(baseHolder));
@@ -22,19 +23,26 @@ public SqliteStorageSupplier(Consumer<Setting> databaseSettingConsumer, File bas
     }
 
     @Override
-    protected Connection getConnection() throws SQLException {
-        Connection connection = client.getConnection();
-        connection.setAutoCommit(false);
-        return connection;
+    protected Connection getConnection() {
+        return connectionReference.updateAndGet(connection -> {
+            try {
+                if (connection == null || connection.isClosed()) {
+                    Connection clientConnection = client.getConnection();
+                    clientConnection.setAutoCommit(false);
+                    return clientConnection;
+                } else {
+                    return connection;
+                }
+            } catch (Exception e) {
+                logger.log(LogLevel.ERROR, "Failed to get the connection", e);
+                return null;
+            }
+        });
     }
 
     @Override
     protected void flushConnection(Connection connection) {
-        try {
-            connection.close();
-        } catch (SQLException e) {
-            logger.log(LogLevel.ERROR, "Failed to close connection", e);
-        }
+        // EMPTY
     }
 
     @Override
@@ -102,4 +110,16 @@ protected List<Object[]> toSaveValues(Object[] keys, Object[] values) {
                 updateValues
         );
     }
+
+    @Override
+    public void disable() {
+        Connection connection = connectionReference.getAndSet(null);
+        try {
+            if (connection != null && !connection.isClosed()) {
+                connection.close();
+            }
+        } catch (Exception e) {
+            logger.log(LogLevel.ERROR, "Failed to close the connection", e);
+        }
+    }
 }