Fixed an issue where if a query never went through it'd never run the consumer

parent 5e79bb76
......@@ -113,11 +113,7 @@ public class DatabaseManager implements IDatabaseManager {
return this.threadPool.submit(() -> {
try (Connection connection = getConnection()) {
try (PreparedStatement statement = prepareStatement(connection, command, parameters)) {
Query query = new Query(statement.executeQuery());
if (query.hasResults()) {
consumer.consume(query);
}
consumer.consume(new Query(statement.executeQuery()));
}
} catch (SQLException e) {
e.printStackTrace();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment