org.activiti.engine.test.profiler

Class ProfilingDbSqlSession

java.lang.Object

org.activiti.engine.impl.db.DbSqlSession

org.activiti.engine.test.profiler.ProfilingDbSqlSession

All Implemented Interfaces:

org.activiti.engine.impl.interceptor.Session

public class ProfilingDbSqlSession
extends org.activiti.engine.impl.db.DbSqlSession

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field and Description
protected CommandExecutionResult	commandExecutionResult

Fields inherited from class org.activiti.engine.impl.db.DbSqlSession

ACTIVITI_VERSIONS, bulkDeleteOperations, CLEAN_VERSION_REGEX, connectionMetadataDefaultCatalog, connectionMetadataDefaultSchema, dbSqlSessionFactory, deletedObjects, entityCache, insertedObjects, JDBC_METADATA_TABLE_TYPES, LAST_V5_VERSION, sqlSession, updatedObjects

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	commit()
void	flush()
protected void	flushBulkDeletes(Class<? extends org.activiti.engine.impl.persistence.entity.Entity> entityClass)
protected void	flushBulkInsert(Collection<org.activiti.engine.impl.persistence.entity.Entity> entities, Class<? extends org.activiti.engine.impl.persistence.entity.Entity> clazz)
protected void	flushDeleteEntities(Class<? extends org.activiti.engine.impl.persistence.entity.Entity> entityClass, Collection<org.activiti.engine.impl.persistence.entity.Entity> entitiesToDelete)
protected void	flushRegularInsert(org.activiti.engine.impl.persistence.entity.Entity entity, Class<? extends org.activiti.engine.impl.persistence.entity.Entity> clazz)
protected void	flushUpdates()
CommandExecutionResult	getCurrentCommandExecution()
<T extends org.activiti.engine.impl.persistence.entity.Entity> T	selectById(Class<T> entityClass, String id, boolean useCache)
List	selectListWithRawParameter(String statement, Object parameter, int firstResult, int maxResults, boolean useCache)
List	selectListWithRawParameterWithoutFilter(String statement, Object parameter, int firstResult, int maxResults)
Object	selectOne(String statement, Object parameter)

Methods inherited from class org.activiti.engine.impl.db.DbSqlSession

addMissingComponent, addSqlStatementPiece, cacheLoadOrStore, cacheLoadOrStore, close, collectChildExecutionsForInsertion, createDeploymentQuery, createExecutionQuery, createGroupQuery, createHistoricActivityInstanceQuery, createHistoricDetailQuery, createHistoricProcessInstanceQuery, createHistoricTaskInstanceQuery, createHistoricVariableInstanceQuery, createJobQuery, createModelQueryImpl, createProcessDefinitionQuery, createProcessInstanceQuery, createTaskQuery, createUserQuery, dbSchemaCheckVersion, dbSchemaCreate, dbSchemaCreateEngine, dbSchemaCreateHistory, dbSchemaCreateIdentity, dbSchemaDrop, dbSchemaPrune, dbSchemaUpdate, dbSchemaUpgrade, debugFlush, delete, delete, determineUpdatedObjects, executeMandatorySchemaResource, executeSchemaResource, findMatchingVersionIndex, flushDeletes, flushInsertEntities, flushInserts, getCleanVersion, getCustomMapper, getDbSqlSessionFactory, getDbVersion, getResourceForDbOperation, getSqlSession, incrementRevision, insert, isEngineTablePresent, isEntityInserted, isEntityToBeDeleted, isHistoryTablePresent, isIdentityTablePresent, isMissingTablesException, isMysql, isOracle, isTablePresent, isUpgradeNeeded, orderExecutionEntities, performSchemaOperationsProcessEngineBuild, performSchemaOperationsProcessEngineClose, prependDatabaseTablePrefix, readNextTrimmedLine, removeUnnecessaryOperations, rollback, selectById, selectList, selectList, selectList, selectList, selectList, selectList, selectList, selectList, selectList, selectList, selectList, selectListWithRawParameter, update, update, updateDdlForMySqlVersionLowerThan56

Methods inherited from class java.lang.Object

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

Field Detail

commandExecutionResult

protected CommandExecutionResult commandExecutionResult

Constructor Detail

ProfilingDbSqlSession

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

ProfilingDbSqlSession

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

Method Detail

flush

public void flush()

Specified by:

flush in interface org.activiti.engine.impl.interceptor.Session

Overrides:

flush in class org.activiti.engine.impl.db.DbSqlSession

commit

public void commit()

Overrides:

commit in class org.activiti.engine.impl.db.DbSqlSession

selectOne

public Object selectOne(String statement,
               Object parameter)

Overrides:

selectOne in class org.activiti.engine.impl.db.DbSqlSession

selectById

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

Overrides:

selectById in class org.activiti.engine.impl.db.DbSqlSession

selectListWithRawParameter

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

Overrides:

selectListWithRawParameter in class org.activiti.engine.impl.db.DbSqlSession

selectListWithRawParameterWithoutFilter

public List selectListWithRawParameterWithoutFilter(String statement,
                                           Object parameter,
                                           int firstResult,
                                           int maxResults)

Overrides:

selectListWithRawParameterWithoutFilter in class org.activiti.engine.impl.db.DbSqlSession

flushRegularInsert

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

Overrides:

flushRegularInsert in class org.activiti.engine.impl.db.DbSqlSession

flushBulkInsert

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

Overrides:

flushBulkInsert in class org.activiti.engine.impl.db.DbSqlSession

flushUpdates

protected void flushUpdates()

Overrides:

flushUpdates in class org.activiti.engine.impl.db.DbSqlSession

flushDeleteEntities

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

Overrides:

flushDeleteEntities in class org.activiti.engine.impl.db.DbSqlSession

flushBulkDeletes

protected void flushBulkDeletes(Class<? extends org.activiti.engine.impl.persistence.entity.Entity> entityClass)

Overrides:

flushBulkDeletes in class org.activiti.engine.impl.db.DbSqlSession

getCurrentCommandExecution

public CommandExecutionResult getCurrentCommandExecution()