Java JDBC MySQL-Ausnahme: “Operation nicht erlaubt, nachdem ResultSet geschlossen wurde”

Ich arbeite jetzt seit fast anderthalb Tagen daran und ich kann diesen Fehler nicht express. Ich weiß nicht, warum das ResultSet geschlossen wird. Vielleicht können einige von euch mir helfen.

MySQLdatabase:

package net.gielinor.network.sql; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public abstract class MySQLDatabase { private String host; private String database; private String username; private String password; private Connection connection = null; private Statement statement; public MySQLDatabase(String host, String database, String username, String password) { this.host = host; this.database = database; this.username = username; this.password = password; } public abstract void cycle() throws SQLException; public abstract void ping(); public void connect() { try { Class.forName("com.mysql.jdbc.Driver").newInstance(); connection = DriverManager.getConnection(String.format("jdbc:mysql://%s/%s", host, database), username, password); statement = connection.createStatement(); } catch (Exception e) { e.printStackTrace(); } } public void ping(String table, String variable) { try { statement.executeQuery(String.format("SELECT * FROM `%s` WHERE `%s` = 'null'", table, variable)); } catch (Exception e) { connect(); } } public ResultSet query(String query) throws SQLException { if (query.toLowerCase().startsWith("select")) { return statement.executeQuery(query); } else { statement.executeUpdate(query); } return null; } public Connection getConnection() { return connection; } } 

MySQLHandler

 package net.gielinor.network.sql; import java.io.FileInputStream; import java.util.ArrayList; import java.util.List; import java.util.Properties; import net.gielinor.network.sql.impl.MySQLDonation; public class MySQLHandler extends Thread { private static final MySQLHandler mysqlHandler = new MySQLHandler(); public static MySQLHandler getMySQLHandler() { return mysqlHandler; } private static List updateList; private static String host; private static String database; private static String username; private static String password; @Override public void run() { while (true) { for (MySQLDatabase database : updateList) { try { if (database.getConnection() == null) { database.connect(); } else { database.ping(); } database.cycle(); } catch (Exception ex) { ex.printStackTrace(); } try { Thread.sleep(10000); } catch (Exception ex) { } } } } private static void loadProperties() { Properties p = new Properties(); try { p.load(new FileInputStream("./sql.ini")); host = p.getProperty("host"); database = p.getProperty("database"); username = p.getProperty("username"); password = p.getProperty("password"); } catch (Exception ex) { System.out.println("Error loading MySQL properties."); } } public static String getHost() { return host; } static { loadProperties(); updateList = new ArrayList(); updateList.add(new MySQLDonation(host, database, username, password)); } } 

MySQLDonation

 package net.gielinor.network.sql.impl; import java.sql.ResultSet; import java.sql.SQLException; import net.gielinor.game.model.player.Client; import net.gielinor.game.model.player.PlayerHandler; import net.gielinor.game.model.player.PlayerSave; import net.gielinor.network.sql.MySQLDatabase; public final class MySQLDonation extends MySQLDatabase { public MySQLDonation(String host, String database, String username, String password) { super(host, database, username, password); } @Override public void cycle() throws SQLException { ResultSet results = query("SELECT * FROM `gieli436_purchases`.`donations`"); if (results == null) { return; } while (results.next()) { String username = results.getString("username").replace("_", " "); System.out.println("name=" + username); Client client = (Client) PlayerHandler.getPlayer(username.toLowerCase()); System.out.println(client == null); if (client != null && !client.disconnected) { int creditamount = results.getInt("creditamount"); if (creditamount <= 0) { continue; } handleDonation(client, creditamount); query(String.format("DELETE FROM `gieli436_purchases`.`donations` WHERE `donations`.`username`='%s' LIMIT 1", client.playerName.replaceAll(" ", "_"))); } } } @Override public void ping() { super.ping("donations", "username"); } private void handleDonation(Client client, int creditamount) throws SQLException { client.credits = (client.credits + creditamount); client.sendMessage("Thank you for your purchase. You have received " + creditamount + " store credits."); PlayerSave.save(client); } } 

Die Ausnahme tritt hier auf: In der while-Schleife in MySQLDonation und dem eigentlichen Stacktrace ist dies:

 java.sql.SQLException: Operation not allowed after ResultSet closed at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1055) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:956) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:926) at com.mysql.jdbc.ResultSetImpl.checkClosed(ResultSetImpl.java:794) at com.mysql.jdbc.ResultSetImpl.next(ResultSetImpl.java:7077) at net.gielinor.network.sql.impl.MySQLDonation.cycle(Unknown Source) at net.gielinor.network.sql.MySQLHandler.run(Unknown Source) 

Mit diesen Informationen kann ich sagen, dass dies funktioniert , ich bekomme meine Nachricht und was nicht im Spiel, aber es wiederholt sich, wie der Benutzer nie aus der Abfrage entfernt wird, so gibt es ihnen unendliche Belohnungen. Wenn Sie weitere Informationen benötigen, zögern Sie nicht zu fragen.

Wenn Sie die Delete Abfrage ausführen, verwenden Sie dieselbe Statement , die in der Select Abfrage verwendet wurde. Wenn Sie die Statement erneut ausführen, wird das vorherige ResultSet geschlossen.

Um dies zu vermeiden, sollten Sie jedes Mal, wenn Sie eine Abfrage ausführen, eine neue Statement erstellen. So entfernen Sie die statement = connection.createStatement(); MySQLDatabase Methode connect() in der MySQLDatabase class, und ersetzen Sie alle statement in dieser class durch connection.createStatement() . Sie können die private Variablenanweisung auch vollständig löschen.

Sie können hier mehr darüber lesen.

Dieser Fehler tritt einige Zeit auf, wenn wir dasselbe statementsobjekt für diff verwenden. Arten

check statement objectsss;