|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.jdbc.object.RdbmsOperation
org.springframework.jdbc.object.SqlOperation
org.springframework.jdbc.object.SqlUpdate
org.springframework.jdbc.object.BatchSqlUpdate
public class BatchSqlUpdate
SqlUpdate subclass that performs batch update operations. Encapsulates
queuing up records to be updated, and adds them as a single batch once
flush
is called or the given batch size has been met.
Note that this class is a non-thread-safe object, in contrast
to all other JDBC operations objects in this package. You need to create
a new instance of it for each use, or call reset
before
reuse within the same thread.
flush()
,
reset()
Field Summary | |
---|---|
private int |
batchSize
|
static int |
DEFAULT_BATCH_SIZE
Default number of inserts to accumulate before commiting a batch (5000). |
private java.util.LinkedList<java.lang.Object[]> |
parameterQueue
|
private java.util.List<java.lang.Integer> |
rowsAffected
|
private boolean |
trackRowsAffected
|
Fields inherited from class org.springframework.jdbc.object.RdbmsOperation |
---|
logger |
Constructor Summary | |
---|---|
BatchSqlUpdate()
Constructor to allow use as a JavaBean. |
|
BatchSqlUpdate(javax.sql.DataSource ds,
java.lang.String sql)
Construct an update object with a given DataSource and SQL. |
|
BatchSqlUpdate(javax.sql.DataSource ds,
java.lang.String sql,
int[] types)
Construct an update object with a given DataSource, SQL and anonymous parameters. |
|
BatchSqlUpdate(javax.sql.DataSource ds,
java.lang.String sql,
int[] types,
int batchSize)
Construct an update object with a given DataSource, SQL, anonymous parameters and specifying the maximum number of rows that may be affected. |
Method Summary | |
---|---|
int[] |
flush()
Trigger any queued update operations to be added as a final batch. |
int |
getExecutionCount()
Return the number of already executed statements. |
int |
getQueueCount()
Return the current number of statements or statement parameters in the queue. |
int[] |
getRowsAffected()
Return the number of affected rows for all already executed statements. |
void |
reset()
Reset the statement parameter queue, the rows affected cache, and the execution count. |
void |
setBatchSize(int batchSize)
Set the number of statements that will trigger an automatic intermediate flush. |
void |
setTrackRowsAffected(boolean trackRowsAffected)
Set whether to track the rows affected by batch updates performed by this operation object. |
protected boolean |
supportsLobParameters()
BatchSqlUpdate does not support BLOB or CLOB parameters. |
int |
update(java.lang.Object... params)
Overridden version of update that adds the given statement
parameters to the queue rather than executing them immediately. |
Methods inherited from class org.springframework.jdbc.object.SqlUpdate |
---|
checkRowsAffected, setMaxRowsAffected, setRequiredRowsAffected, update, update, update, update, update, update, update, update, updateByNamedParam, updateByNamedParam |
Methods inherited from class org.springframework.jdbc.object.SqlOperation |
---|
compileInternal, getParsedSql, newPreparedStatementCreator, newPreparedStatementCreator, newPreparedStatementSetter, onCompileInternal |
Methods inherited from class org.springframework.jdbc.object.RdbmsOperation |
---|
afterPropertiesSet, allowsUnusedParameters, checkCompiled, compile, declareParameter, getDeclaredParameters, getGeneratedKeysColumnNames, getJdbcTemplate, getResultSetType, getSql, isCompiled, isReturnGeneratedKeys, isUpdatableResults, setDataSource, setFetchSize, setGeneratedKeysColumnNames, setJdbcTemplate, setMaxRows, setParameters, setQueryTimeout, setResultSetType, setReturnGeneratedKeys, setSql, setTypes, setUpdatableResults, validateNamedParameters, validateParameters |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static int DEFAULT_BATCH_SIZE
private int batchSize
private boolean trackRowsAffected
private final java.util.LinkedList<java.lang.Object[]> parameterQueue
private final java.util.List<java.lang.Integer> rowsAffected
Constructor Detail |
---|
public BatchSqlUpdate()
RdbmsOperation.setDataSource(javax.sql.DataSource)
,
RdbmsOperation.setSql(java.lang.String)
public BatchSqlUpdate(javax.sql.DataSource ds, java.lang.String sql)
ds
- DataSource to use to obtain connectionssql
- SQL statement to executepublic BatchSqlUpdate(javax.sql.DataSource ds, java.lang.String sql, int[] types)
ds
- DataSource to use to obtain connectionssql
- SQL statement to executetypes
- SQL types of the parameters, as defined in the
java.sql.Types
classTypes
public BatchSqlUpdate(javax.sql.DataSource ds, java.lang.String sql, int[] types, int batchSize)
ds
- DataSource to use to obtain connectionssql
- SQL statement to executetypes
- SQL types of the parameters, as defined in the
java.sql.Types
classbatchSize
- the number of statements that will trigger
an automatic intermediate flushTypes
Method Detail |
---|
public void setBatchSize(int batchSize)
update
calls or the given statement parameters will
be queued until the batch size is met, at which point it will empty the
queue and execute the batch.
You can also flush already queued statements with an explicit
flush
call. Note that you need to this after queueing
all parameters to guarantee that all statements have been flushed.
public void setTrackRowsAffected(boolean trackRowsAffected)
Default is "true". Turn this off to save the memory needed for the list of row counts.
getRowsAffected()
protected boolean supportsLobParameters()
supportsLobParameters
in class RdbmsOperation
public int update(java.lang.Object... params) throws DataAccessException
update
that adds the given statement
parameters to the queue rather than executing them immediately.
All other update
methods of the SqlUpdate base class go
through this method and will thus behave similarly.
You need to call flush
to actually execute the batch.
If the specified batch size is reached, an implicit flush will happen;
you still need to finally call flush
to flush all statements.
update
in class SqlUpdate
params
- array of parameter objects
DataAccessException
flush()
public int[] flush()
public int getQueueCount()
public int getExecutionCount()
public int[] getRowsAffected()
flush
's return values until
reset
is invoked.
reset()
public void reset()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |