diff --git a/src/main/java/net/tylermurphy/ken/database/SelfRoleTable.java b/src/main/java/net/tylermurphy/ken/database/SelfRoleTable.java index 5ad289c..f44f6a2 100644 --- a/src/main/java/net/tylermurphy/ken/database/SelfRoleTable.java +++ b/src/main/java/net/tylermurphy/ken/database/SelfRoleTable.java @@ -55,13 +55,20 @@ public class SelfRoleTable { } public boolean deleteData(long guildId, int page){ - String sql = "DELETE FROM self_role_data WHERE guild_id = ? AND page = ?; UPDATE self_role_data SET page = page - 1 WHERE guild_id = ? AND page > ?;"; - try(Connection connection = database.connect(); PreparedStatement statement = connection.prepareStatement(sql)) { - statement.setLong(1, guildId); - statement.setInt(2, page); - statement.setLong(3, guildId); - statement.setInt(4, page); - return statement.executeUpdate() != 0; + try(Connection connection = database.connect();) { + String sql = "DELETE FROM self_role_data WHERE guild_id = ? AND page = ?;"; + try(PreparedStatement statement = connection.prepareStatement(sql)){ + statement.setLong(1, guildId); + statement.setInt(2, page); + statement.executeUpdate(); + } + sql = "UPDATE self_role_data SET page = page - 1 WHERE guild_id = ? AND page > ?;"; + try(PreparedStatement statement = connection.prepareStatement(sql)){ + statement.setLong(1, guildId); + statement.setInt(2, page); + statement.executeUpdate(); + } + return true; } catch (SQLException e) { Ken.getInstance().getLogger().error("SQL Error: " + e.getMessage()); return false;