change to NewSqliteStorageSupplier

since early MC versions don't support upsert by default

Author: HSGamer

agent/storage-simple/src/main/java/me/hsgamer/topper/agent/storage/simple/builder/DataStorageBuilder.java

@@ -27,7 +27,7 @@ public DataStorageBuilder(
         this.defaultSupplier = () -> new FlatStorageSupplier<>(holderBaseFolder, flatEntryConverter);
         register(defaultSupplier, "flat", "properties", "");
         register(v -> new SqliteStorageSupplier<>(databaseSettingSupplier.get(), holderBaseFolder, sqlEntryConverter), "sqlite", "sqlite3");
-        register(v -> new OldSqliteStorageSupplier<>(databaseSettingSupplier.get(), holderBaseFolder, sqlEntryConverter), "old-sqlite");
+        register(v -> new NewSqliteStorageSupplier<>(databaseSettingSupplier.get(), holderBaseFolder, sqlEntryConverter), "new-sqlite", "new-sqlite3");
         register(v -> new MySqlStorageSupplier<>(databaseSettingSupplier.get(), sqlEntryConverter), "mysql", "mysql-connector-java", "mysql-connector");
     }
 

…e/supplier/OldSqliteStorageSupplier.java …e/supplier/NewSqliteStorageSupplier.javaagent/storage-simple/src/main/java/me/hsgamer/topper/agent/storage/simple/supplier/OldSqliteStorageSupplier.java renamed to agent/storage-simple/src/main/java/me/hsgamer/topper/agent/storage/simple/supplier/NewSqliteStorageSupplier.java agent/storage-simple/src/main/java/me/hsgamer/topper/agent/storage/simple/supplier/OldSqliteStorageSupplier.java renamed to agent/storage-simple/src/main/java/me/hsgamer/topper/agent/storage/simple/supplier/NewSqliteStorageSupplier.java

@@ -5,14 +5,14 @@
 
 import java.io.File;
 
-public class OldSqliteStorageSupplier<K, V> extends SqliteStorageSupplier<K, V> {
-    public OldSqliteStorageSupplier(DatabaseSetting databaseSetting, File holderBaseFolder, SqlEntryConverter<K, V> converter) {
+public class NewSqliteStorageSupplier<K, V> extends SqliteStorageSupplier<K, V> {
+    public NewSqliteStorageSupplier(DatabaseSetting databaseSetting, File holderBaseFolder, SqlEntryConverter<K, V> converter) {
         super(databaseSetting, holderBaseFolder, converter);
     }
 
     @Override
     protected String toSaveStatement(String name, String[] keyColumns, String[] valueColumns) {
-        StringBuilder statement = new StringBuilder("INSERT OR REPLACE INTO `")
+        StringBuilder statement = new StringBuilder("INSERT INTO `")
                 .append(name)
                 .append("` (");
         for (int i = 0; i < keyColumns.length + valueColumns.length; i++) {
@@ -30,7 +30,28 @@ protected String toSaveStatement(String name, String[] keyColumns, String[] valu
                 statement.append(", ");
             }
         }
-        statement.append(");");
+        statement.append(")");
+        statement.append(" ON CONFLICT (");
+        for (int i = 0; i < keyColumns.length; i++) {
+            statement.append("`")
+                    .append(keyColumns[i])
+                    .append("`");
+            if (i != keyColumns.length - 1) {
+                statement.append(", ");
+            }
+        }
+        statement.append(") DO UPDATE SET ");
+        for (int i = 0; i < valueColumns.length; i++) {
+            statement.append("`")
+                    .append(valueColumns[i])
+                    .append("` = EXCLUDED.`")
+                    .append(valueColumns[i])
+                    .append("`");
+            if (i != valueColumns.length - 1) {
+                statement.append(", ");
+            }
+        }
+        statement.append(";");
         return statement.toString();
     }
 }

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

@@ -43,7 +43,7 @@ protected void flushConnection(Connection connection) {
 
     @Override
     protected String toSaveStatement(String name, String[] keyColumns, String[] valueColumns) {
-        StringBuilder statement = new StringBuilder("INSERT INTO `")
+        StringBuilder statement = new StringBuilder("INSERT OR REPLACE INTO `")
                 .append(name)
                 .append("` (");
         for (int i = 0; i < keyColumns.length + valueColumns.length; i++) {
@@ -61,28 +61,7 @@ protected String toSaveStatement(String name, String[] keyColumns, String[] valu
                 statement.append(", ");
             }
         }
-        statement.append(")");
-        statement.append(" ON CONFLICT (");
-        for (int i = 0; i < keyColumns.length; i++) {
-            statement.append("`")
-                    .append(keyColumns[i])
-                    .append("`");
-            if (i != keyColumns.length - 1) {
-                statement.append(", ");
-            }
-        }
-        statement.append(") DO UPDATE SET ");
-        for (int i = 0; i < valueColumns.length; i++) {
-            statement.append("`")
-                    .append(valueColumns[i])
-                    .append("` = EXCLUDED.`")
-                    .append(valueColumns[i])
-                    .append("`");
-            if (i != valueColumns.length - 1) {
-                statement.append(", ");
-            }
-        }
-        statement.append(";");
+        statement.append(");");
         return statement.toString();
     }