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
-
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
All Methods Instance Methods Concrete Methods 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
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
flushUpdates()
CommandExecutionResult
getCurrentCommandExecution()
<T extends org.flowable.common.engine.impl.persistence.entity.Entity>
TselectById(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, 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
-
-
-
-
Field Detail
-
commandExecutionResult
protected CommandExecutionResult commandExecutionResult
-
-
Constructor Detail
-
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 Detail
-
flush
public void flush()
- Specified by:
flush
in interfaceorg.flowable.common.engine.impl.interceptor.Session
- Overrides:
flush
in classorg.flowable.common.engine.impl.db.DbSqlSession
-
commit
public void commit()
- Overrides:
commit
in classorg.flowable.common.engine.impl.db.DbSqlSession
-
selectOne
public Object selectOne(String statement, Object parameter)
- Overrides:
selectOne
in classorg.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 classorg.flowable.common.engine.impl.db.DbSqlSession
-
selectListWithRawParameter
public List selectListWithRawParameter(String statement, Object parameter, boolean useCache)
- Overrides:
selectListWithRawParameter
in classorg.flowable.common.engine.impl.db.DbSqlSession
-
selectListWithRawParameterNoCacheLoadAndStore
public List selectListWithRawParameterNoCacheLoadAndStore(String statement, Object parameter)
- Overrides:
selectListWithRawParameterNoCacheLoadAndStore
in classorg.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 classorg.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 classorg.flowable.common.engine.impl.db.DbSqlSession
-
flushUpdates
protected void flushUpdates()
- Overrides:
flushUpdates
in classorg.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 classorg.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 classorg.flowable.common.engine.impl.db.DbSqlSession
-
getCurrentCommandExecution
public CommandExecutionResult getCurrentCommandExecution()
-
-