Integrated the SQLQuery into the MySQLConnection

This commit is contained in:
mathias 2021-08-26 16:29:54 +02:00
parent 357a69f3ac
commit 07126218af
No known key found for this signature in database
GPG Key ID: 8950DF62139C852A

View File

@ -6,6 +6,7 @@ import de.gnmyt.sqltoolkit.generator.TableGenerator;
import de.gnmyt.sqltoolkit.manager.*; import de.gnmyt.sqltoolkit.manager.*;
import de.gnmyt.sqltoolkit.querybuilder.AbstractQuery; import de.gnmyt.sqltoolkit.querybuilder.AbstractQuery;
import de.gnmyt.sqltoolkit.querybuilder.QueryBuilder; import de.gnmyt.sqltoolkit.querybuilder.QueryBuilder;
import de.gnmyt.sqltoolkit.querybuilder.SQLQuery;
import de.gnmyt.sqltoolkit.types.LoginParam; import de.gnmyt.sqltoolkit.types.LoginParam;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; 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} * Gets a new instance of the {@link QueryBuilder}
* *