Browse Source

JdbcTemplate preserves order of stored procedure output parameters

Closes gh-22491
pull/22521/head
Juergen Hoeller 7 years ago
parent
commit
1a64d23f9d
  1. 326
      spring-jdbc/src/main/java/org/springframework/jdbc/core/JdbcOperations.java
  2. 107
      spring-jdbc/src/main/java/org/springframework/jdbc/core/JdbcTemplate.java

326
spring-jdbc/src/main/java/org/springframework/jdbc/core/JdbcOperations.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2018 the original author or authors. * Copyright 2002-2019 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -54,10 +54,10 @@ public interface JdbcOperations {
* data access operations, within Spring's managed JDBC environment: * data access operations, within Spring's managed JDBC environment:
* that is, participating in Spring-managed transactions and converting * that is, participating in Spring-managed transactions and converting
* JDBC SQLExceptions into Spring's DataAccessException hierarchy. * JDBC SQLExceptions into Spring's DataAccessException hierarchy.
* <p>The callback action can return a result object, for example a * <p>The callback action can return a result object, for example a domain
* domain object or a collection of domain objects. * object or a collection of domain objects.
* @param action the callback object that specifies the action * @param action a callback object that specifies the action
* @return a result object returned by the action, or {@code null} * @return a result object returned by the action, or {@code null} if none
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@Nullable @Nullable
@ -74,10 +74,10 @@ public interface JdbcOperations {
* access operations on a single Statement, within Spring's managed JDBC * access operations on a single Statement, within Spring's managed JDBC
* environment: that is, participating in Spring-managed transactions and * environment: that is, participating in Spring-managed transactions and
* converting JDBC SQLExceptions into Spring's DataAccessException hierarchy. * converting JDBC SQLExceptions into Spring's DataAccessException hierarchy.
* <p>The callback action can return a result object, for example a * <p>The callback action can return a result object, for example a domain
* domain object or a collection of domain objects. * object or a collection of domain objects.
* @param action callback object that specifies the action * @param action a callback that specifies the action
* @return a result object returned by the action, or {@code null} * @return a result object returned by the action, or {@code null} if none
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@Nullable @Nullable
@ -96,8 +96,8 @@ public interface JdbcOperations {
* <p>Uses a JDBC Statement, not a PreparedStatement. If you want to * <p>Uses a JDBC Statement, not a PreparedStatement. If you want to
* execute a static query with a PreparedStatement, use the overloaded * execute a static query with a PreparedStatement, use the overloaded
* {@code query} method with {@code null} as argument array. * {@code query} method with {@code null} as argument array.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rse object that will extract all rows of results * @param rse a callback that will extract all rows of results
* @return an arbitrary result object, as returned by the ResultSetExtractor * @return an arbitrary result object, as returned by the ResultSetExtractor
* @throws DataAccessException if there is any problem executing the query * @throws DataAccessException if there is any problem executing the query
* @see #query(String, Object[], ResultSetExtractor) * @see #query(String, Object[], ResultSetExtractor)
@ -111,21 +111,21 @@ public interface JdbcOperations {
* <p>Uses a JDBC Statement, not a PreparedStatement. If you want to * <p>Uses a JDBC Statement, not a PreparedStatement. If you want to
* execute a static query with a PreparedStatement, use the overloaded * execute a static query with a PreparedStatement, use the overloaded
* {@code query} method with {@code null} as argument array. * {@code query} method with {@code null} as argument array.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rch object that will extract results, one row at a time * @param rch a callback that will extract results, one row at a time
* @throws DataAccessException if there is any problem executing the query * @throws DataAccessException if there is any problem executing the query
* @see #query(String, Object[], RowCallbackHandler) * @see #query(String, Object[], RowCallbackHandler)
*/ */
void query(String sql, RowCallbackHandler rch) throws DataAccessException; void query(String sql, RowCallbackHandler rch) throws DataAccessException;
/** /**
* Execute a query given static SQL, mapping each row to a Java object * Execute a query given static SQL, mapping each row to a result object
* via a RowMapper. * via a RowMapper.
* <p>Uses a JDBC Statement, not a PreparedStatement. If you want to * <p>Uses a JDBC Statement, not a PreparedStatement. If you want to
* execute a static query with a PreparedStatement, use the overloaded * execute a static query with a PreparedStatement, use the overloaded
* {@code query} method with {@code null} as argument array. * {@code query} method with {@code null} as argument array.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the result List, containing mapped objects * @return the result List, containing mapped objects
* @throws DataAccessException if there is any problem executing the query * @throws DataAccessException if there is any problem executing the query
* @see #query(String, Object[], RowMapper) * @see #query(String, Object[], RowMapper)
@ -133,14 +133,14 @@ public interface JdbcOperations {
<T> List<T> query(String sql, RowMapper<T> rowMapper) throws DataAccessException; <T> List<T> query(String sql, RowMapper<T> rowMapper) throws DataAccessException;
/** /**
* Execute a query given static SQL, mapping a single result row to a Java * Execute a query given static SQL, mapping a single result row to a
* object via a RowMapper. * result object via a RowMapper.
* <p>Uses a JDBC Statement, not a PreparedStatement. If you want to * <p>Uses a JDBC Statement, not a PreparedStatement. If you want to
* execute a static query with a PreparedStatement, use the overloaded * execute a static query with a PreparedStatement, use the overloaded
* {@link #queryForObject(String, RowMapper, Object...)} method with * {@link #queryForObject(String, RowMapper, Object...)} method with
* {@code null} as argument array. * {@code null} as argument array.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the single mapped object (may be {@code null} if the given * @return the single mapped object (may be {@code null} if the given
* {@link RowMapper} returned {@code} null) * {@link RowMapper} returned {@code} null)
* @throws IncorrectResultSizeDataAccessException if the query does not * @throws IncorrectResultSizeDataAccessException if the query does not
@ -160,7 +160,7 @@ public interface JdbcOperations {
* <p>This method is useful for running static SQL with a known outcome. * <p>This method is useful for running static SQL with a known outcome.
* The query is expected to be a single row/single column query; the returned * The query is expected to be a single row/single column query; the returned
* result will be directly mapped to the corresponding object type. * result will be directly mapped to the corresponding object type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param requiredType the type that the result object is expected to match * @param requiredType the type that the result object is expected to match
* @return the result object of the required type, or {@code null} in case of SQL NULL * @return the result object of the required type, or {@code null} in case of SQL NULL
* @throws IncorrectResultSizeDataAccessException if the query does not return * @throws IncorrectResultSizeDataAccessException if the query does not return
@ -180,8 +180,7 @@ public interface JdbcOperations {
* <p>The query is expected to be a single row query; the result row will be * <p>The query is expected to be a single row query; the result row will be
* mapped to a Map (one entry for each column, using the column name as the key). * mapped to a Map (one entry for each column, using the column name as the key).
* @param sql SQL query to execute * @param sql SQL query to execute
* @return the result Map (one entry for each column, using the * @return the result Map (one entry per column, with column name as key)
* column name as the key)
* @throws IncorrectResultSizeDataAccessException if the query does not * @throws IncorrectResultSizeDataAccessException if the query does not
* return exactly one row * return exactly one row
* @throws DataAccessException if there is any problem executing the query * @throws DataAccessException if there is any problem executing the query
@ -197,7 +196,7 @@ public interface JdbcOperations {
* {@code queryForList} method with {@code null} as argument array. * {@code queryForList} method with {@code null} as argument array.
* <p>The results will be mapped to a List (one entry for each row) of * <p>The results will be mapped to a List (one entry for each row) of
* result objects, each of them matching the specified element type. * result objects, each of them matching the specified element type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param elementType the required type of element in the result list * @param elementType the required type of element in the result list
* (for example, {@code Integer.class}) * (for example, {@code Integer.class})
* @return a List of objects that match the specified element type * @return a List of objects that match the specified element type
@ -216,7 +215,7 @@ public interface JdbcOperations {
* Maps (one entry for each column using the column name as the key). * Maps (one entry for each column using the column name as the key).
* Each element in the list will be of the form returned by this interface's * Each element in the list will be of the form returned by this interface's
* queryForMap() methods. * queryForMap() methods.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @return an List that contains a Map per row * @return an List that contains a Map per row
* @throws DataAccessException if there is any problem executing the query * @throws DataAccessException if there is any problem executing the query
* @see #queryForList(String, Object[]) * @see #queryForList(String, Object[])
@ -234,7 +233,7 @@ public interface JdbcOperations {
* be available at runtime: by default, Sun's {@code com.sun.rowset.CachedRowSetImpl} * be available at runtime: by default, Sun's {@code com.sun.rowset.CachedRowSetImpl}
* class is used, which is part of JDK 1.5+ and also available separately as part of * class is used, which is part of JDK 1.5+ and also available separately as part of
* Sun's JDBC RowSet Implementations download (rowset.jar). * Sun's JDBC RowSet Implementations download (rowset.jar).
* @param sql SQL query to execute * @param sql the SQL query to execute
* @return a SqlRowSet representation (possibly a wrapper around a * @return a SqlRowSet representation (possibly a wrapper around a
* {@code javax.sql.rowset.CachedRowSet}) * {@code javax.sql.rowset.CachedRowSet})
* @throws DataAccessException if there is any problem executing the query * @throws DataAccessException if there is any problem executing the query
@ -270,14 +269,14 @@ public interface JdbcOperations {
/** /**
* Execute a JDBC data access operation, implemented as callback action * Execute a JDBC data access operation, implemented as callback action
* working on a JDBC PreparedStatement. This allows for implementing arbitrary * working on a JDBC PreparedStatement. This allows for implementing arbitrary
* data access operations on a single Statement, within Spring's managed * data access operations on a single Statement, within Spring's managed JDBC
* JDBC environment: that is, participating in Spring-managed transactions * environment: that is, participating in Spring-managed transactions and
* and converting JDBC SQLExceptions into Spring's DataAccessException hierarchy. * converting JDBC SQLExceptions into Spring's DataAccessException hierarchy.
* <p>The callback action can return a result object, for example a * <p>The callback action can return a result object, for example a domain
* domain object or a collection of domain objects. * object or a collection of domain objects.
* @param psc object that can create a PreparedStatement given a Connection * @param psc a callback that creates a PreparedStatement given a Connection
* @param action callback object that specifies the action * @param action a callback that specifies the action
* @return a result object returned by the action, or {@code null} * @return a result object returned by the action, or {@code null} if none
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@Nullable @Nullable
@ -286,26 +285,25 @@ public interface JdbcOperations {
/** /**
* Execute a JDBC data access operation, implemented as callback action * Execute a JDBC data access operation, implemented as callback action
* working on a JDBC PreparedStatement. This allows for implementing arbitrary * working on a JDBC PreparedStatement. This allows for implementing arbitrary
* data access operations on a single Statement, within Spring's managed * data access operations on a single Statement, within Spring's managed JDBC
* JDBC environment: that is, participating in Spring-managed transactions * environment: that is, participating in Spring-managed transactions and
* and converting JDBC SQLExceptions into Spring's DataAccessException hierarchy. * converting JDBC SQLExceptions into Spring's DataAccessException hierarchy.
* <p>The callback action can return a result object, for example a * <p>The callback action can return a result object, for example a domain
* domain object or a collection of domain objects. * object or a collection of domain objects.
* @param sql SQL to execute * @param sql the SQL to execute
* @param action callback object that specifies the action * @param action a callback that specifies the action
* @return a result object returned by the action, or {@code null} * @return a result object returned by the action, or {@code null} if none
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@Nullable @Nullable
<T> T execute(String sql, PreparedStatementCallback<T> action) throws DataAccessException; <T> T execute(String sql, PreparedStatementCallback<T> action) throws DataAccessException;
/** /**
* Query using a prepared statement, reading the ResultSet with a * Query using a prepared statement, reading the ResultSet with a ResultSetExtractor.
* ResultSetExtractor.
* <p>A PreparedStatementCreator can either be implemented directly or * <p>A PreparedStatementCreator can either be implemented directly or
* configured through a PreparedStatementCreatorFactory. * configured through a PreparedStatementCreatorFactory.
* @param psc object that can create a PreparedStatement given a Connection * @param psc a callback that creates a PreparedStatement given a Connection
* @param rse object that will extract results * @param rse a callback that will extract results
* @return an arbitrary result object, as returned by the ResultSetExtractor * @return an arbitrary result object, as returned by the ResultSetExtractor
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
* @see PreparedStatementCreatorFactory * @see PreparedStatementCreatorFactory
@ -314,14 +312,13 @@ public interface JdbcOperations {
<T> T query(PreparedStatementCreator psc, ResultSetExtractor<T> rse) throws DataAccessException; <T> T query(PreparedStatementCreator psc, ResultSetExtractor<T> rse) throws DataAccessException;
/** /**
* Query using a prepared statement, reading the ResultSet with a * Query using a prepared statement, reading the ResultSet with a ResultSetExtractor.
* ResultSetExtractor. * @param sql the SQL query to execute
* @param sql SQL query to execute * @param pss a callback that knows how to set values on the prepared statement.
* @param pss object that knows how to set values on the prepared statement.
* If this is {@code null}, the SQL will be assumed to contain no bind parameters. * If this is {@code null}, the SQL will be assumed to contain no bind parameters.
* Even if there are no bind parameters, this object may be used to * Even if there are no bind parameters, this callback may be used to set the
* set fetch size and other performance options. * fetch size and other performance options.
* @param rse object that will extract results * @param rse a callback that will extract results
* @return an arbitrary result object, as returned by the ResultSetExtractor * @return an arbitrary result object, as returned by the ResultSetExtractor
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@ -329,14 +326,13 @@ public interface JdbcOperations {
<T> T query(String sql, @Nullable PreparedStatementSetter pss, ResultSetExtractor<T> rse) throws DataAccessException; <T> T query(String sql, @Nullable PreparedStatementSetter pss, ResultSetExtractor<T> rse) throws DataAccessException;
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list of arguments
* of arguments to bind to the query, reading the ResultSet with a * to bind to the query, reading the ResultSet with a ResultSetExtractor.
* ResultSetExtractor. * @param sql the SQL query to execute
* @param sql SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @param rse object that will extract results * @param rse a callback that will extract results
* @return an arbitrary result object, as returned by the ResultSetExtractor * @return an arbitrary result object, as returned by the ResultSetExtractor
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
* @see java.sql.Types * @see java.sql.Types
@ -345,15 +341,14 @@ public interface JdbcOperations {
<T> T query(String sql, Object[] args, int[] argTypes, ResultSetExtractor<T> rse) throws DataAccessException; <T> T query(String sql, Object[] args, int[] argTypes, ResultSetExtractor<T> rse) throws DataAccessException;
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list of arguments
* of arguments to bind to the query, reading the ResultSet with a * to bind to the query, reading the ResultSet with a ResultSetExtractor.
* ResultSetExtractor. * @param sql the SQL query to execute
* @param sql SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
* only the argument value but also the SQL type and optionally the scale * only the argument value but also the SQL type and optionally the scale
* @param rse object that will extract results * @param rse a callback that will extract results
* @return an arbitrary result object, as returned by the ResultSetExtractor * @return an arbitrary result object, as returned by the ResultSetExtractor
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
*/ */
@ -361,11 +356,10 @@ public interface JdbcOperations {
<T> T query(String sql, Object[] args, ResultSetExtractor<T> rse) throws DataAccessException; <T> T query(String sql, Object[] args, ResultSetExtractor<T> rse) throws DataAccessException;
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list of arguments
* of arguments to bind to the query, reading the ResultSet with a * to bind to the query, reading the ResultSet with a ResultSetExtractor.
* ResultSetExtractor. * @param sql the SQL query to execute
* @param sql SQL query to execute * @param rse a callback that will extract results
* @param rse object that will extract results
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -378,12 +372,12 @@ public interface JdbcOperations {
<T> T query(String sql, ResultSetExtractor<T> rse, @Nullable Object... args) throws DataAccessException; <T> T query(String sql, ResultSetExtractor<T> rse, @Nullable Object... args) throws DataAccessException;
/** /**
* Query using a prepared statement, reading the ResultSet on a per-row * Query using a prepared statement, reading the ResultSet on a per-row basis
* basis with a RowCallbackHandler. * with a RowCallbackHandler.
* <p>A PreparedStatementCreator can either be implemented directly or * <p>A PreparedStatementCreator can either be implemented directly or
* configured through a PreparedStatementCreatorFactory. * configured through a PreparedStatementCreatorFactory.
* @param psc object that can create a PreparedStatement given a Connection * @param psc a callback that creates a PreparedStatement given a Connection
* @param rch object that will extract results, one row at a time * @param rch a callback that will extract results, one row at a time
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
* @see PreparedStatementCreatorFactory * @see PreparedStatementCreatorFactory
*/ */
@ -391,15 +385,14 @@ public interface JdbcOperations {
/** /**
* Query given SQL to create a prepared statement from SQL and a * Query given SQL to create a prepared statement from SQL and a
* PreparedStatementSetter implementation that knows how to bind values * PreparedStatementSetter implementation that knows how to bind values to the
* to the query, reading the ResultSet on a per-row basis with a * query, reading the ResultSet on a per-row basis with a RowCallbackHandler.
* RowCallbackHandler. * @param sql the SQL query to execute
* @param sql SQL query to execute * @param pss a callback that knows how to set values on the prepared statement.
* @param pss object that knows how to set values on the prepared statement.
* If this is {@code null}, the SQL will be assumed to contain no bind parameters. * If this is {@code null}, the SQL will be assumed to contain no bind parameters.
* Even if there are no bind parameters, this object may be used to * Even if there are no bind parameters, this callback may be used to set the
* set fetch size and other performance options. * fetch size and other performance options.
* @param rch object that will extract results, one row at a time * @param rch a callback that will extract results, one row at a time
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
*/ */
void query(String sql, @Nullable PreparedStatementSetter pss, RowCallbackHandler rch) throws DataAccessException; void query(String sql, @Nullable PreparedStatementSetter pss, RowCallbackHandler rch) throws DataAccessException;
@ -408,11 +401,11 @@ public interface JdbcOperations {
* Query given SQL to create a prepared statement from SQL and a list of * Query given SQL to create a prepared statement from SQL and a list of
* arguments to bind to the query, reading the ResultSet on a per-row basis * arguments to bind to the query, reading the ResultSet on a per-row basis
* with a RowCallbackHandler. * with a RowCallbackHandler.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @param rch object that will extract results, one row at a time * @param rch a callback that will extract results, one row at a time
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
* @see java.sql.Types * @see java.sql.Types
*/ */
@ -422,12 +415,12 @@ public interface JdbcOperations {
* Query given SQL to create a prepared statement from SQL and a list of * Query given SQL to create a prepared statement from SQL and a list of
* arguments to bind to the query, reading the ResultSet on a per-row basis * arguments to bind to the query, reading the ResultSet on a per-row basis
* with a RowCallbackHandler. * with a RowCallbackHandler.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
* only the argument value but also the SQL type and optionally the scale * only the argument value but also the SQL type and optionally the scale
* @param rch object that will extract results, one row at a time * @param rch a callback that will extract results, one row at a time
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
*/ */
void query(String sql, Object[] args, RowCallbackHandler rch) throws DataAccessException; void query(String sql, Object[] args, RowCallbackHandler rch) throws DataAccessException;
@ -436,8 +429,8 @@ public interface JdbcOperations {
* Query given SQL to create a prepared statement from SQL and a list of * Query given SQL to create a prepared statement from SQL and a list of
* arguments to bind to the query, reading the ResultSet on a per-row basis * arguments to bind to the query, reading the ResultSet on a per-row basis
* with a RowCallbackHandler. * with a RowCallbackHandler.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rch object that will extract results, one row at a time * @param rch a callback that will extract results, one row at a time
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -448,12 +441,12 @@ public interface JdbcOperations {
void query(String sql, RowCallbackHandler rch, @Nullable Object... args) throws DataAccessException; void query(String sql, RowCallbackHandler rch, @Nullable Object... args) throws DataAccessException;
/** /**
* Query using a prepared statement, mapping each row to a Java object * Query using a prepared statement, mapping each row to a result object
* via a RowMapper. * via a RowMapper.
* <p>A PreparedStatementCreator can either be implemented directly or * <p>A PreparedStatementCreator can either be implemented directly or
* configured through a PreparedStatementCreatorFactory. * configured through a PreparedStatementCreatorFactory.
* @param psc object that can create a PreparedStatement given a Connection * @param psc a callback that creates a PreparedStatement given a Connection
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the result List, containing mapped objects * @return the result List, containing mapped objects
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
* @see PreparedStatementCreatorFactory * @see PreparedStatementCreatorFactory
@ -463,27 +456,27 @@ public interface JdbcOperations {
/** /**
* Query given SQL to create a prepared statement from SQL and a * Query given SQL to create a prepared statement from SQL and a
* PreparedStatementSetter implementation that knows how to bind values * PreparedStatementSetter implementation that knows how to bind values
* to the query, mapping each row to a Java object via a RowMapper. * to the query, mapping each row to a result object via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param pss object that knows how to set values on the prepared statement. * @param pss a callback that knows how to set values on the prepared statement.
* If this is {@code null}, the SQL will be assumed to contain no bind parameters. * If this is {@code null}, the SQL will be assumed to contain no bind parameters.
* Even if there are no bind parameters, this object may be used to * Even if there are no bind parameters, this callback may be used to set the
* set fetch size and other performance options. * fetch size and other performance options.
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the result List, containing mapped objects * @return the result List, containing mapped objects
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
*/ */
<T> List<T> query(String sql, @Nullable PreparedStatementSetter pss, RowMapper<T> rowMapper) throws DataAccessException; <T> List<T> query(String sql, @Nullable PreparedStatementSetter pss, RowMapper<T> rowMapper) throws DataAccessException;
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list of
* of arguments to bind to the query, mapping each row to a Java object * arguments to bind to the query, mapping each row to a result object
* via a RowMapper. * via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the result List, containing mapped objects * @return the result List, containing mapped objects
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
* @see java.sql.Types * @see java.sql.Types
@ -491,26 +484,26 @@ public interface JdbcOperations {
<T> List<T> query(String sql, Object[] args, int[] argTypes, RowMapper<T> rowMapper) throws DataAccessException; <T> List<T> query(String sql, Object[] args, int[] argTypes, RowMapper<T> rowMapper) throws DataAccessException;
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list of
* of arguments to bind to the query, mapping each row to a Java object * arguments to bind to the query, mapping each row to a result object
* via a RowMapper. * via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
* only the argument value but also the SQL type and optionally the scale * only the argument value but also the SQL type and optionally the scale
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the result List, containing mapped objects * @return the result List, containing mapped objects
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
*/ */
<T> List<T> query(String sql, Object[] args, RowMapper<T> rowMapper) throws DataAccessException; <T> List<T> query(String sql, Object[] args, RowMapper<T> rowMapper) throws DataAccessException;
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list of
* of arguments to bind to the query, mapping each row to a Java object * arguments to bind to the query, mapping each row to a result object
* via a RowMapper. * via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -524,13 +517,13 @@ public interface JdbcOperations {
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list
* of arguments to bind to the query, mapping a single result row to a * of arguments to bind to the query, mapping a single result row to a
* Java object via a RowMapper. * result object via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type) * (leaving it to the PreparedStatement to guess the corresponding SQL type)
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the single mapped object (may be {@code null} if the given * @return the single mapped object (may be {@code null} if the given
* {@link RowMapper} returned {@code} null) * {@link RowMapper} returned {@code} null)
* @throws IncorrectResultSizeDataAccessException if the query does not * @throws IncorrectResultSizeDataAccessException if the query does not
@ -544,13 +537,13 @@ public interface JdbcOperations {
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list
* of arguments to bind to the query, mapping a single result row to a * of arguments to bind to the query, mapping a single result row to a
* Java object via a RowMapper. * result object via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
* only the argument value but also the SQL type and optionally the scale * only the argument value but also the SQL type and optionally the scale
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @return the single mapped object (may be {@code null} if the given * @return the single mapped object (may be {@code null} if the given
* {@link RowMapper} returned {@code} null) * {@link RowMapper} returned {@code} null)
* @throws IncorrectResultSizeDataAccessException if the query does not * @throws IncorrectResultSizeDataAccessException if the query does not
@ -563,9 +556,9 @@ public interface JdbcOperations {
/** /**
* Query given SQL to create a prepared statement from SQL and a list * Query given SQL to create a prepared statement from SQL and a list
* of arguments to bind to the query, mapping a single result row to a * of arguments to bind to the query, mapping a single result row to a
* Java object via a RowMapper. * result object via a RowMapper.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param rowMapper object that will map one object per row * @param rowMapper a callback that will map one object per row
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -585,9 +578,9 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result object. * list of arguments to bind to the query, expecting a result object.
* <p>The query is expected to be a single row/single column query; the returned * <p>The query is expected to be a single row/single column query; the returned
* result will be directly mapped to the corresponding object type. * result will be directly mapped to the corresponding object type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @param requiredType the type that the result object is expected to match * @param requiredType the type that the result object is expected to match
* @return the result object of the required type, or {@code null} in case of SQL NULL * @return the result object of the required type, or {@code null} in case of SQL NULL
@ -606,7 +599,7 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result object. * list of arguments to bind to the query, expecting a result object.
* <p>The query is expected to be a single row/single column query; the returned * <p>The query is expected to be a single row/single column query; the returned
* result will be directly mapped to the corresponding object type. * result will be directly mapped to the corresponding object type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -626,7 +619,7 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result object. * list of arguments to bind to the query, expecting a result object.
* <p>The query is expected to be a single row/single column query; the returned * <p>The query is expected to be a single row/single column query; the returned
* result will be directly mapped to the corresponding object type. * result will be directly mapped to the corresponding object type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param requiredType the type that the result object is expected to match * @param requiredType the type that the result object is expected to match
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
@ -647,12 +640,11 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result Map. * list of arguments to bind to the query, expecting a result Map.
* <p>The query is expected to be a single row query; the result row will be * <p>The query is expected to be a single row query; the result row will be
* mapped to a Map (one entry for each column, using the column name as the key). * mapped to a Map (one entry for each column, using the column name as the key).
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @return the result Map (one entry for each column, using the * @return the result Map (one entry per column, with column name as key)
* column name as the key)
* @throws IncorrectResultSizeDataAccessException if the query does not * @throws IncorrectResultSizeDataAccessException if the query does not
* return exactly one row * return exactly one row
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
@ -670,7 +662,7 @@ public interface JdbcOperations {
* one of the queryForObject() methods. * one of the queryForObject() methods.
* <p>The query is expected to be a single row query; the result row will be * <p>The query is expected to be a single row query; the result row will be
* mapped to a Map (one entry for each column, using the column name as the key). * mapped to a Map (one entry for each column, using the column name as the key).
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -690,9 +682,9 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result list. * list of arguments to bind to the query, expecting a result list.
* <p>The results will be mapped to a List (one entry for each row) of * <p>The results will be mapped to a List (one entry for each row) of
* result objects, each of them matching the specified element type. * result objects, each of them matching the specified element type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @param elementType the required type of element in the result list * @param elementType the required type of element in the result list
* (for example, {@code Integer.class}) * (for example, {@code Integer.class})
@ -709,7 +701,7 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result list. * list of arguments to bind to the query, expecting a result list.
* <p>The results will be mapped to a List (one entry for each row) of * <p>The results will be mapped to a List (one entry for each row) of
* result objects, each of them matching the specified element type. * result objects, each of them matching the specified element type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -728,7 +720,7 @@ public interface JdbcOperations {
* list of arguments to bind to the query, expecting a result list. * list of arguments to bind to the query, expecting a result list.
* <p>The results will be mapped to a List (one entry for each row) of * <p>The results will be mapped to a List (one entry for each row) of
* result objects, each of them matching the specified element type. * result objects, each of them matching the specified element type.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param elementType the required type of element in the result list * @param elementType the required type of element in the result list
* (for example, {@code Integer.class}) * (for example, {@code Integer.class})
* @param args arguments to bind to the query * @param args arguments to bind to the query
@ -750,9 +742,9 @@ public interface JdbcOperations {
* Maps (one entry for each column, using the column name as the key). * Maps (one entry for each column, using the column name as the key).
* Thus Each element in the list will be of the form returned by this interface's * Thus Each element in the list will be of the form returned by this interface's
* queryForMap() methods. * queryForMap() methods.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @return a List that contains a Map per row * @return a List that contains a Map per row
* @throws DataAccessException if the query fails * @throws DataAccessException if the query fails
@ -768,7 +760,7 @@ public interface JdbcOperations {
* Maps (one entry for each column, using the column name as the key). * Maps (one entry for each column, using the column name as the key).
* Each element in the list will be of the form returned by this interface's * Each element in the list will be of the form returned by this interface's
* queryForMap() methods. * queryForMap() methods.
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -788,9 +780,9 @@ public interface JdbcOperations {
* be available at runtime: by default, Sun's {@code com.sun.rowset.CachedRowSetImpl} * be available at runtime: by default, Sun's {@code com.sun.rowset.CachedRowSetImpl}
* class is used, which is part of JDK 1.5+ and also available separately as part of * class is used, which is part of JDK 1.5+ and also available separately as part of
* Sun's JDBC RowSet Implementations download (rowset.jar). * Sun's JDBC RowSet Implementations download (rowset.jar).
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @return a SqlRowSet representation (possibly a wrapper around a * @return a SqlRowSet representation (possibly a wrapper around a
* {@code javax.sql.rowset.CachedRowSet}) * {@code javax.sql.rowset.CachedRowSet})
@ -811,7 +803,7 @@ public interface JdbcOperations {
* be available at runtime: by default, Sun's {@code com.sun.rowset.CachedRowSetImpl} * be available at runtime: by default, Sun's {@code com.sun.rowset.CachedRowSetImpl}
* class is used, which is part of JDK 1.5+ and also available separately as part of * class is used, which is part of JDK 1.5+ and also available separately as part of
* Sun's JDBC RowSet Implementations download (rowset.jar). * Sun's JDBC RowSet Implementations download (rowset.jar).
* @param sql SQL query to execute * @param sql the SQL query to execute
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -830,7 +822,7 @@ public interface JdbcOperations {
* using a PreparedStatementCreator to provide SQL and any required parameters. * using a PreparedStatementCreator to provide SQL and any required parameters.
* <p>A PreparedStatementCreator can either be implemented directly or * <p>A PreparedStatementCreator can either be implemented directly or
* configured through a PreparedStatementCreatorFactory. * configured through a PreparedStatementCreatorFactory.
* @param psc object that provides SQL and any necessary parameters * @param psc a callback that provides SQL and any necessary parameters
* @return the number of rows affected * @return the number of rows affected
* @throws DataAccessException if there is any problem issuing the update * @throws DataAccessException if there is any problem issuing the update
* @see PreparedStatementCreatorFactory * @see PreparedStatementCreatorFactory
@ -843,8 +835,8 @@ public interface JdbcOperations {
* <p>Note that the given PreparedStatementCreator has to create a statement * <p>Note that the given PreparedStatementCreator has to create a statement
* with activated extraction of generated keys (a JDBC 3.0 feature). This can * with activated extraction of generated keys (a JDBC 3.0 feature). This can
* either be done directly or through using a PreparedStatementCreatorFactory. * either be done directly or through using a PreparedStatementCreatorFactory.
* @param psc object that provides SQL and any necessary parameters * @param psc a callback that provides SQL and any necessary parameters
* @param generatedKeyHolder KeyHolder that will hold the generated keys * @param generatedKeyHolder a KeyHolder that will hold the generated keys
* @return the number of rows affected * @return the number of rows affected
* @throws DataAccessException if there is any problem issuing the update * @throws DataAccessException if there is any problem issuing the update
* @see PreparedStatementCreatorFactory * @see PreparedStatementCreatorFactory
@ -857,7 +849,7 @@ public interface JdbcOperations {
* with given SQL. Simpler than using a PreparedStatementCreator as this method * with given SQL. Simpler than using a PreparedStatementCreator as this method
* will create the PreparedStatement: The PreparedStatementSetter just needs to * will create the PreparedStatement: The PreparedStatementSetter just needs to
* set parameters. * set parameters.
* @param sql SQL containing bind parameters * @param sql the SQL containing bind parameters
* @param pss helper that sets bind parameters. If this is {@code null} * @param pss helper that sets bind parameters. If this is {@code null}
* we run an update with static SQL. * we run an update with static SQL.
* @return the number of rows affected * @return the number of rows affected
@ -868,9 +860,9 @@ public interface JdbcOperations {
/** /**
* Issue a single SQL update operation (such as an insert, update or delete statement) * Issue a single SQL update operation (such as an insert, update or delete statement)
* via a prepared statement, binding the given arguments. * via a prepared statement, binding the given arguments.
* @param sql SQL containing bind parameters * @param sql the SQL containing bind parameters
* @param args arguments to bind to the query * @param args arguments to bind to the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @return the number of rows affected * @return the number of rows affected
* @throws DataAccessException if there is any problem issuing the update * @throws DataAccessException if there is any problem issuing the update
@ -881,7 +873,7 @@ public interface JdbcOperations {
/** /**
* Issue a single SQL update operation (such as an insert, update or delete statement) * Issue a single SQL update operation (such as an insert, update or delete statement)
* via a prepared statement, binding the given arguments. * via a prepared statement, binding the given arguments.
* @param sql SQL containing bind parameters * @param sql the SQL containing bind parameters
* @param args arguments to bind to the query * @param args arguments to bind to the query
* (leaving it to the PreparedStatement to guess the corresponding SQL type); * (leaving it to the PreparedStatement to guess the corresponding SQL type);
* may also contain {@link SqlParameterValue} objects which indicate not * may also contain {@link SqlParameterValue} objects which indicate not
@ -917,7 +909,7 @@ public interface JdbcOperations {
* Execute a batch using the supplied SQL statement with the batch of supplied arguments. * Execute a batch using the supplied SQL statement with the batch of supplied arguments.
* @param sql the SQL statement to execute. * @param sql the SQL statement to execute.
* @param batchArgs the List of Object arrays containing the batch of arguments for the query * @param batchArgs the List of Object arrays containing the batch of arguments for the query
* @param argTypes SQL types of the arguments * @param argTypes the SQL types of the arguments
* (constants from {@code java.sql.Types}) * (constants from {@code java.sql.Types})
* @return an array containing the numbers of rows affected by each update in the batch * @return an array containing the numbers of rows affected by each update in the batch
*/ */
@ -930,7 +922,7 @@ public interface JdbcOperations {
* @param sql the SQL statement to execute. * @param sql the SQL statement to execute.
* @param batchArgs the List of Object arrays containing the batch of arguments for the query * @param batchArgs the List of Object arrays containing the batch of arguments for the query
* @param batchSize batch size * @param batchSize batch size
* @param pss ParameterizedPreparedStatementSetter to use * @param pss the ParameterizedPreparedStatementSetter to use
* @return an array containing for each batch another array containing the numbers of rows affected * @return an array containing for each batch another array containing the numbers of rows affected
* by each update in the batch * by each update in the batch
* @since 3.1 * @since 3.1
@ -946,14 +938,14 @@ public interface JdbcOperations {
/** /**
* Execute a JDBC data access operation, implemented as callback action * Execute a JDBC data access operation, implemented as callback action
* working on a JDBC CallableStatement. This allows for implementing arbitrary * working on a JDBC CallableStatement. This allows for implementing arbitrary
* data access operations on a single Statement, within Spring's managed * data access operations on a single Statement, within Spring's managed JDBC
* JDBC environment: that is, participating in Spring-managed transactions * environment: that is, participating in Spring-managed transactions and
* and converting JDBC SQLExceptions into Spring's DataAccessException hierarchy. * converting JDBC SQLExceptions into Spring's DataAccessException hierarchy.
* <p>The callback action can return a result object, for example a * <p>The callback action can return a result object, for example a domain
* domain object or a collection of domain objects. * object or a collection of domain objects.
* @param csc object that can create a CallableStatement given a Connection * @param csc a callback that creates a CallableStatement given a Connection
* @param action callback object that specifies the action * @param action a callback that specifies the action
* @return a result object returned by the action, or {@code null} * @return a result object returned by the action, or {@code null} if none
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@Nullable @Nullable
@ -962,25 +954,25 @@ public interface JdbcOperations {
/** /**
* Execute a JDBC data access operation, implemented as callback action * Execute a JDBC data access operation, implemented as callback action
* working on a JDBC CallableStatement. This allows for implementing arbitrary * working on a JDBC CallableStatement. This allows for implementing arbitrary
* data access operations on a single Statement, within Spring's managed * data access operations on a single Statement, within Spring's managed JDBC
* JDBC environment: that is, participating in Spring-managed transactions * environment: that is, participating in Spring-managed transactions and
* and converting JDBC SQLExceptions into Spring's DataAccessException hierarchy. * converting JDBC SQLExceptions into Spring's DataAccessException hierarchy.
* <p>The callback action can return a result object, for example a * <p>The callback action can return a result object, for example a domain
* domain object or a collection of domain objects. * object or a collection of domain objects.
* @param callString the SQL call string to execute * @param callString the SQL call string to execute
* @param action callback object that specifies the action * @param action a callback that specifies the action
* @return a result object returned by the action, or {@code null} * @return a result object returned by the action, or {@code null} if none
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@Nullable @Nullable
<T> T execute(String callString, CallableStatementCallback<T> action) throws DataAccessException; <T> T execute(String callString, CallableStatementCallback<T> action) throws DataAccessException;
/** /**
* Execute a SQL call using a CallableStatementCreator to provide SQL and any * Execute a SQL call using a CallableStatementCreator to provide SQL and
* required parameters. * any required parameters.
* @param csc object that provides SQL and any necessary parameters * @param csc a callback that provides SQL and any necessary parameters
* @param declaredParameters list of declared SqlParameter objects * @param declaredParameters list of declared SqlParameter objects
* @return Map of extracted out parameters * @return a Map of extracted out parameters
* @throws DataAccessException if there is any problem issuing the update * @throws DataAccessException if there is any problem issuing the update
*/ */
Map<String, Object> call(CallableStatementCreator csc, List<SqlParameter> declaredParameters) Map<String, Object> call(CallableStatementCreator csc, List<SqlParameter> declaredParameters)

107
spring-jdbc/src/main/java/org/springframework/jdbc/core/JdbcTemplate.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2018 the original author or authors. * Copyright 2002-2019 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -31,7 +31,6 @@ import java.sql.Statement;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.Collections; import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -105,7 +104,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
private static final String RETURN_UPDATE_COUNT_PREFIX = "#update-count-"; private static final String RETURN_UPDATE_COUNT_PREFIX = "#update-count-";
/** If this variable is false, we will throw exceptions on SQL warnings */ /** If this variable is false, we will throw exceptions on SQL warnings. */
private boolean ignoreWarnings = true; private boolean ignoreWarnings = true;
/** /**
@ -638,11 +637,10 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
* Query using a prepared statement, allowing for a PreparedStatementCreator * Query using a prepared statement, allowing for a PreparedStatementCreator
* and a PreparedStatementSetter. Most other query methods use this method, * and a PreparedStatementSetter. Most other query methods use this method,
* but application code will always work with either a creator or a setter. * but application code will always work with either a creator or a setter.
* @param psc Callback handler that can create a PreparedStatement given a * @param psc a callback that creates a PreparedStatement given a Connection
* Connection * @param pss a callback that knows how to set values on the prepared statement.
* @param pss object that knows how to set values on the prepared statement. * If this is {@code null}, the SQL will be assumed to contain no bind parameters.
* If this is null, the SQL will be assumed to contain no bind parameters. * @param rse a callback that will extract results
* @param rse object that will extract results.
* @return an arbitrary result object, as returned by the ResultSetExtractor * @return an arbitrary result object, as returned by the ResultSetExtractor
* @throws DataAccessException if there is any problem * @throws DataAccessException if there is any problem
*/ */
@ -1022,6 +1020,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
return result; return result;
} }
//------------------------------------------------------------------------- //-------------------------------------------------------------------------
// Methods dealing with callable statements // Methods dealing with callable statements
//------------------------------------------------------------------------- //-------------------------------------------------------------------------
@ -1118,16 +1117,16 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
/** /**
* Extract returned ResultSets from the completed stored procedure. * Extract returned ResultSets from the completed stored procedure.
* @param cs JDBC wrapper for the stored procedure * @param cs a JDBC wrapper for the stored procedure
* @param updateCountParameters Parameter list of declared update count parameters for the stored procedure * @param updateCountParameters the parameter list of declared update count parameters for the stored procedure
* @param resultSetParameters Parameter list of declared resultSet parameters for the stored procedure * @param resultSetParameters the parameter list of declared resultSet parameters for the stored procedure
* @return Map that contains returned results * @return a Map that contains returned results
*/ */
protected Map<String, Object> extractReturnedResults(CallableStatement cs, protected Map<String, Object> extractReturnedResults(CallableStatement cs,
@Nullable List<SqlParameter> updateCountParameters, @Nullable List<SqlParameter> resultSetParameters, @Nullable List<SqlParameter> updateCountParameters, @Nullable List<SqlParameter> resultSetParameters,
int updateCount) throws SQLException { int updateCount) throws SQLException {
Map<String, Object> returnedResults = new HashMap<>(); Map<String, Object> results = new LinkedHashMap<>(4);
int rsIndex = 0; int rsIndex = 0;
int updateIndex = 0; int updateIndex = 0;
boolean moreResults; boolean moreResults;
@ -1136,7 +1135,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
if (updateCount == -1) { if (updateCount == -1) {
if (resultSetParameters != null && resultSetParameters.size() > rsIndex) { if (resultSetParameters != null && resultSetParameters.size() > rsIndex) {
SqlReturnResultSet declaredRsParam = (SqlReturnResultSet) resultSetParameters.get(rsIndex); SqlReturnResultSet declaredRsParam = (SqlReturnResultSet) resultSetParameters.get(rsIndex);
returnedResults.putAll(processResultSet(cs.getResultSet(), declaredRsParam)); results.putAll(processResultSet(cs.getResultSet(), declaredRsParam));
rsIndex++; rsIndex++;
} }
else { else {
@ -1146,7 +1145,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
if (logger.isDebugEnabled()) { if (logger.isDebugEnabled()) {
logger.debug("Added default SqlReturnResultSet parameter named '" + rsName + "'"); logger.debug("Added default SqlReturnResultSet parameter named '" + rsName + "'");
} }
returnedResults.putAll(processResultSet(cs.getResultSet(), undeclaredRsParam)); results.putAll(processResultSet(cs.getResultSet(), undeclaredRsParam));
rsIndex++; rsIndex++;
} }
} }
@ -1155,7 +1154,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
if (updateCountParameters != null && updateCountParameters.size() > updateIndex) { if (updateCountParameters != null && updateCountParameters.size() > updateIndex) {
SqlReturnUpdateCount ucParam = (SqlReturnUpdateCount) updateCountParameters.get(updateIndex); SqlReturnUpdateCount ucParam = (SqlReturnUpdateCount) updateCountParameters.get(updateIndex);
String declaredUcName = ucParam.getName(); String declaredUcName = ucParam.getName();
returnedResults.put(declaredUcName, updateCount); results.put(declaredUcName, updateCount);
updateIndex++; updateIndex++;
} }
else { else {
@ -1164,7 +1163,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
if (logger.isDebugEnabled()) { if (logger.isDebugEnabled()) {
logger.debug("Added default SqlReturnUpdateCount parameter named '" + undeclaredName + "'"); logger.debug("Added default SqlReturnUpdateCount parameter named '" + undeclaredName + "'");
} }
returnedResults.put(undeclaredName, updateCount); results.put(undeclaredName, updateCount);
updateIndex++; updateIndex++;
} }
} }
@ -1177,19 +1176,19 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
} }
while (moreResults || updateCount != -1); while (moreResults || updateCount != -1);
} }
return returnedResults; return results;
} }
/** /**
* Extract output parameters from the completed stored procedure. * Extract output parameters from the completed stored procedure.
* @param cs JDBC wrapper for the stored procedure * @param cs the JDBC wrapper for the stored procedure
* @param parameters parameter list for the stored procedure * @param parameters parameter list for the stored procedure
* @return Map that contains returned results * @return a Map that contains returned results
*/ */
protected Map<String, Object> extractOutputParameters(CallableStatement cs, List<SqlParameter> parameters) protected Map<String, Object> extractOutputParameters(CallableStatement cs, List<SqlParameter> parameters)
throws SQLException { throws SQLException {
Map<String, Object> returnedResults = new HashMap<>(); Map<String, Object> results = new LinkedHashMap<>(parameters.size());
int sqlColIndex = 1; int sqlColIndex = 1;
for (SqlParameter param : parameters) { for (SqlParameter param : parameters) {
if (param instanceof SqlOutParameter) { if (param instanceof SqlOutParameter) {
@ -1198,25 +1197,25 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
SqlReturnType returnType = outParam.getSqlReturnType(); SqlReturnType returnType = outParam.getSqlReturnType();
if (returnType != null) { if (returnType != null) {
Object out = returnType.getTypeValue(cs, sqlColIndex, outParam.getSqlType(), outParam.getTypeName()); Object out = returnType.getTypeValue(cs, sqlColIndex, outParam.getSqlType(), outParam.getTypeName());
returnedResults.put(outParam.getName(), out); results.put(outParam.getName(), out);
} }
else { else {
Object out = cs.getObject(sqlColIndex); Object out = cs.getObject(sqlColIndex);
if (out instanceof ResultSet) { if (out instanceof ResultSet) {
if (outParam.isResultSetSupported()) { if (outParam.isResultSetSupported()) {
returnedResults.putAll(processResultSet((ResultSet) out, outParam)); results.putAll(processResultSet((ResultSet) out, outParam));
} }
else { else {
String rsName = outParam.getName(); String rsName = outParam.getName();
SqlReturnResultSet rsParam = new SqlReturnResultSet(rsName, getColumnMapRowMapper()); SqlReturnResultSet rsParam = new SqlReturnResultSet(rsName, getColumnMapRowMapper());
returnedResults.putAll(processResultSet((ResultSet) out, rsParam)); results.putAll(processResultSet((ResultSet) out, rsParam));
if (logger.isDebugEnabled()) { if (logger.isDebugEnabled()) {
logger.debug("Added default SqlReturnResultSet parameter named '" + rsName + "'"); logger.debug("Added default SqlReturnResultSet parameter named '" + rsName + "'");
} }
} }
} }
else { else {
returnedResults.put(outParam.getName(), out); results.put(outParam.getName(), out);
} }
} }
} }
@ -1224,43 +1223,41 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
sqlColIndex++; sqlColIndex++;
} }
} }
return returnedResults; return results;
} }
/** /**
* Process the given ResultSet from a stored procedure. * Process the given ResultSet from a stored procedure.
* @param rs the ResultSet to process * @param rs the ResultSet to process
* @param param the corresponding stored procedure parameter * @param param the corresponding stored procedure parameter
* @return Map that contains returned results * @return a Map that contains returned results
*/ */
protected Map<String, Object> processResultSet( protected Map<String, Object> processResultSet(
@Nullable ResultSet rs, ResultSetSupportingSqlParameter param) throws SQLException { @Nullable ResultSet rs, ResultSetSupportingSqlParameter param) throws SQLException {
if (rs == null) { if (rs != null) {
return Collections.emptyMap(); try {
} if (param.getRowMapper() != null) {
RowMapper<?> rowMapper = param.getRowMapper();
Map<String, Object> returnedResults = new HashMap<>(); Object result = (new RowMapperResultSetExtractor<>(rowMapper)).extractData(rs);
try { return Collections.singletonMap(param.getName(), result);
if (param.getRowMapper() != null) { }
RowMapper<?> rowMapper = param.getRowMapper(); else if (param.getRowCallbackHandler() != null) {
Object result = (new RowMapperResultSetExtractor<>(rowMapper)).extractData(rs); RowCallbackHandler rch = param.getRowCallbackHandler();
returnedResults.put(param.getName(), result); (new RowCallbackHandlerResultSetExtractor(rch)).extractData(rs);
} return Collections.singletonMap(param.getName(),
else if (param.getRowCallbackHandler() != null) { "ResultSet returned from stored procedure was processed");
RowCallbackHandler rch = param.getRowCallbackHandler(); }
(new RowCallbackHandlerResultSetExtractor(rch)).extractData(rs); else if (param.getResultSetExtractor() != null) {
returnedResults.put(param.getName(), "ResultSet returned from stored procedure was processed"); Object result = param.getResultSetExtractor().extractData(rs);
return Collections.singletonMap(param.getName(), result);
}
} }
else if (param.getResultSetExtractor() != null) { finally {
Object result = param.getResultSetExtractor().extractData(rs); JdbcUtils.closeResultSet(rs);
returnedResults.put(param.getName(), result);
} }
} }
finally { return Collections.emptyMap();
JdbcUtils.closeResultSet(rs);
}
return returnedResults;
} }
@ -1351,8 +1348,8 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
} }
/** /**
* Throw an SQLWarningException if we're not ignoring warnings, * Throw a SQLWarningException if we're not ignoring warnings,
* else log the warnings (at debug level). * otherwise log the warnings at debug level.
* @param stmt the current JDBC statement * @param stmt the current JDBC statement
* @throws SQLWarningException if not ignoring warnings * @throws SQLWarningException if not ignoring warnings
* @see org.springframework.jdbc.SQLWarningException * @see org.springframework.jdbc.SQLWarningException
@ -1374,7 +1371,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
} }
/** /**
* Throw an SQLWarningException if encountering an actual warning. * Throw a SQLWarningException if encountering an actual warning.
* @param warning the warnings object from the current statement. * @param warning the warnings object from the current statement.
* May be {@code null}, in which case this method does nothing. * May be {@code null}, in which case this method does nothing.
* @throws SQLWarningException in case of an actual warning to be raised * @throws SQLWarningException in case of an actual warning to be raised
@ -1388,7 +1385,7 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
/** /**
* Translate the given {@link SQLException} into a generic {@link DataAccessException}. * Translate the given {@link SQLException} into a generic {@link DataAccessException}.
* @param task readable text describing the task being attempted * @param task readable text describing the task being attempted
* @param sql SQL query or update that caused the problem (may be {@code null}) * @param sql the SQL query or update that caused the problem (may be {@code null})
* @param ex the offending {@code SQLException} * @param ex the offending {@code SQLException}
* @return a DataAccessException wrapping the {@code SQLException} (never {@code null}) * @return a DataAccessException wrapping the {@code SQLException} (never {@code null})
* @since 5.0 * @since 5.0
@ -1402,8 +1399,8 @@ public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {
/** /**
* Determine SQL from potential provider object. * Determine SQL from potential provider object.
* @param sqlProvider object that's potentially a SqlProvider * @param sqlProvider object which is potentially a SqlProvider
* @return the SQL string, or {@code null} * @return the SQL string, or {@code null} if not known
* @see SqlProvider * @see SqlProvider
*/ */
@Nullable @Nullable

Loading…
Cancel
Save