public class AsyncQueryRunner extends AbstractQueryRunner
ResultSets. This class is thread safe.ResultSetHandler| Modifier and Type | Class and Description |
|---|---|
protected class |
AsyncQueryRunner.BatchCallableStatement
Deprecated.
No longer used by this class. Will be removed in a future version.
Class that encapsulates the continuation for batch calls.
|
protected class |
AsyncQueryRunner.QueryCallableStatement<T>
Class that encapsulates the continuation for query calls.
|
protected class |
AsyncQueryRunner.UpdateCallableStatement
Deprecated.
No longer used by this class. Will be removed in a future version.
Class that encapsulates the continuation for update calls.
|
ds| Constructor and Description |
|---|
AsyncQueryRunner(boolean pmdKnownBroken,
ExecutorService executorService)
Deprecated.
Use
AsyncQueryRunner(ExecutorService, QueryRunner) instead.
Constructor for AsyncQueryRunner that controls the use of ParameterMetaData. |
AsyncQueryRunner(DataSource ds,
boolean pmdKnownBroken,
ExecutorService executorService)
Deprecated.
Use
AsyncQueryRunner(ExecutorService, QueryRunner) instead.
Constructor for AsyncQueryRunner that take a DataSource and controls the use of ParameterMetaData.
Methods that do not take a Connection parameter will retrieve connections from this
DataSource. |
AsyncQueryRunner(DataSource ds,
ExecutorService executorService)
Deprecated.
Use
AsyncQueryRunner(ExecutorService, QueryRunner) instead.
Constructor for AsyncQueryRunner that takes a DataSource.
Methods that do not take a Connection parameter will retrieve connections from this
DataSource. |
AsyncQueryRunner(ExecutorService executorService)
Constructor for AsyncQueryRunner.
|
AsyncQueryRunner(ExecutorService executorService,
QueryRunner queryRunner)
Constructor for AsyncQueryRunner which uses a provided ExecutorService and underlying QueryRunner.
|
| Modifier and Type | Method and Description |
|---|---|
Future<int[]> |
batch(Connection conn,
String sql,
Object[][] params)
Execute a batch of SQL INSERT, UPDATE, or DELETE queries.
|
Future<int[]> |
batch(String sql,
Object[][] params)
Execute a batch of SQL INSERT, UPDATE, or DELETE queries.
|
<T> Future<T> |
insert(Connection conn,
String sql,
ResultSetHandler<T> rsh)
Executes
QueryRunner.insert(Connection, String, ResultSetHandler) asynchronously. |
<T> Future<T> |
insert(Connection conn,
String sql,
ResultSetHandler<T> rsh,
Object... params)
Executes
QueryRunner.insert(Connection, String, ResultSetHandler, Object...) asynchronously. |
<T> Future<T> |
insert(String sql,
ResultSetHandler<T> rsh)
Executes
QueryRunner.insert(String, ResultSetHandler) asynchronously. |
<T> Future<T> |
insert(String sql,
ResultSetHandler<T> rsh,
Object... params)
Executes
QueryRunner.insert(String, ResultSetHandler, Object...) asynchronously. |
<T> Future<T> |
insertBatch(Connection conn,
String sql,
ResultSetHandler<T> rsh,
Object[][] params)
|
<T> Future<T> |
insertBatch(String sql,
ResultSetHandler<T> rsh,
Object[][] params)
QueryRunner.insertBatch(String, ResultSetHandler, Object[][]) asynchronously. |
<T> Future<T> |
query(Connection conn,
String sql,
ResultSetHandler<T> rsh)
Execute an SQL SELECT query without any replacement parameters.
|
<T> Future<T> |
query(Connection conn,
String sql,
ResultSetHandler<T> rsh,
Object... params)
Execute an SQL SELECT query with replacement parameters.
|
<T> Future<T> |
query(String sql,
ResultSetHandler<T> rsh)
Executes the given SELECT SQL without any replacement parameters.
|
<T> Future<T> |
query(String sql,
ResultSetHandler<T> rsh,
Object... params)
Executes the given SELECT SQL query and returns a result object.
|
Future<Integer> |
update(Connection conn,
String sql)
Execute an SQL INSERT, UPDATE, or DELETE query without replacement
parameters.
|
Future<Integer> |
update(Connection conn,
String sql,
Object... params)
Execute an SQL INSERT, UPDATE, or DELETE query.
|
Future<Integer> |
update(Connection conn,
String sql,
Object param)
Execute an SQL INSERT, UPDATE, or DELETE query with a single replacement
parameter.
|
Future<Integer> |
update(String sql)
Executes the given INSERT, UPDATE, or DELETE SQL statement without
any replacement parameters.
|
Future<Integer> |
update(String sql,
Object... params)
Executes the given INSERT, UPDATE, or DELETE SQL statement.
|
Future<Integer> |
update(String sql,
Object param)
Executes the given INSERT, UPDATE, or DELETE SQL statement with
a single replacement parameter.
|
close, close, close, closeQuietly, closeQuietly, closeQuietly, fillStatement, fillStatement, fillStatementWithBean, fillStatementWithBean, getDataSource, getParameterMetaData, isPmdKnownBroken, prepareCall, prepareConnection, prepareStatement, prepareStatement, rethrow, wrap@Deprecated public AsyncQueryRunner(boolean pmdKnownBroken, ExecutorService executorService)
AsyncQueryRunner(ExecutorService, QueryRunner) instead.
Constructor for AsyncQueryRunner that controls the use of ParameterMetaData.pmdKnownBroken - Some drivers don't support ParameterMetaData.getParameterType(int);
if pmdKnownBroken is set to true, we won't even try it; if false, we'll try it,
and if it breaks, we'll remember not to use it again.executorService - the ExecutorService instance used to run JDBC invocations concurrently.@Deprecated public AsyncQueryRunner(DataSource ds, boolean pmdKnownBroken, ExecutorService executorService)
AsyncQueryRunner(ExecutorService, QueryRunner) instead.
Constructor for AsyncQueryRunner that take a DataSource and controls the use of ParameterMetaData.
Methods that do not take a Connection parameter will retrieve connections from this
DataSource.ds - The DataSource to retrieve connections from.pmdKnownBroken - Some drivers don't support ParameterMetaData.getParameterType(int);
if pmdKnownBroken is set to true, we won't even try it; if false, we'll try it,
and if it breaks, we'll remember not to use it again.executorService - the ExecutorService instance used to run JDBC invocations concurrently.@Deprecated public AsyncQueryRunner(DataSource ds, ExecutorService executorService)
AsyncQueryRunner(ExecutorService, QueryRunner) instead.
Constructor for AsyncQueryRunner that takes a DataSource.
Methods that do not take a Connection parameter will retrieve connections from this
DataSource.ds - The DataSource to retrieve connections from.executorService - the ExecutorService instance used to run JDBC invocations concurrently.public AsyncQueryRunner(ExecutorService executorService)
executorService - the ExecutorService instance used to run JDBC invocations concurrently.public AsyncQueryRunner(ExecutorService executorService, QueryRunner queryRunner)
executorService - the ExecutorService instance used to run JDBC invocations concurrently.queryRunner - the QueryRunner instance to use for the queries.public Future<int[]> batch(Connection conn, String sql, Object[][] params) throws SQLException
conn - The Connection to use to run the query. The caller is
responsible for closing this Connection.sql - The SQL to execute.params - An array of query replacement parameters. Each row in
this array is one set of batch replacement values.Future which returns the number of rows updated per statement.SQLException - if a database access error occurspublic Future<int[]> batch(String sql, Object[][] params) throws SQLException
Connection is retrieved from the DataSource
set in the constructor. This Connection must be in
auto-commit mode or the update will not be saved.sql - The SQL to execute.params - An array of query replacement parameters. Each row in
this array is one set of batch replacement values.Future which returns the number of rows updated per statement.SQLException - if a database access error occurspublic <T> Future<T> insert(Connection conn, String sql, ResultSetHandler<T> rsh) throws SQLException
QueryRunner.insert(Connection, String, ResultSetHandler) asynchronously.T - Return type expectedconn - Connection to use to execute the SQL statementsql - SQL insert statement to executersh - ResultSetHandler for handling the resultsFuture that executes a query runner insertSQLException - if a database access error occursQueryRunner.insert(Connection, String, ResultSetHandler)public <T> Future<T> insert(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException
QueryRunner.insert(Connection, String, ResultSetHandler, Object...) asynchronously.T - Return type expectedconn - Connection to use to execute the SQL statementsql - SQL insert statement to executersh - ResultSetHandler for handling the resultsparams - Parameter values for substitution in the SQL statementFuture that executes a query runner insertSQLException - if a database access error occursQueryRunner.insert(Connection, String, ResultSetHandler, Object...)public <T> Future<T> insert(String sql, ResultSetHandler<T> rsh) throws SQLException
QueryRunner.insert(String, ResultSetHandler) asynchronously.T - Return type expectedsql - SQL insert statement to executersh - ResultSetHandler for handling the resultsFuture that executes a query runner insertSQLException - if a database access error occursQueryRunner.insert(String, ResultSetHandler)public <T> Future<T> insert(String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException
QueryRunner.insert(String, ResultSetHandler, Object...) asynchronously.T - Return type expectedsql - SQL insert statement to executersh - ResultSetHandler for handling the resultsparams - Parameter values for substitution in the SQL statementFuture that executes a query runner insertSQLException - if a database access error occursQueryRunner.insert(String, ResultSetHandler, Object...)public <T> Future<T> insertBatch(Connection conn, String sql, ResultSetHandler<T> rsh, Object[][] params) throws SQLException
T - Return type expectedconn - Connection to use to execute the SQL statementsql - SQL insert statement to executersh - ResultSetHandler for handling the resultsparams - An array of query replacement parameters. Each row in
this array is one set of batch replacement values.Future that executes a query runner batch insertSQLException - if a database access error occursQueryRunner.insertBatch(Connection, String, ResultSetHandler, Object[][])public <T> Future<T> insertBatch(String sql, ResultSetHandler<T> rsh, Object[][] params) throws SQLException
QueryRunner.insertBatch(String, ResultSetHandler, Object[][]) asynchronously.T - Return type expectedsql - SQL insert statement to executersh - ResultSetHandler for handling the resultsparams - An array of query replacement parameters. Each row in
this array is one set of batch replacement values.Future that executes a query runner batch insertSQLException - if a database access error occursQueryRunner.insertBatch(String, ResultSetHandler, Object[][])public <T> Future<T> query(Connection conn, String sql, ResultSetHandler<T> rsh) throws SQLException
T - The type of object that the handler returnsconn - The connection to execute the query in.sql - The query to execute.rsh - The handler that converts the results into an object.Future which returns the result of the query call.SQLException - if a database access error occurspublic <T> Future<T> query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException
T - The type of object that the handler returnsconn - The connection to execute the query in.sql - The query to execute.rsh - The handler that converts the results into an object.params - The replacement parameters.Future which returns the result of the query call.SQLException - if a database access error occurspublic <T> Future<T> query(String sql, ResultSetHandler<T> rsh) throws SQLException
Connection is retrieved from the
DataSource set in the constructor.T - The type of object that the handler returnssql - The SQL statement to execute.rsh - The handler used to create the result object from
the ResultSet.Future which returns the result of the query call.SQLException - if a database access error occurspublic <T> Future<T> query(String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException
Connection is retrieved from the
DataSource set in the constructor.T - The type of object that the handler returnssql - The SQL statement to execute.rsh - The handler used to create the result object from
the ResultSet.params - Initialize the PreparedStatement's IN parameters with
this array.Future which returns the result of the query call.SQLException - if a database access error occurspublic Future<Integer> update(Connection conn, String sql) throws SQLException
conn - The connection to use to run the query.sql - The SQL to execute.Future which returns the number of rows updated.SQLException - if a database access error occurspublic Future<Integer> update(Connection conn, String sql, Object param) throws SQLException
conn - The connection to use to run the query.sql - The SQL to execute.param - The replacement parameter.Future which returns the number of rows updated.SQLException - if a database access error occurspublic Future<Integer> update(Connection conn, String sql, Object... params) throws SQLException
conn - The connection to use to run the query.sql - The SQL to execute.params - The query replacement parameters.Future which returns the number of rows updated.SQLException - if a database access error occurspublic Future<Integer> update(String sql) throws SQLException
Connection is retrieved
from the DataSource set in the constructor. This
Connection must be in auto-commit mode or the update will
not be saved.sql - The SQL statement to execute.Future which returns the number of rows updated.SQLException - if a database access error occurspublic Future<Integer> update(String sql, Object param) throws SQLException
Connection is
retrieved from the DataSource set in the constructor.
This Connection must be in auto-commit mode or the
update will not be saved.sql - The SQL statement to execute.param - The replacement parameter.Future which returns the number of rows updated.SQLException - if a database access error occurspublic Future<Integer> update(String sql, Object... params) throws SQLException
Connection is retrieved from the DataSource
set in the constructor. This Connection must be in
auto-commit mode or the update will not be saved.sql - The SQL statement to execute.params - Initializes the PreparedStatement's IN (i.e. '?')
parameters.Future which returns the number of rows updated.SQLException - if a database access error occursCopyright © 2002–2023 The Apache Software Foundation. All rights reserved.