Package org.flowable.engine.test.profiler

Class ProfilingDbSqlSession

java.lang.Object

org.flowable.common.engine.impl.db.DbSqlSession

org.flowable.engine.test.profiler.ProfilingDbSqlSession

All Implemented Interfaces:

org.flowable.common.engine.impl.interceptor.Session

public class ProfilingDbSqlSession
extends org.flowable.common.engine.impl.db.DbSqlSession

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected CommandExecutionResult	commandExecutionResult

Fields inherited from class org.flowable.common.engine.impl.db.DbSqlSession

bulkDeleteOperations, bulkUpdateOperations, connectionMetadataDefaultCatalog, connectionMetadataDefaultSchema, dbSqlSessionFactory, deletedObjects, entityCache, insertedObjects, JDBC_METADATA_TABLE_TYPES, sqlSession, updatedObjects

Constructor Summary

Constructors

Constructor	Description
ProfilingDbSqlSession(org.flowable.common.engine.impl.db.DbSqlSessionFactory dbSqlSessionFactory, org.flowable.common.engine.impl.persistence.cache.EntityCache entityCache)
ProfilingDbSqlSession(org.flowable.common.engine.impl.db.DbSqlSessionFactory dbSqlSessionFactory, org.flowable.common.engine.impl.persistence.cache.EntityCache entityCache, Connection connection, String catalog, String schema)

Method Summary

Modifier and Type	Method	Description
void	commit()
void	flush()
protected void	flushBulkDeletes(Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> entityClass, List<org.flowable.common.engine.impl.db.BulkDeleteOperation> deleteOperations)
protected void	flushBulkInsert(Collection<org.flowable.common.engine.impl.persistence.entity.Entity> entities, Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> clazz)
protected void	flushBulkUpdate(org.flowable.common.engine.impl.db.BulkUpdateOperation bulkUpdateOperation)
protected void	flushDeleteEntities(Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> entityClass, Collection<org.flowable.common.engine.impl.persistence.entity.Entity> entitiesToDelete)
protected void	flushRegularInsert(org.flowable.common.engine.impl.persistence.entity.Entity entity, Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> clazz)
protected void	flushUpdateEntity(org.flowable.common.engine.impl.persistence.entity.Entity updatedObject)
CommandExecutionResult	getCurrentCommandExecution()
<T extends org.flowable.common.engine.impl.persistence.entity.Entity> T	selectById(Class<T> entityClass, String id, boolean useCache)
List	selectListWithRawParameter(String statement, Object parameter, boolean useCache)
List	selectListWithRawParameterNoCacheLoadAndStore(String statement, Object parameter)
Object	selectOne(String statement, Object parameter)

Methods inherited from class org.flowable.common.engine.impl.db.DbSqlSession

cacheLoadOrStore, cacheLoadOrStore, close, debugFlush, delete, delete, determineUpdatedObjects, directInsert, directUpdate, flushDeletes, flushInsertEntities, flushInserts, flushUpdates, getConnectionMetadataDefaultCatalog, getConnectionMetadataDefaultSchema, getCustomMapper, getDbSqlSessionFactory, getSqlSession, incrementRevision, insert, isEntityInserted, isEntityInserted, isEntityToBeDeleted, queryWithRawParameter, queryWithRawParameterNoCacheLoadAndStore, removeUnnecessaryOperations, rollback, selectById, selectList, selectList, selectList, selectList, selectList, selectList, selectListNoCacheLoadAndStore, selectListNoCacheLoadAndStore, selectListNoCacheLoadAndStore, selectListWithRawParameter, selectListWithRawParameterNoCacheLoadAndStore, selectListWithRawParameterNoCacheLoadAndStore, setConnectionMetadataDefaultCatalog, setConnectionMetadataDefaultSchema, update, update

Methods inherited from class java.lang.Object

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

Field Details

commandExecutionResult

protected CommandExecutionResult commandExecutionResult

Constructor Details

ProfilingDbSqlSession

public ProfilingDbSqlSession(org.flowable.common.engine.impl.db.DbSqlSessionFactory dbSqlSessionFactory,
 org.flowable.common.engine.impl.persistence.cache.EntityCache entityCache)

ProfilingDbSqlSession

public ProfilingDbSqlSession(org.flowable.common.engine.impl.db.DbSqlSessionFactory dbSqlSessionFactory,
 org.flowable.common.engine.impl.persistence.cache.EntityCache entityCache,
 Connection connection,
 String catalog,
 String schema)

Method Details

flush

public void flush()

Specified by:

flush in interface org.flowable.common.engine.impl.interceptor.Session

Overrides:

flush in class org.flowable.common.engine.impl.db.DbSqlSession

commit

public void commit()

Overrides:

commit in class org.flowable.common.engine.impl.db.DbSqlSession

selectOne

public Object selectOne(String statement,
 Object parameter)

Overrides:

selectOne in class org.flowable.common.engine.impl.db.DbSqlSession

selectById

public <T extends org.flowable.common.engine.impl.persistence.entity.Entity>
T selectById(Class<T> entityClass,
 String id,
 boolean useCache)

Overrides:

selectById in class org.flowable.common.engine.impl.db.DbSqlSession

selectListWithRawParameter

public List selectListWithRawParameter(String statement,
 Object parameter,
 boolean useCache)

Overrides:

selectListWithRawParameter in class org.flowable.common.engine.impl.db.DbSqlSession

selectListWithRawParameterNoCacheLoadAndStore

public List selectListWithRawParameterNoCacheLoadAndStore(String statement,
 Object parameter)

Overrides:

selectListWithRawParameterNoCacheLoadAndStore in class org.flowable.common.engine.impl.db.DbSqlSession

flushRegularInsert

protected void flushRegularInsert(org.flowable.common.engine.impl.persistence.entity.Entity entity,
 Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> clazz)

Overrides:

flushRegularInsert in class org.flowable.common.engine.impl.db.DbSqlSession

flushBulkInsert

protected void flushBulkInsert(Collection<org.flowable.common.engine.impl.persistence.entity.Entity> entities,
 Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> clazz)

Overrides:

flushBulkInsert in class org.flowable.common.engine.impl.db.DbSqlSession

flushUpdateEntity

protected void flushUpdateEntity(org.flowable.common.engine.impl.persistence.entity.Entity updatedObject)

Overrides:

flushUpdateEntity in class org.flowable.common.engine.impl.db.DbSqlSession

flushBulkUpdate

protected void flushBulkUpdate(org.flowable.common.engine.impl.db.BulkUpdateOperation bulkUpdateOperation)

Overrides:

flushBulkUpdate in class org.flowable.common.engine.impl.db.DbSqlSession

flushDeleteEntities

protected void flushDeleteEntities(Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> entityClass,
 Collection<org.flowable.common.engine.impl.persistence.entity.Entity> entitiesToDelete)

Overrides:

flushDeleteEntities in class org.flowable.common.engine.impl.db.DbSqlSession

flushBulkDeletes

protected void flushBulkDeletes(Class<? extends org.flowable.common.engine.impl.persistence.entity.Entity> entityClass,
 List<org.flowable.common.engine.impl.db.BulkDeleteOperation> deleteOperations)

Overrides:

flushBulkDeletes in class org.flowable.common.engine.impl.db.DbSqlSession

getCurrentCommandExecution

public CommandExecutionResult getCurrentCommandExecution()