diff --git a/common/src/main/java/net/william278/husksync/database/PostgresDatabase.java b/common/src/main/java/net/william278/husksync/database/PostgresDatabase.java index 4dc8f4d1..6701fb7c 100644 --- a/common/src/main/java/net/william278/husksync/database/PostgresDatabase.java +++ b/common/src/main/java/net/william278/husksync/database/PostgresDatabase.java @@ -330,13 +330,13 @@ public class PostgresDatabase extends Database { try (PreparedStatement statement = connection.prepareStatement(formatStatementTables(""" WITH cte AS ( SELECT id - FROM user_data_table + FROM %user_data_table% WHERE player_uuid=? AND pinned=FALSE ORDER BY timestamp ASC LIMIT %entry_count% ) - DELETE FROM user_data_table + DELETE FROM %user_data_table% WHERE id IN (SELECT id FROM cte);""".replace("%entry_count%", Integer.toString(unpinnedUserData.size() - maxSnapshots))))) { statement.setObject(1, user.getUuid()); @@ -434,7 +434,7 @@ public class PostgresDatabase extends Database { public void wipeDatabase() { try (Connection connection = getConnection()) { try (Statement statement = connection.createStatement()) { - statement.executeUpdate(formatStatementTables("DELETE FROM \"%user_data_table%\";")); + statement.executeUpdate(formatStatementTables("DELETE FROM %user_data_table%;")); } } catch (SQLException e) { plugin.log(Level.SEVERE, "Failed to wipe the database", e);