org.camunda.bpm.engine.impl.db.sql

Class BatchDbSqlSession

java.lang.Object

org.camunda.bpm.engine.impl.db.AbstractPersistenceSession

org.camunda.bpm.engine.impl.db.sql.DbSqlSession

org.camunda.bpm.engine.impl.db.sql.BatchDbSqlSession

All Implemented Interfaces:

PersistenceSession, Session

public class BatchDbSqlSession
extends DbSqlSession

For mybatis ExecutorType.BATCH

Field Summary

Fields inherited from class org.camunda.bpm.engine.impl.db.sql.DbSqlSession

connectionMetadataDefaultCatalog, connectionMetadataDefaultSchema, dbSqlSessionFactory, JDBC_METADATA_TABLE_TYPES, LOG, PG_JDBC_METADATA_TABLE_TYPES, sqlSession

Fields inherited from class org.camunda.bpm.engine.impl.db.AbstractPersistenceSession

listeners

Constructor Summary

Constructors

Constructor and Description
BatchDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)
BatchDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory, Connection connection, String catalog, String schema)

Method Summary

Modifier and Type	Method and Description
protected void	deleteBulk(DbBulkOperation operation)
protected void	deleteEntity(DbEntityOperation operation)
FlushResult	executeDbOperations(List<DbOperation> operations) Attempts to perform the operations in order and returns a flush result.
protected void	executeSelectForUpdate(String statement, Object parameter)
protected FlushResult	postProcessBatchFailure(List<DbOperation> operations, RuntimeException exception)
protected FlushResult	postProcessBatchSuccess(List<DbOperation> operations, List<org.apache.ibatis.executor.BatchResult> batchResults)
protected void	postProcessJdbcBatchResult(Iterator<DbOperation> operationsIt, int[] statementResults, Exception failure, List<DbOperation> failedOperations) This method can be called with three cases: Case 1: Success.
protected void	postProcessOperationPerformed(DbOperation operation, int rowsAffected, Exception failure)
protected boolean	requiresAffectedRows(DbOperationType operationType)
protected void	updateBulk(DbBulkOperation operation)
protected void	updateEntity(DbEntityOperation operation)

Methods inherited from class org.camunda.bpm.engine.impl.db.sql.DbSqlSession

addSqlStatementPiece, bulkDeletePerformed, bulkOperationPerformed, bulkUpdatePerformed, close, commit, dbSchemaCheckVersion, dbSchemaCreateCmmn, dbSchemaCreateCmmnHistory, dbSchemaCreateDmn, dbSchemaCreateDmnHistory, dbSchemaCreateEngine, dbSchemaCreateHistory, dbSchemaCreateIdentity, dbSchemaDropCmmn, dbSchemaDropCmmnHistory, dbSchemaDropDmn, dbSchemaDropDmnHistory, dbSchemaDropEngine, dbSchemaDropHistory, dbSchemaDropIdentity, entityDeletePerformed, entityInsertPerformed, entityUpdatePerformed, executeDelete, executeInsertEntity, executeMandatorySchemaResource, executeNonEmptyUpdateStmt, executeSchemaResource, executeSchemaResource, executeSelectList, executeUpdate, flush, flushBatchOperations, flushOperations, getDbSqlSessionFactory, getDbVersion, getResourceForDbOperation, getSqlSession, getTableNamesPresent, getTablesPresentInOracleDatabase, getTableTypes, insertEntity, isCmmnHistoryTablePresent, isCmmnTablePresent, isConcurrentModificationException, isDmnHistoryTablePresent, isDmnTablePresent, isEngineTablePresent, isHistoryTablePresent, isIdentityTablePresent, isMissingTablesException, isTablePresent, lock, prependDatabaseTablePrefix, readNextTrimmedLine, rollback, selectById, selectList, selectOne, update

Methods inherited from class org.camunda.bpm.engine.impl.db.AbstractPersistenceSession

addEntityLoadListener, dbSchemaCreate, dbSchemaDrop, dbSchemaPrune, dbSchemaUpdate, executeDbOperation, fireEntityLoaded

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchDbSqlSession

public BatchDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)

BatchDbSqlSession

public BatchDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory,
                         Connection connection,
                         String catalog,
                         String schema)

Method Detail

executeDbOperations

public FlushResult executeDbOperations(List<DbOperation> operations)

Description copied from interface: PersistenceSession

Attempts to perform the operations in order and returns a flush result. The result indicates if there are operations that were not successful (via FlushResult.getFailedOperations() and if some operations were not executed (via FlushResult.getRemainingOperations(). The remaining operations must be a suffix of the parameter (e.g. for operations [a, b, c, d], [c, d] is a valid list of remaining operations, [b, c] is not).

This method modifies the operation's state, i.e. DbOperation.getState() will be updated by calling this method:

• Successful operations: DbOperation.State.APPLIED
• Failed operations: DbOperation.State.FAILED_ERROR or DbOperation.State.FAILED_CONCURRENT_MODIFICATION.
• Remaining operations: DbOperation.State.NOT_APPLIED

In addition, the number of affected rows and failure (if any) is updated in the operation.

postProcessBatchSuccess

protected FlushResult postProcessBatchSuccess(List<DbOperation> operations,
                                              List<org.apache.ibatis.executor.BatchResult> batchResults)

postProcessBatchFailure

protected FlushResult postProcessBatchFailure(List<DbOperation> operations,
                                              RuntimeException exception)

postProcessJdbcBatchResult

protected void postProcessJdbcBatchResult(Iterator<DbOperation> operationsIt,
                                          int[] statementResults,
                                          Exception failure,
                                          List<DbOperation> failedOperations)

This method can be called with three cases:

• Case 1: Success. statementResults contains the number of affected rows for all operations.
• Case 2: Failure. statementResults contains the number of affected rows for all successful operations that were executed before the failed operation.
• Case 3: Failure. statementResults contains the number of affected rows for all operations of the batch, i.e. further statements were executed after the first failed statement.

See BatchUpdateException.getUpdateCounts() for the specification of cases 2 and 3.

requiresAffectedRows

protected boolean requiresAffectedRows(DbOperationType operationType)

postProcessOperationPerformed

protected void postProcessOperationPerformed(DbOperation operation,
                                             int rowsAffected,
                                             Exception failure)

updateEntity

protected void updateEntity(DbEntityOperation operation)

Specified by:

updateEntity in class AbstractPersistenceSession

updateBulk

protected void updateBulk(DbBulkOperation operation)

Specified by:

updateBulk in class AbstractPersistenceSession

deleteBulk

protected void deleteBulk(DbBulkOperation operation)

Specified by:

deleteBulk in class AbstractPersistenceSession

deleteEntity

protected void deleteEntity(DbEntityOperation operation)

Specified by:

deleteEntity in class AbstractPersistenceSession

executeSelectForUpdate

protected void executeSelectForUpdate(String statement,
                                      Object parameter)

Specified by:

executeSelectForUpdate in class DbSqlSession