org.apache.commons.dbutils.AbstractQueryRunner
org.apache.commons.dbutils.AsyncQueryRunner
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Object
public class AsyncQueryRunner
Executes SQL queries with pluggable strategies for handling
ResultSets. This class is thread safe.
ResultSetHandler| Nested Class Summary | |
|---|---|
protected class |
AsyncQueryRunner.BatchCallableStatement
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
Class that encapsulates the continuation for update calls. |
| Field Summary |
|---|
| Fields inherited from class org.apache.commons.dbutils.AbstractQueryRunner |
|---|
ds |
| Constructor Summary | |
|---|---|
AsyncQueryRunner(boolean pmdKnownBroken,
ExecutorService executorService)
Constructor for AsyncQueryRunner, allows workaround for Oracle drivers |
|
AsyncQueryRunner(DataSource ds,
boolean pmdKnownBroken,
ExecutorService executorService)
Constructor for QueryRunner, allows workaround for Oracle drivers. |
|
AsyncQueryRunner(DataSource ds,
ExecutorService executorService)
Constructor for AsyncQueryRunner which takes a DataSource. |
|
AsyncQueryRunner(ExecutorService executorService)
Constructor for AsyncQueryRunner. |
|
| Method Summary | ||
|---|---|---|
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. |
|
|
query(Connection conn,
String sql,
ResultSetHandler<T> rsh)
Execute an SQL SELECT query without any replacement parameters. |
|
|
query(Connection conn,
String sql,
ResultSetHandler<T> rsh,
Object... params)
Execute an SQL SELECT query with replacement parameters. |
|
|
query(String sql,
ResultSetHandler<T> rsh)
Executes the given SELECT SQL without any replacement parameters. |
|
|
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. |
|
| Methods inherited from class org.apache.commons.dbutils.AbstractQueryRunner |
|---|
close, close, close, fillStatement, fillStatementWithBean, fillStatementWithBean, getDataSource, isPmdKnownBroken, prepareConnection, prepareStatement, rethrow, wrap |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AsyncQueryRunner(ExecutorService executorService)
executorService - the ExecutorService instance used to run JDBC invocations concurrently.
public AsyncQueryRunner(boolean pmdKnownBroken,
ExecutorService executorService)
pmdKnownBroken - Oracle 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.
public AsyncQueryRunner(DataSource ds,
ExecutorService executorService)
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(DataSource ds,
boolean pmdKnownBroken,
ExecutorService executorService)
Connection parameter will retrieve connections from this
DataSource.
ds - The DataSource to retrieve connections from.pmdKnownBroken - Oracle 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.| Method Detail |
|---|
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 occurs
public 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 occurs
public <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 occurs
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 occurs
public <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 occurs
public <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 occurs
public 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 occurs
public 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 occurs
public 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 occurs
public 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 occurs
public 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 occurs
public 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 occurs
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||