preferencesを更新するように

Author: Elic0de

src/main/java/com/github/elic0de/thejpspit/TheJpsPit.java

@@ -174,6 +174,7 @@ private void registerHooks() {
 
     @Override
     public void onDisable() {
+        pitPreferences.ifPresent(preferences -> database.updatePitPreferences(preferences));
         // Plugin shutdown logic
         if (database != null) {
             database.terminate();

src/main/java/com/github/elic0de/thejpspit/database/Database.java

@@ -74,6 +74,8 @@ public abstract CompletableFuture<Optional<Integer>> getPlayerRanking(PitPlayer
 
     public abstract void updateUserData(OfflinePitPlayer player);
 
+    public abstract void updatePitPreferences(PitPreferences pitPreferences);
+
     public abstract void deletePlayerData();
 
     public abstract void terminate();

src/main/java/com/github/elic0de/thejpspit/database/SqLiteDatabase.java

@@ -265,7 +265,7 @@ public void createPitPreferences(PitPreferences pitPreferences) {
         try {
             try (PreparedStatement statement = getConnection().prepareStatement(
                 formatStatementTables("""
-                                    INSERT INTO `%pit_preferences%` (`username`)
+                                    INSERT INTO `%pit_preferences%` (`preferences`)
                                     VALUES (?);"""))) {
 
                 statement.setBytes(1, plugin.getGson().toJson(pitPreferences).getBytes(StandardCharsets.UTF_8));
@@ -327,6 +327,19 @@ public void updateUserData(OfflinePitPlayer player) {
         }
     }
 
+    @Override
+    public void updatePitPreferences(PitPreferences pitPreferences) {
+        try (PreparedStatement statement = getConnection().prepareStatement(formatStatementTables("""
+                UPDATE `%pit_preferences%`
+                SET `preferences` = ?
+                LIMIT 1"""))) {
+            statement.setBytes(2, plugin.getGson().toJson(pitPreferences).getBytes(StandardCharsets.UTF_8));
+            statement.executeUpdate();
+        } catch (SQLException e) {
+            getLogger().log(Level.SEVERE, "Failed to update user in table", e);
+        }
+    }
+
     @Override
     public void deletePlayerData() {
         try (Connection connection = getConnection()) {