org.activiti.engine.impl.db
类 DbSqlSession
java.lang.Object
org.activiti.engine.impl.db.DbSqlSession
- 所有已实现的接口:
- Session
public class DbSqlSession
- extends Object
- implements Session
responsibilities:
- delayed flushing of inserts updates and deletes
- optional dirty checking
- db specific statement name mapping
- 作者:
- Tom Baeyens, Joram Barrez
方法摘要 |
void |
addDeserializedObject(Object deserializedObject,
byte[] serializedBytes,
VariableInstanceEntity variableInstanceEntity)
|
protected String |
addMissingComponent(String missingComponents,
String component)
|
protected String |
addSqlStatementPiece(String sqlStatement,
String line)
|
protected PersistentObject |
cacheFilter(PersistentObject persistentObject)
returns the object in the cache. |
protected
|
cacheGet(Class<T> entityClass,
String id)
|
protected DbSqlSession.CachedObject |
cachePut(PersistentObject persistentObject,
boolean storeState)
|
protected void |
cacheRemove(Class<?> persistentObjectClass,
String persistentObjectId)
|
void |
close()
|
void |
commit()
|
DeploymentQueryImpl |
createDeploymentQuery()
|
ExecutionQueryImpl |
createExecutionQuery()
|
GroupQueryImpl |
createGroupQuery()
|
HistoricActivityInstanceQueryImpl |
createHistoricActivityInstanceQuery()
|
HistoricDetailQueryImpl |
createHistoricDetailQuery()
|
HistoricProcessInstanceQueryImpl |
createHistoricProcessInstanceQuery()
|
HistoricTaskInstanceQueryImpl |
createHistoricTaskInstanceQuery()
|
HistoricVariableInstanceQueryImpl |
createHistoricVariableInstanceQuery()
|
JobQueryImpl |
createJobQuery()
|
ModelQueryImpl |
createModelQueryImpl()
|
ProcessDefinitionQueryImpl |
createProcessDefinitionQuery()
|
ProcessInstanceQueryImpl |
createProcessInstanceQuery()
|
TaskQueryImpl |
createTaskQuery()
|
UserQueryImpl |
createUserQuery()
|
void |
dbSchemaCheckVersion()
|
void |
dbSchemaCreate()
|
protected void |
dbSchemaCreateEngine()
|
protected void |
dbSchemaCreateHistory()
|
protected void |
dbSchemaCreateIdentity()
|
void |
dbSchemaDrop()
|
void |
dbSchemaPrune()
|
String |
dbSchemaUpdate()
|
protected void |
dbSchemaUpgrade(String component,
String dbVersion)
|
void |
delete(PersistentObject persistentObject)
|
void |
delete(String statement,
Object parameter)
|
void |
executeMandatorySchemaResource(String operation,
String component)
|
void |
executeSchemaResource(String operation,
String component,
String resourceName,
boolean isOptional)
|
protected List |
filterLoadedObjects(List<Object> loadedObjects)
|
|
findInCache(Class<T> entityClass)
|
|
findInCache(Class<T> entityClass,
String id)
|
void |
flush()
|
protected void |
flushDeletes()
|
protected void |
flushDeserializedObjects()
|
protected void |
flushInserts()
|
protected void |
flushUpdates(List<PersistentObject> updatedObjects)
|
protected String |
getCleanVersion(String versionString)
|
DbSqlSessionFactory |
getDbSqlSessionFactory()
|
protected String |
getDbVersion()
|
String |
getResourceForDbOperation(String directory,
String operation,
String component)
|
org.apache.ibatis.session.SqlSession |
getSqlSession()
|
List<PersistentObject> |
getUpdatedObjects()
|
void |
insert(PersistentObject persistentObject)
|
boolean |
isEngineTablePresent()
|
boolean |
isHistoryTablePresent()
|
boolean |
isIdentityTablePresent()
|
protected boolean |
isMissingTablesException(Exception e)
|
protected boolean |
isPersistentObjectDeleted(PersistentObject persistentObject)
|
boolean |
isTablePresent(String tableName)
|
protected boolean |
isUpgradeNeeded(String versionInDatabase)
|
void |
performSchemaOperationsProcessEngineBuild()
|
void |
performSchemaOperationsProcessEngineClose()
|
protected String |
prependDatabaseTablePrefix(String tableName)
|
|
pruneDeletedEntities(List<T> listToPrune)
|
protected String |
readNextTrimmedLine(BufferedReader reader)
|
protected void |
removeUnnecessaryOperations()
Clears all deleted and inserted objects from the cache,
and removes inserts and deletes that cancel each other. |
void |
rollback()
|
|
selectById(Class<T> entityClass,
String id)
|
List |
selectList(String statement)
|
List |
selectList(String statement,
ListQueryParameterObject parameter)
|
List |
selectList(String statement,
ListQueryParameterObject parameter,
Page page)
|
List |
selectList(String statement,
Object parameter)
|
List |
selectList(String statement,
Object parameter,
int firstResult,
int maxResults)
|
List |
selectList(String statement,
Object parameter,
Page page)
|
List |
selectListWithRawParameter(String statement,
Object parameter,
int firstResult,
int maxResults)
|
Object |
selectOne(String statement,
Object parameter)
|
void |
update(PersistentObject persistentObject)
|
从类 java.lang.Object 继承的方法 |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
sqlSession
protected org.apache.ibatis.session.SqlSession sqlSession
dbSqlSessionFactory
protected DbSqlSessionFactory dbSqlSessionFactory
insertedObjects
protected List<PersistentObject> insertedObjects
cachedObjects
protected Map<Class<?>,Map<String,DbSqlSession.CachedObject>> cachedObjects
deleteOperations
protected List<DbSqlSession.DeleteOperation> deleteOperations
deserializedObjects
protected List<DeserializedObject> deserializedObjects
connectionMetadataDefaultCatalog
protected String connectionMetadataDefaultCatalog
connectionMetadataDefaultSchema
protected String connectionMetadataDefaultSchema
JDBC_METADATA_TABLE_TYPES
public static String[] JDBC_METADATA_TABLE_TYPES
DbSqlSession
public DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)
DbSqlSession
public DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory,
Connection connection,
String catalog,
String schema)
insert
public void insert(PersistentObject persistentObject)
update
public void update(PersistentObject persistentObject)
delete
public void delete(String statement,
Object parameter)
delete
public void delete(PersistentObject persistentObject)
selectList
public List selectList(String statement)
selectList
public List selectList(String statement,
Object parameter)
selectList
public List selectList(String statement,
Object parameter,
Page page)
selectList
public List selectList(String statement,
ListQueryParameterObject parameter,
Page page)
selectList
public List selectList(String statement,
Object parameter,
int firstResult,
int maxResults)
selectList
public List selectList(String statement,
ListQueryParameterObject parameter)
selectListWithRawParameter
public List selectListWithRawParameter(String statement,
Object parameter,
int firstResult,
int maxResults)
selectOne
public Object selectOne(String statement,
Object parameter)
selectById
public <T extends PersistentObject> T selectById(Class<T> entityClass,
String id)
filterLoadedObjects
protected List filterLoadedObjects(List<Object> loadedObjects)
cachePut
protected DbSqlSession.CachedObject cachePut(PersistentObject persistentObject,
boolean storeState)
cacheFilter
protected PersistentObject cacheFilter(PersistentObject persistentObject)
- returns the object in the cache. if this object was loaded before,
then the original object is returned. if this is the first time
this object is loaded, then the loadedObject is added to the cache.
cacheGet
protected <T> T cacheGet(Class<T> entityClass,
String id)
cacheRemove
protected void cacheRemove(Class<?> persistentObjectClass,
String persistentObjectId)
findInCache
public <T> List<T> findInCache(Class<T> entityClass)
findInCache
public <T> T findInCache(Class<T> entityClass,
String id)
addDeserializedObject
public void addDeserializedObject(Object deserializedObject,
byte[] serializedBytes,
VariableInstanceEntity variableInstanceEntity)
flush
public void flush()
- 指定者:
- 接口
Session
中的 flush
removeUnnecessaryOperations
protected void removeUnnecessaryOperations()
- Clears all deleted and inserted objects from the cache,
and removes inserts and deletes that cancel each other.
flushDeserializedObjects
protected void flushDeserializedObjects()
getUpdatedObjects
public List<PersistentObject> getUpdatedObjects()
isPersistentObjectDeleted
protected boolean isPersistentObjectDeleted(PersistentObject persistentObject)
pruneDeletedEntities
public <T extends PersistentObject> List<T> pruneDeletedEntities(List<T> listToPrune)
flushInserts
protected void flushInserts()
flushUpdates
protected void flushUpdates(List<PersistentObject> updatedObjects)
flushDeletes
protected void flushDeletes()
close
public void close()
- 指定者:
- 接口
Session
中的 close
commit
public void commit()
rollback
public void rollback()
dbSchemaCheckVersion
public void dbSchemaCheckVersion()
addMissingComponent
protected String addMissingComponent(String missingComponents,
String component)
getDbVersion
protected String getDbVersion()
dbSchemaCreate
public void dbSchemaCreate()
dbSchemaCreateIdentity
protected void dbSchemaCreateIdentity()
dbSchemaCreateHistory
protected void dbSchemaCreateHistory()
dbSchemaCreateEngine
protected void dbSchemaCreateEngine()
dbSchemaDrop
public void dbSchemaDrop()
dbSchemaPrune
public void dbSchemaPrune()
executeMandatorySchemaResource
public void executeMandatorySchemaResource(String operation,
String component)
dbSchemaUpdate
public String dbSchemaUpdate()
isEngineTablePresent
public boolean isEngineTablePresent()
isHistoryTablePresent
public boolean isHistoryTablePresent()
isIdentityTablePresent
public boolean isIdentityTablePresent()
isTablePresent
public boolean isTablePresent(String tableName)
isUpgradeNeeded
protected boolean isUpgradeNeeded(String versionInDatabase)
getCleanVersion
protected String getCleanVersion(String versionString)
prependDatabaseTablePrefix
protected String prependDatabaseTablePrefix(String tableName)
dbSchemaUpgrade
protected void dbSchemaUpgrade(String component,
String dbVersion)
getResourceForDbOperation
public String getResourceForDbOperation(String directory,
String operation,
String component)
executeSchemaResource
public void executeSchemaResource(String operation,
String component,
String resourceName,
boolean isOptional)
addSqlStatementPiece
protected String addSqlStatementPiece(String sqlStatement,
String line)
readNextTrimmedLine
protected String readNextTrimmedLine(BufferedReader reader)
throws IOException
- 抛出:
IOException
isMissingTablesException
protected boolean isMissingTablesException(Exception e)
performSchemaOperationsProcessEngineBuild
public void performSchemaOperationsProcessEngineBuild()
performSchemaOperationsProcessEngineClose
public void performSchemaOperationsProcessEngineClose()
createDeploymentQuery
public DeploymentQueryImpl createDeploymentQuery()
createModelQueryImpl
public ModelQueryImpl createModelQueryImpl()
createProcessDefinitionQuery
public ProcessDefinitionQueryImpl createProcessDefinitionQuery()
createProcessInstanceQuery
public ProcessInstanceQueryImpl createProcessInstanceQuery()
createExecutionQuery
public ExecutionQueryImpl createExecutionQuery()
createTaskQuery
public TaskQueryImpl createTaskQuery()
createJobQuery
public JobQueryImpl createJobQuery()
createHistoricProcessInstanceQuery
public HistoricProcessInstanceQueryImpl createHistoricProcessInstanceQuery()
createHistoricActivityInstanceQuery
public HistoricActivityInstanceQueryImpl createHistoricActivityInstanceQuery()
createHistoricTaskInstanceQuery
public HistoricTaskInstanceQueryImpl createHistoricTaskInstanceQuery()
createHistoricDetailQuery
public HistoricDetailQueryImpl createHistoricDetailQuery()
createHistoricVariableInstanceQuery
public HistoricVariableInstanceQueryImpl createHistoricVariableInstanceQuery()
createUserQuery
public UserQueryImpl createUserQuery()
createGroupQuery
public GroupQueryImpl createGroupQuery()
getSqlSession
public org.apache.ibatis.session.SqlSession getSqlSession()
getDbSqlSessionFactory
public DbSqlSessionFactory getDbSqlSessionFactory()
Copyright © 2013 Alfresco. All rights reserved.