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 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 consumer) { + try { + consumer.accept(getResult(query)); + } catch (Exception e) { + LOG.error(e.getMessage()); + } + } + /** * Gets a new instance of the {@link QueryBuilder} *