org.camunda.bpm.engine.impl.db.entitymanager

Class DbEntityManager

java.lang.Object

org.camunda.bpm.engine.impl.db.entitymanager.DbEntityManager

All Implemented Interfaces:

Session

public class DbEntityManager
extends Object
implements Session

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
protected DbEntityCache	dbEntityCache
protected DbOperationExecutor	dbOperationExecutor
protected DbOperationManager	dbOperationManager
protected IdGenerator	idGenerator
protected List<OptimisticLockingListener>	optimisticLockingListeners

Constructor Summary

Constructors

Constructor and Description
DbEntityManager(DbSqlSessionFactory dbSqlSessionFactory, org.apache.ibatis.session.SqlSession sqlSession)

Method Summary

Methods

Modifier and Type	Method and Description
void	bulkDelete(Class<? extends PersistentObject> entityType, String statement, Object parameter)
void	bulkUpdate(Class<? extends PersistentObject> entityType, String statement, Object parameter)
void	close()
void	delete(PersistentObject persistentObject)
protected void	ensureHasId(PersistentObject persistentObject)
void	flush()
protected void	flushEntityCache() Flushes the entity cache: Depending on the entity state, the required DbOperation is performed and the cache is updated.
DbEntityCache	getDbEntityCache()
DbOperationExecutor	getDbOperationExecutor()
DbOperationManager	getDbOperationManager()
protected void	handleOptimisticLockingException(DbOperation dbOperation)
protected void	initialize(DbSqlSessionFactory dbSqlSessionFactory, org.apache.ibatis.session.SqlSession sqlSession)
void	insert(PersistentObject persistentObject)
boolean	isDeleted(PersistentObject object)
protected void	logFlushSummary(Collection<DbOperation> operations)
void	merge(PersistentObject persistentObject)
protected DbBulkOperation	performBulkOperation(Class<? extends PersistentObject> entityType, String statement, Object parameter, DbOperationType operationType)
protected void	performEntityOperation(CachedDbEntity cachedDbEntity, DbOperationType type)
void	registerOptimisticLockingListener(OptimisticLockingListener optimisticLockingListener)
void	setDbEntityCache(DbEntityCache dbEntityCache)
void	setDbOperationExecutor(DbOperationExecutor executor)
void	setDbOperationManager(DbOperationManager operationManager)

Methods inherited from class java.lang.Object

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

Field Detail

optimisticLockingListeners

protected List<OptimisticLockingListener> optimisticLockingListeners

idGenerator

protected IdGenerator idGenerator

dbEntityCache

protected DbEntityCache dbEntityCache

dbOperationManager

protected DbOperationManager dbOperationManager

dbOperationExecutor

protected DbOperationExecutor dbOperationExecutor

Constructor Detail

DbEntityManager

public DbEntityManager(DbSqlSessionFactory dbSqlSessionFactory,
               org.apache.ibatis.session.SqlSession sqlSession)

Method Detail

initialize

protected void initialize(DbSqlSessionFactory dbSqlSessionFactory,
              org.apache.ibatis.session.SqlSession sqlSession)

flush

public void flush()

Specified by:

flush in interface Session

handleOptimisticLockingException

protected void handleOptimisticLockingException(DbOperation dbOperation)

flushEntityCache

protected void flushEntityCache()

Flushes the entity cache: Depending on the entity state, the required DbOperation is performed and the cache is updated.

insert

public void insert(PersistentObject persistentObject)

merge

public void merge(PersistentObject persistentObject)

delete

public void delete(PersistentObject persistentObject)

bulkUpdate

public void bulkUpdate(Class<? extends PersistentObject> entityType,
              String statement,
              Object parameter)

bulkDelete

public void bulkDelete(Class<? extends PersistentObject> entityType,
              String statement,
              Object parameter)

performBulkOperation

protected DbBulkOperation performBulkOperation(Class<? extends PersistentObject> entityType,
                                   String statement,
                                   Object parameter,
                                   DbOperationType operationType)

performEntityOperation

protected void performEntityOperation(CachedDbEntity cachedDbEntity,
                          DbOperationType type)

logFlushSummary

protected void logFlushSummary(Collection<DbOperation> operations)

close

public void close()

Specified by:

close in interface Session

isDeleted

public boolean isDeleted(PersistentObject object)

ensureHasId

protected void ensureHasId(PersistentObject persistentObject)

getDbOperationExecutor

public DbOperationExecutor getDbOperationExecutor()

setDbOperationExecutor

public void setDbOperationExecutor(DbOperationExecutor executor)

getDbOperationManager

public DbOperationManager getDbOperationManager()

setDbOperationManager

public void setDbOperationManager(DbOperationManager operationManager)

getDbEntityCache

public DbEntityCache getDbEntityCache()

setDbEntityCache

public void setDbEntityCache(DbEntityCache dbEntityCache)

registerOptimisticLockingListener

public void registerOptimisticLockingListener(OptimisticLockingListener optimisticLockingListener)