com.haulmont.bali.db

Class QueryRunner

java.lang.Object

com.haulmont.bali.db.QueryRunner

public class QueryRunner
extends java.lang.Object

Executes SQL queries with pluggable strategies for handling ResultSets. This class is thread safe.

See Also:

ResultSetHandler

Constructor Summary

Constructors

Constructor and Description
QueryRunner() Constructor for QueryRunner.
QueryRunner(javax.sql.DataSource ds) Constructor for QueryRunner.

Method Summary

Modifier and Type	Method and Description
int[]	batch(java.sql.Connection conn, java.lang.String sql, java.lang.Object[][] params) Execute a batch of SQL INSERT, UPDATE, or DELETE queries.
int[]	batch(java.sql.Connection conn, java.lang.String sql, java.lang.Object[][] params, int[] paramTypes) Execute a batch of SQL INSERT, UPDATE, or DELETE queries.
int[]	batch(java.lang.String sql, java.lang.Object[][] params) Execute a batch of SQL INSERT, UPDATE, or DELETE queries.
int[]	batch(java.lang.String sql, java.lang.Object[][] params, int[] paramTypes) Execute a batch of SQL INSERT, UPDATE, or DELETE queries.
javax.sql.DataSource	getDataSource() Returns the DataSource this runner is using.
<T> T	query(java.sql.Connection conn, java.lang.String sql, java.lang.Object[] params, int[] paramTypes, ResultSetHandler<T> rsh) Execute an SQL SELECT query with replacement parameters.
<T> T	query(java.sql.Connection conn, java.lang.String sql, java.lang.Object[] params, ResultSetHandler<T> rsh) Execute an SQL SELECT query with replacement parameters.
<T> T	query(java.sql.Connection conn, java.lang.String sql, java.lang.Object param, ResultSetHandler<T> rsh) Execute an SQL SELECT query with a single replacement parameter.
<T> T	query(java.sql.Connection conn, java.lang.String sql, ResultSetHandler<T> rsh) Execute an SQL SELECT query without any replacement parameters.
<T> T	query(java.lang.String sql, java.lang.Object[] params, int[] paramTypes, ResultSetHandler<T> rsh) Executes the given SELECT SQL query and returns a result object.
<T> T	query(java.lang.String sql, java.lang.Object[] params, ResultSetHandler<T> rsh) Executes the given SELECT SQL query and returns a result object.
<T> T	query(java.lang.String sql, java.lang.Object param, ResultSetHandler<T> rsh) Executes the given SELECT SQL with a single replacement parameter.
<T> T	query(java.lang.String sql, ResultSetHandler<T> rsh) Executes the given SELECT SQL without any replacement parameters.
void	setDataSource(javax.sql.DataSource dataSource) Sets the DataSource this runner will use to get database connections from.
int	update(java.sql.Connection conn, java.lang.String sql) Execute an SQL INSERT, UPDATE, or DELETE query without replacement parameters.
int	update(java.sql.Connection conn, java.lang.String sql, java.lang.Object param) Execute an SQL INSERT, UPDATE, or DELETE query with a single replacement parameter.
int	update(java.sql.Connection conn, java.lang.String sql, java.lang.Object[] params) Execute an SQL INSERT, UPDATE, or DELETE query.
int	update(java.sql.Connection conn, java.lang.String sql, java.lang.Object[] params, int[] paramTypes) Execute an SQL INSERT, UPDATE, or DELETE query.
int	update(java.lang.String sql) Executes the given INSERT, UPDATE, or DELETE SQL statement without any replacement parameters.
int	update(java.lang.String sql, java.lang.Object param) Executes the given INSERT, UPDATE, or DELETE SQL statement with a single replacement parameter.
int	update(java.lang.String sql, java.lang.Object[] params) Executes the given INSERT, UPDATE, or DELETE SQL statement.
int	update(java.lang.String sql, java.lang.Object[] params, int[] paramTypes) Executes the given INSERT, UPDATE, or DELETE SQL statement.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryRunner

public QueryRunner()

Constructor for QueryRunner.

QueryRunner

public QueryRunner(javax.sql.DataSource ds)

Constructor for QueryRunner. Methods that do not take a Connection parameter will retrieve connections from this DataSource.

Parameters:

ds - The DataSource to retrieve connections from.

Method Detail

batch

public int[] batch(java.sql.Connection conn,
                   java.lang.String sql,
                   java.lang.Object[][] params)
            throws java.sql.SQLException

Execute a batch of SQL INSERT, UPDATE, or DELETE queries.

Parameters:

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.

Returns:

The number of rows updated per statement.

Throws:

java.sql.SQLException - if a database access error occurs

Since:

DbUtils 1.1

batch

public int[] batch(java.sql.Connection conn,
                   java.lang.String sql,
                   java.lang.Object[][] params,
                   int[] paramTypes)
            throws java.sql.SQLException

Execute a batch of SQL INSERT, UPDATE, or DELETE queries.

Parameters:

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.

paramTypes - Query replacement parameters types; null is a valid value to pass in.

Returns:

The number of rows updated per statement.

Throws:

java.sql.SQLException - if a database access error occurs

batch

public int[] batch(java.lang.String sql,
                   java.lang.Object[][] params)
            throws java.sql.SQLException

Execute a batch of SQL INSERT, UPDATE, or DELETE queries. The 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.

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:

The number of rows updated per statement.

Throws:

java.sql.SQLException - if a database access error occurs

Since:

DbUtils 1.1

batch

public int[] batch(java.lang.String sql,
                   java.lang.Object[][] params,
                   int[] paramTypes)
            throws java.sql.SQLException

