From fefbebeb3a9065f901556159fce985e3d5fc3000 Mon Sep 17 00:00:00 2001 From: mathias Date: Fri, 20 Aug 2021 14:53:12 +0200 Subject: [PATCH] Updated the consumer methods in the MySQLConnection --- .../SQLToolkit/drivers/MySQLConnection.java | 24 +++++++++++++++---- 1 file changed, 19 insertions(+), 5 deletions(-) diff --git a/src/main/java/de/gnmyt/SQLToolkit/drivers/MySQLConnection.java b/src/main/java/de/gnmyt/SQLToolkit/drivers/MySQLConnection.java index 69d7d5c..a6e8764 100755 --- a/src/main/java/de/gnmyt/SQLToolkit/drivers/MySQLConnection.java +++ b/src/main/java/de/gnmyt/SQLToolkit/drivers/MySQLConnection.java @@ -99,12 +99,26 @@ public class MySQLConnection { * @param consumer The consumer * @param params The optional parameters */ - public void getResult(String query, SQLConsumer consumer, Object... params) { + public void getResultSet(String query, SQLConsumer consumer, Object... params) { try { - ResultSet resultSet = getResultSet(query, params); - consumer.accept(resultSet); - resultSet.close(); - } catch (Exception ignored) { + consumer.accept(getResultSet(query, params)); + } catch (Exception e) { + LOG.error(e.getMessage()); + } + } + + /** + * Run an action with a result from your server + * + * @param query The search query + * @param consumer The consumer + * @param params The optional parameters + */ + public void getResult(String query, SQLConsumer consumer, Object... params) { + try { + consumer.accept(getResult(query, params)); + } catch (Exception e) { + LOG.error(e.getMessage()); } }