From 07126218af754cce63996d309435912364ad217a Mon Sep 17 00:00:00 2001
From: mathias <germannewsmaker@gmail.com>
Date: Thu, 26 Aug 2021 16:29:54 +0200
Subject: [PATCH] Integrated the SQLQuery into the MySQLConnection

---
 .../sqltoolkit/drivers/MySQLConnection.java   | 49 +++++++++++++++++++
 1 file changed, 49 insertions(+)

diff --git a/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java b/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java
index 03b448f..8da4e34 100755
--- a/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java
+++ b/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java
@@ -6,6 +6,7 @@ import de.gnmyt.sqltoolkit.generator.TableGenerator;
 import de.gnmyt.sqltoolkit.manager.*;
 import de.gnmyt.sqltoolkit.querybuilder.AbstractQuery;
 import de.gnmyt.sqltoolkit.querybuilder.QueryBuilder;
+import de.gnmyt.sqltoolkit.querybuilder.SQLQuery;
 import de.gnmyt.sqltoolkit.types.LoginParam;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -124,6 +125,54 @@ public class MySQLConnection {
         }
     }
 
+    /**
+     * Gets a {@link ResultSet} from the server
+     *
+     * @param query The query you want to execute
+     * @return the {@link ResultSet}
+     */
+    public ResultSet getResultSet(SQLQuery query) {
+        return getResultSet(query.getStatement(), query.getParameters());
+    }
+
+    /**
+     * Gets a {@link ResultManager} from the server
+     *
+     * @param query The query you want to execute
+     * @return the {@link ResultManager}
+     */
+    public ResultManager getResult(SQLQuery query) {
+        return getResult(query.getStatement(), query.getParameters());
+    }
+
+    /**
+     * Run an action with the result from your server
+     *
+     * @param query    The query you want to execute
+     * @param consumer The consumer you want to execute
+     */
+    public void getResultSet(SQLQuery query, SQLConsumer<ResultSet> consumer) {
+        try {
+            consumer.accept(getResultSet(query));
+        } catch (Exception e) {
+            LOG.error(e.getMessage());
+        }
+    }
+
+    /**
+     * Run an action with the result from your server (get the manager)
+     *
+     * @param query    The query you want to execute
+     * @param consumer The consumer you want to execute
+     */
+    public void getResult(SQLQuery query, SQLConsumer<ResultManager> consumer) {
+        try {
+            consumer.accept(getResult(query));
+        } catch (Exception e) {
+            LOG.error(e.getMessage());
+        }
+    }
+
     /**
      * Gets a new instance of the {@link QueryBuilder}
      *