Package liquibase.statement

Class BatchDmlExecutablePreparedStatement

java.lang.Object

liquibase.statement.ExecutablePreparedStatementBase

liquibase.statement.BatchDmlExecutablePreparedStatement

All Implemented Interfaces:

ExecutablePreparedStatement, SqlStatement

public class BatchDmlExecutablePreparedStatement
extends ExecutablePreparedStatementBase

Performance-optimised version of ExecutablePreparedStatementBase. JDBC batching collects several executions of DML statements and waits until a certain number of commands has been collected. Then, it sends all of them to the RDBMS in a single call. Statement.executeBatch() saves many round-trips between client and database, often speeding up bulk inserts/updates dramatically if the JDBC driver supports it.

See Also:

Blog entry on "Java Persistence Performance" about batching

Nested Class Summary

Nested classes/interfaces inherited from class liquibase.statement.ExecutablePreparedStatementBase

ExecutablePreparedStatementBase.LOBContent<T>

Field Summary

Fields inherited from class liquibase.statement.ExecutablePreparedStatementBase

coreBundle, database

Fields inherited from interface liquibase.statement.SqlStatement

EMPTY_SQL_STATEMENT

Constructor Summary

Constructors

Constructor	Description
BatchDmlExecutablePreparedStatement(Database database, String catalogName, String schemaName, String tableName, List<LoadDataColumnConfig> columns, ChangeSet changeSet, ResourceAccessor resourceAccessor, List<ExecutablePreparedStatementBase> statements)

Method Summary

Modifier and Type	Method	Description
protected void	attachParams(List<? extends ColumnConfig> ignored, PreparedStatement stmt)	Sets the list of bind variables for the execution of a DML statement
boolean	continueOnError()
protected void	executePreparedStatement(PreparedStatement stmt)
protected String	generateSql(List<ColumnConfig> cols)
List<ExecutablePreparedStatementBase>	getIndividualStatements()	Returns the individual statements that are currently store in this batch.

Methods inherited from class liquibase.statement.ExecutablePreparedStatementBase

applyColumnParameter, applyVisitors, createStream, execute, getCachedStatement, getCatalogName, getChangeSet, getColumns, getContentLength, getContentLength, getResourceAccessor, getResourceAsStream, getSchemaName, getTableName, skipOnUnsupported, toBinaryStream, toCharacterStream

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchDmlExecutablePreparedStatement

public BatchDmlExecutablePreparedStatement(Database database,
                                           String catalogName,
                                           String schemaName,
                                           String tableName,
                                           List<LoadDataColumnConfig> columns,
                                           ChangeSet changeSet,
                                           ResourceAccessor resourceAccessor,
                                           List<ExecutablePreparedStatementBase> statements)

Method Detail

getIndividualStatements

public List<ExecutablePreparedStatementBase> getIndividualStatements()

Returns the individual statements that are currently store in this batch.

Returns:

the List of the stored statements (may be empty if none are stored)

attachParams

protected void attachParams(List<? extends ColumnConfig> ignored,
                            PreparedStatement stmt)
                     throws SQLException,
                            DatabaseException

Description copied from class: ExecutablePreparedStatementBase

Sets the list of bind variables for the execution of a DML statement

Overrides:

attachParams in class ExecutablePreparedStatementBase

Parameters:

ignored - a list of columns with their designated values

stmt - the PreparedStatement to which the values are to be attached

Throws:

SQLException - if JDBC objects to a setting (non-existent bind number, wrong column type etc.)

DatabaseException - if an I/O error occurs during the read of LOB values

generateSql

protected String generateSql(List<ColumnConfig> cols)

Specified by:

generateSql in class ExecutablePreparedStatementBase

executePreparedStatement

protected void executePreparedStatement(PreparedStatement stmt)
                                 throws SQLException

Overrides:

executePreparedStatement in class ExecutablePreparedStatementBase

Throws:

SQLException

continueOnError

public boolean continueOnError()