Fix SQLite compatibility issue with 1.8 servers

Author: AlexanderMandera

TradeSystem-Spigot/src/main/java/de/codingair/tradesystem/spigot/database/DatabaseHandler.java

@@ -2,13 +2,13 @@
 
 import com.github.Anon8281.universalScheduler.UniversalScheduler;
 import de.codingair.codingapi.files.ConfigFile;
+import de.codingair.codingapi.server.specification.Version;
 import de.codingair.tradesystem.spigot.TradeSystem;
 import de.codingair.tradesystem.spigot.database.migrations.SqlMigrations;
 import de.codingair.tradesystem.spigot.database.migrations.mysql.MySQLConnection;
 import de.codingair.tradesystem.spigot.database.migrations.mysql.MysqlMigrations;
 import de.codingair.tradesystem.spigot.database.migrations.sqlite.SqLiteMigrations;
 import de.codingair.tradesystem.spigot.database.migrations.sqlite.SqlLiteConnection;
-import org.bukkit.Bukkit;
 import org.bukkit.configuration.file.FileConfiguration;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -23,6 +23,20 @@ public void load() {
         loadType();
 
         TradeSystem.log("  > Queuing database initializing task");
+
+        if(Version.before(9)) {
+            // Load and register drivers manually
+            try {
+                Class.forName("org.sqlite.JDBC");
+            } catch(Exception ignored) {
+            }
+
+            try {
+                Class.forName("com.mysql.jdbc.Driver");
+            } catch(Exception ignored) {
+            }
+        }
+
         UniversalScheduler.getScheduler(TradeSystem.getInstance()).runTaskAsynchronously(
         new Runnable() {
             @Override

TradeSystem-Spigot/src/main/java/de/codingair/tradesystem/spigot/database/migrations/SqlMigrations.java

@@ -92,8 +92,11 @@ private void runMigrations(@NotNull Connection connect, @NotNull String user, @N
 
             for (String command : commands) {
                 try (Statement stmt = connect.createStatement()) {
+                    System.out.println(command);
                     stmt.execute(command);
                 }
+                System.out.println("Successfully executed!");
+                Thread.sleep(1000);
             }
         }
 

TradeSystem-Spigot/src/main/java/de/codingair/tradesystem/spigot/database/migrations/sqlite/SqLiteMigrations.java

@@ -28,10 +28,9 @@ private SqLiteMigrations() {
 
     @Override
     public void setVersion(@NotNull Connection connection, @NotNull String user, int version) throws Exception {
-        try (PreparedStatement stmt = connection.prepareStatement("INSERT INTO migrations VALUES (?, ?) ON CONFLICT(user) DO UPDATE SET version=?;")) {
+        try (PreparedStatement stmt = connection.prepareStatement("INSERT OR REPLACE INTO migrations VALUES (?, ?);")) {
             stmt.setString(1, user);
             stmt.setInt(2, version);
-            stmt.setInt(3, version);
             stmt.executeUpdate();
         }
     }

TradeSystem-Spigot/src/main/java/de/codingair/tradesystem/spigot/extras/tradelog/repository/adapters/SqlLiteTradeLogRepository.java

@@ -10,6 +10,7 @@
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
+import java.sql.Statement;
 import java.time.Instant;
 import java.time.ZoneId;
 import java.util.ArrayList;
@@ -20,15 +21,31 @@ public class SqlLiteTradeLogRepository implements TradeLogRepository {
 
     @Override
     public void registerOrUpdatePlayer(@NotNull UUID uuid, @NotNull String name) throws Exception {
-        String sql = "INSERT INTO trade_players(uuid, name) VALUES(?,?) ON CONFLICT(uuid) DO UPDATE SET name=?;";
+        String insertSql = "INSERT INTO trade_players(name, uuid) VALUES(?,?);";
+        String updateSql = "UPDATE trade_players SET name = ? WHERE id = ?;";
+
+        try (Connection con = SqlLiteConnection.connect(); ) {
+            int id = -1;
+            try(PreparedStatement stmt = con.prepareStatement("SELECT id FROM trade_players WHERE uuid = ?")) {
+                stmt.setString(1, uuid.toString());
+                ResultSet rs = stmt.executeQuery();
+                if(rs.next()) {
+                    id = rs.getInt("id");
+                }
+            }
 
-        try (Connection con = SqlLiteConnection.connect();
-             PreparedStatement pstmt = con.prepareStatement(sql)) {
-            pstmt.setString(1, uuid.toString());
-            pstmt.setString(2, name);
-            pstmt.setString(3, name);
+            try(PreparedStatement pstmt = con.prepareStatement(id == -1 ? insertSql : updateSql)) {
+                pstmt.setString(1, name);
+
+                if(id == -1) {
+                    pstmt.setString(2, uuid.toString());
+                } else {
+                    pstmt.setInt(2, id);
+                }
+
+                pstmt.executeUpdate();
+            }
 
-            pstmt.executeUpdate();
         }
     }