Execute a batch of SQL INSERT, UPDATE, or DELETE queries. The 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.

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.

paramTypes - Query replacement parameters types; null is a valid value to pass in.

Returns:

The number of rows updated per statement.

Throws:

java.sql.SQLException - if a database access error occurs

getDataSource

public javax.sql.DataSource getDataSource()

Returns the DataSource this runner is using. QueryRunner methods always call this method to get the DataSource so subclasses can provide specialized behavior.

Returns:

DataSource the runner is using

query

public <T> T query(java.sql.Connection conn,
                   java.lang.String sql,
                   java.lang.Object param,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Execute an SQL SELECT query with a single replacement parameter. The caller is responsible for closing the connection.

Parameters:

conn - The connection to execute the query in.

sql - The query to execute.

param - The replacement parameter.

rsh - The handler that converts the results into an object.

Returns:

The object returned by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.sql.Connection conn,
                   java.lang.String sql,
                   java.lang.Object[] params,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Execute an SQL SELECT query with replacement parameters. The caller is responsible for closing the connection.

Parameters:

conn - The connection to execute the query in.

sql - The query to execute.

params - The replacement parameters.

rsh - The handler that converts the results into an object.

Returns:

The object returned by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.sql.Connection conn,
                   java.lang.String sql,
                   java.lang.Object[] params,
                   int[] paramTypes,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Execute an SQL SELECT query with replacement parameters. The caller is responsible for closing the connection.

Parameters:

conn - The connection to execute the query in.

sql - The query to execute.

params - The replacement parameters.

paramTypes - The query replacement parameter types.

rsh - The handler that converts the results into an object.

Returns:

The object returned by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.sql.Connection conn,
                   java.lang.String sql,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Execute an SQL SELECT query without any replacement parameters. The caller is responsible for closing the connection.

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:

The object returned by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.lang.String sql,
                   java.lang.Object param,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Executes the given SELECT SQL with a single replacement parameter. The Connection is retrieved from the DataSource set in the constructor.

Parameters:

sql - The SQL statement to execute.

param - The replacement parameter.

rsh - The handler used to create the result object from the ResultSet.

Returns:

An object generated by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.lang.String sql,
                   java.lang.Object[] params,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Executes the given SELECT SQL query and returns a result object. The Connection is retrieved from the DataSource set in the constructor.

Parameters:

sql - The SQL statement to execute.

params - Initialize the PreparedStatement's IN parameters with this array.

rsh - The handler used to create the result object from the ResultSet.

Returns:

An object generated by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.lang.String sql,
                   java.lang.Object[] params,
                   int[] paramTypes,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Executes the given SELECT SQL query and returns a result object. The Connection is retrieved from the DataSource set in the constructor.

Parameters:

sql - The SQL statement to execute.

params - Initialize the PreparedStatement's IN parameters with this array.

paramTypes - The query replacement parameter types.

rsh - The handler used to create the result object from the ResultSet.

Returns:

An object generated by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

query

public <T> T query(java.lang.String sql,
                   ResultSetHandler<T> rsh)
            throws java.sql.SQLException

Executes the given SELECT SQL without any replacement parameters. The Connection is retrieved from the DataSource set in the constructor.

Parameters:

sql - The SQL statement to execute.

rsh - The handler used to create the result object from the ResultSet.

Returns:

An object generated by the handler.

Throws:

java.sql.SQLException - if a database access error occurs

setDataSource

public void setDataSource(javax.sql.DataSource dataSource)

Sets the DataSource this runner will use to get database connections from. This should be called after creating a runner with the default constructor if you intend to use the execute methods without passing in a Connection.

Parameters:

dataSource - The DataSource to use.

update

public int update(java.sql.Connection conn,
                  java.lang.String sql)
           throws java.sql.SQLException

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:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.sql.Connection conn,
                  java.lang.String sql,
                  java.lang.Object param)
           throws java.sql.SQLException

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:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.sql.Connection conn,
                  java.lang.String sql,
                  java.lang.Object[] params)
           throws java.sql.SQLException

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:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.sql.Connection conn,
                  java.lang.String sql,
                  java.lang.Object[] params,
                  int[] paramTypes)
           throws java.sql.SQLException

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.

paramTypes - The query replacement parameter types.

Returns:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.lang.String sql)
           throws java.sql.SQLException

Executes the given INSERT, UPDATE, or DELETE SQL statement without any replacement parameters. The 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.

Parameters:

sql - The SQL statement to execute.

Returns:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.lang.String sql,
                  java.lang.Object param)
           throws java.sql.SQLException

Executes the given INSERT, UPDATE, or DELETE SQL statement with a single replacement parameter. The 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.

Parameters:

sql - The SQL statement to execute.

param - The replacement parameter.

Returns:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.lang.String sql,
                  java.lang.Object[] params)
           throws java.sql.SQLException

Executes the given INSERT, UPDATE, or DELETE SQL statement. The 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.

Parameters:

sql - The SQL statement to execute.

params - Initializes the PreparedStatement's IN (i.e. '?') parameters.

Returns:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs

update

public int update(java.lang.String sql,
                  java.lang.Object[] params,
                  int[] paramTypes)
           throws java.sql.SQLException

Executes the given INSERT, UPDATE, or DELETE SQL statement. The 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.

Parameters:

sql - The SQL statement to execute.

params - Initializes the PreparedStatement's IN (i.e. '?') parameters.

paramTypes - The query replacement parameter types.

Returns:

The number of rows updated.

Throws:

java.sql.SQLException - if a database access error occurs