Package org.apache.commons.dbutils
Class AsyncQueryRunner
java.lang.Object
org.apache.commons.dbutils.AbstractQueryRunner
org.apache.commons.dbutils.AsyncQueryRunner
Executes SQL queries with pluggable strategies for handling
ResultSets. This class is thread safe.- Since:
- 1.4
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected classDeprecated.No longer used by this class.protected classClass that encapsulates the continuation for query calls.protected classDeprecated.No longer used by this class. -
Field Summary
Fields inherited from class org.apache.commons.dbutils.AbstractQueryRunner
ds -
Constructor Summary
ConstructorsConstructorDescriptionAsyncQueryRunner(boolean pmdKnownBroken, ExecutorService executorService) Deprecated.UseAsyncQueryRunner(ExecutorService, QueryRunner)instead.AsyncQueryRunner(ExecutorService executorService) Constructor for AsyncQueryRunner.AsyncQueryRunner(ExecutorService executorService, QueryRunner queryRunner) Constructor for AsyncQueryRunner which uses a provided ExecutorService and underlying QueryRunner.AsyncQueryRunner(DataSource ds, boolean pmdKnownBroken, ExecutorService executorService) Deprecated.UseAsyncQueryRunner(ExecutorService, QueryRunner)instead.AsyncQueryRunner(DataSource ds, ExecutorService executorService) Deprecated.UseAsyncQueryRunner(ExecutorService, QueryRunner)instead. -
Method Summary
Modifier and TypeMethodDescriptionFuture<int[]>Execute a batch of SQL INSERT, UPDATE, or DELETE queries.Future<int[]>batch(Connection conn, String sql, Object[][] params) Execute a batch of SQL INSERT, UPDATE, or DELETE queries.<T> Future<T>insert(String sql, ResultSetHandler<T> rsh) ExecutesQueryRunner.insert(String, ResultSetHandler)asynchronously.<T> Future<T>insert(String sql, ResultSetHandler<T> rsh, Object... params) ExecutesQueryRunner.insert(String, ResultSetHandler, Object...)asynchronously.<T> Future<T>insert(Connection conn, String sql, ResultSetHandler<T> rsh) ExecutesQueryRunner.insert(Connection, String, ResultSetHandler)asynchronously.<T> Future<T>insert(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) ExecutesQueryRunner.insert(Connection, String, ResultSetHandler, Object...)asynchronously.<T> Future<T>insertBatch(String sql, ResultSetHandler<T> rsh, Object[][] params) QueryRunner.insertBatch(String, ResultSetHandler, Object[][])asynchronously.<T> Future<T>insertBatch(Connection conn, String sql, ResultSetHandler<T> rsh, Object[][] params) <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.<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.Executes the given INSERT, UPDATE, or DELETE SQL statement without any replacement parameters.Executes the given INSERT, UPDATE, or DELETE SQL statement with a single replacement parameter.Executes the given INSERT, UPDATE, or DELETE SQL statement.update(Connection conn, String sql) Execute an SQL INSERT, UPDATE, or DELETE query without replacement parameters.update(Connection conn, String sql, Object param) Execute an SQL INSERT, UPDATE, or DELETE query with a single replacement parameter.update(Connection conn, String sql, Object... params) Execute an SQL INSERT, UPDATE, or DELETE query.Methods inherited from class org.apache.commons.dbutils.AbstractQueryRunner
close, close, close, closeQuietly, closeQuietly, closeQuietly, fillStatement, fillStatement, fillStatementWithBean, fillStatementWithBean, getDataSource, getParameterMetaData, isPmdKnownBroken, prepareCall, prepareConnection, prepareStatement, prepareStatement, rethrow, wrap
-
Constructor Details
-
AsyncQueryRunner
Deprecated.UseAsyncQueryRunner(ExecutorService, QueryRunner)instead. Constructor for AsyncQueryRunner that controls the use ofParameterMetaData.- Parameters:
pmdKnownBroken- Some drivers don't supportParameterMetaData.getParameterType(int); ifpmdKnownBrokenis 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- theExecutorServiceinstance used to run JDBC invocations concurrently.
-
AsyncQueryRunner
@Deprecated public AsyncQueryRunner(DataSource ds, boolean pmdKnownBroken, ExecutorService executorService) Deprecated.UseAsyncQueryRunner(ExecutorService, QueryRunner)instead. Constructor for AsyncQueryRunner that take aDataSourceand controls the use ofParameterMetaData. Methods that do not take aConnectionparameter will retrieve connections from thisDataSource.- Parameters:
ds- TheDataSourceto retrieve connections from.pmdKnownBroken- Some drivers don't supportParameterMetaData.getParameterType(int); ifpmdKnownBrokenis 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- theExecutorServiceinstance used to run JDBC invocations concurrently.
-
AsyncQueryRunner
Deprecated.UseAsyncQueryRunner(ExecutorService, QueryRunner)instead. Constructor for AsyncQueryRunner that takes aDataSource. Methods that do not take aConnectionparameter will retrieve connections from thisDataSource.- Parameters:
ds- TheDataSourceto retrieve connections from.executorService- theExecutorServiceinstance used to run JDBC invocations concurrently.
-
AsyncQueryRunner
Constructor for AsyncQueryRunner.- Parameters:
executorService- theExecutorServiceinstance used to run JDBC invocations concurrently.
-
AsyncQueryRunner
Constructor for AsyncQueryRunner which uses a provided ExecutorService and underlying QueryRunner.- Parameters:
executorService- theExecutorServiceinstance used to run JDBC invocations concurrently.queryRunner- theQueryRunnerinstance to use for the queries.- Since:
- 1.5
-
-
Method Details
-
batch
Execute a batch of SQL INSERT, UPDATE, or DELETE queries.- Parameters:
conn- TheConnectionto 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.- Returns:
- A
Futurewhich returns the number of rows updated per statement. - Throws:
SQLException- if a database access error occurs
-
batch
Execute a batch of SQL INSERT, UPDATE, or DELETE queries. TheConnectionis retrieved from theDataSourceset in the constructor. ThisConnectionmust be in auto-commit mode or the update will not be saved.- Parameters:
sql- The SQL to execute.params- An array of query replacement parameters. Each row in this array is one set of batch replacement values.- Returns:
- A
Futurewhich returns the number of rows updated per statement. - Throws:
SQLException- if a database access error occurs
-
insert
public <T> Future<T> insert(Connection conn, String sql, ResultSetHandler<T> rsh) throws SQLException ExecutesQueryRunner.insert(Connection, String, ResultSetHandler)asynchronously.- Type Parameters:
T- Return type expected- Parameters:
conn-Connectionto use to execute the SQL statementsql- SQL insert statement to executersh-ResultSetHandlerfor handling the results- Returns:
Futurethat executes a query runner insert- Throws:
SQLException- if a database access error occurs- Since:
- 1.6
- See Also:
-
insert
public <T> Future<T> insert(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException ExecutesQueryRunner.insert(Connection, String, ResultSetHandler, Object...)asynchronously.- Type Parameters:
T- Return type expected- Parameters:
conn-Connectionto use to execute the SQL statementsql- SQL insert statement to executersh-ResultSetHandlerfor handling the resultsparams- Parameter values for substitution in the SQL statement- Returns:
Futurethat executes a query runner insert- Throws:
SQLException- if a database access error occurs- Since:
- 1.6
- See Also:
-
insert
ExecutesQueryRunner.insert(String, ResultSetHandler)asynchronously.- Type Parameters:
T- Return type expected- Parameters:
sql- SQL insert statement to executersh-ResultSetHandlerfor handling the results- Returns:
Futurethat executes a query runner insert- Throws:
SQLException- if a database access error occurs- Since:
- 1.6
- See Also:
-
insert
public <T> Future<T> insert(String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException ExecutesQueryRunner.insert(String, ResultSetHandler, Object...)asynchronously.- Type Parameters:
T- Return type expected- Parameters:
sql- SQL insert statement to executersh-ResultSetHandlerfor handling the resultsparams- Parameter values for substitution in the SQL statement- Returns:
Futurethat executes a query runner insert- Throws:
SQLException- if a database access error occurs- Since:
- 1.6
- See Also:
-
insertBatch
public <T> Future<T> insertBatch(Connection conn, String sql, ResultSetHandler<T> rsh, Object[][] params) throws SQLException - Type Parameters:
T- Return type expected- Parameters:
conn-Connectionto use to execute the SQL statementsql- SQL insert statement to executersh-ResultSetHandlerfor handling the resultsparams- An array of query replacement parameters. Each row in this array is one set of batch replacement values.- Returns:
Futurethat executes a query runner batch insert- Throws:
SQLException- if a database access error occurs- Since:
- 1.6
- See Also:
-
insertBatch
public <T> Future<T> insertBatch(String sql, ResultSetHandler<T> rsh, Object[][] params) throws SQLException QueryRunner.insertBatch(String, ResultSetHandler, Object[][])asynchronously.- Type Parameters:
T- Return type expected- Parameters:
sql- SQL insert statement to executersh-ResultSetHandlerfor handling the resultsparams- An array of query replacement parameters. Each row in this array is one set of batch replacement values.- Returns:
Futurethat executes a query runner batch insert- Throws:
SQLException- if a database access error occurs- Since:
- 1.6
- See Also:
-
query
public <T> Future<T> query(Connection conn, String sql, ResultSetHandler<T> rsh) throws SQLException Execute an SQL SELECT query without any replacement parameters. The caller is responsible for closing the connection.- Type Parameters:
T- The type of object that the handler returns- Parameters:
conn- The connection to execute the query in.sql- The query to execute.rsh- The handler that converts the results into an object.- Returns:
- A
Futurewhich returns the result of the query call. - Throws:
SQLException- if a database access error occurs
-
query
public <T> Future<T> query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException Execute an SQL SELECT query with replacement parameters. The caller is responsible for closing the connection.- Type Parameters:
T- The type of object that the handler returns- Parameters:
conn- 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.- Returns:
- A
Futurewhich returns the result of the query call. - Throws:
SQLException- if a database access error occurs
-
query
Executes the given SELECT SQL without any replacement parameters. TheConnectionis retrieved from theDataSourceset in the constructor.- Type Parameters:
T- The type of object that the handler returns- Parameters:
sql- The SQL statement to execute.rsh- The handler used to create the result object from theResultSet.- Returns:
- A
Futurewhich returns the result of the query call. - Throws:
SQLException- if a database access error occurs
-
query
public <T> Future<T> query(String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException Executes the given SELECT SQL query and returns a result object. TheConnectionis retrieved from theDataSourceset in the constructor.- Type Parameters:
T- The type of object that the handler returns- Parameters:
sql- The SQL statement to execute.rsh- The handler used to create the result object from theResultSet.params- Initialize the PreparedStatement's IN parameters with this array.- Returns:
- A
Futurewhich returns the result of the query call. - Throws:
SQLException- if a database access error occurs
-
update
Execute an SQL INSERT, UPDATE, or DELETE query without replacement parameters.- Parameters:
conn- The connection to use to run the query.sql- The SQL to execute.- Returns:
- A
Futurewhich returns the number of rows updated. - Throws:
SQLException- if a database access error occurs
-
update
Execute an SQL INSERT, UPDATE, or DELETE query with a single replacement parameter.- Parameters:
conn- The connection to use to run the query.sql- The SQL to execute.param- The replacement parameter.- Returns:
- A
Futurewhich returns the number of rows updated. - Throws:
SQLException- if a database access error occurs
-
update
Execute an SQL INSERT, UPDATE, or DELETE query.- Parameters:
conn- The connection to use to run the query.sql- The SQL to execute.params- The query replacement parameters.- Returns:
- A
Futurewhich returns the number of rows updated. - Throws:
SQLException- if a database access error occurs
-
update
Executes the given INSERT, UPDATE, or DELETE SQL statement without any replacement parameters. TheConnectionis retrieved from theDataSourceset in the constructor. ThisConnectionmust be in auto-commit mode or the update will not be saved.- Parameters:
sql- The SQL statement to execute.- Returns:
- A
Futurewhich returns the number of rows updated. - Throws:
SQLException- if a database access error occurs
-
update
Executes the given INSERT, UPDATE, or DELETE SQL statement with a single replacement parameter. TheConnectionis retrieved from theDataSourceset in the constructor. ThisConnectionmust be in auto-commit mode or the update will not be saved.- Parameters:
sql- The SQL statement to execute.param- The replacement parameter.- Returns:
- A
Futurewhich returns the number of rows updated. - Throws:
SQLException- if a database access error occurs
-
update
Executes the given INSERT, UPDATE, or DELETE SQL statement. TheConnectionis retrieved from theDataSourceset in the constructor. ThisConnectionmust be in auto-commit mode or the update will not be saved.- Parameters:
sql- The SQL statement to execute.params- Initializes the PreparedStatement's IN (i.e. '?') parameters.- Returns:
- A
Futurewhich returns the number of rows updated. - Throws:
SQLException- if a database access error occurs
-