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

Class SimpleDbSqlSession

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.SimpleDbSqlSession

All Implemented Interfaces:

PersistenceSession, Session

public class SimpleDbSqlSession
extends DbSqlSession

For mybatis ExecutorType.SIMPLE

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	Description
SimpleDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)
SimpleDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory, java.sql.Connection connection, java.lang.String catalog, java.lang.String schema)

Method Summary

Modifier and Type	Method	Description
protected void	deleteBulk(DbBulkOperation operation)
protected void	deleteEntity(DbEntityOperation operation)
FlushResult	executeDbOperations(java.util.List<DbOperation> operations)	Attempts to perform the operations in order and returns a flush result.
protected void	executeSelectForUpdate(java.lang.String statement, java.lang.Object parameter)
protected void	insertEntity(DbEntityOperation operation)
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, configureFailedDbEntityOperation, 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, isCmmnHistoryTablePresent, isCmmnTablePresent, isConcurrentModificationException, isCrdbConcurrencyConflict, isCrdbConcurrencyConflictOnCommit, 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

SimpleDbSqlSession

public SimpleDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)

SimpleDbSqlSession

public SimpleDbSqlSession(DbSqlSessionFactory dbSqlSessionFactory,
                          java.sql.Connection connection,
                          java.lang.String catalog,
                          java.lang.String schema)

Method Detail

executeSelectForUpdate

protected void executeSelectForUpdate(java.lang.String statement,
                                      java.lang.Object parameter)

Specified by:

executeSelectForUpdate in class DbSqlSession

executeDbOperations

public FlushResult executeDbOperations(java.util.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.

insertEntity

protected void insertEntity(DbEntityOperation operation)

Overrides:

insertEntity in class DbSqlSession

deleteEntity

protected void deleteEntity(DbEntityOperation operation)

Specified by:

deleteEntity in class AbstractPersistenceSession

deleteBulk

protected void deleteBulk(DbBulkOperation operation)

Specified by:

deleteBulk in class AbstractPersistenceSession

updateEntity

protected void updateEntity(DbEntityOperation operation)

Specified by:

updateEntity in class AbstractPersistenceSession

updateBulk

protected void updateBulk(DbBulkOperation operation)

Specified by:

updateBulk in class AbstractPersistenceSession