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

嵌套类摘要
 class DbSqlSession.BulkDeleteOperation
          Use this DbSqlSession.DeleteOperation to execute a dedicated delete statement.
static class DbSqlSession.CachedObject
           
 class DbSqlSession.CheckedDeleteOperation
          A DbSqlSession.DeleteOperation that checks for concurrent modifications if the persistent object implements HasRevision.
static interface DbSqlSession.DeleteOperation
           
 
字段摘要
protected  Map<Class<?>,Map<String,DbSqlSession.CachedObject>> cachedObjects
           
protected  String connectionMetadataDefaultCatalog
           
protected  String connectionMetadataDefaultSchema
           
protected  DbSqlSessionFactory dbSqlSessionFactory
           
protected  List<DbSqlSession.DeleteOperation> deleteOperations
           
protected  List<DeserializedObject> deserializedObjects
           
protected  List<PersistentObject> insertedObjects
           
static String[] JDBC_METADATA_TABLE_TYPES
           
protected  org.apache.ibatis.session.SqlSession sqlSession
           
 
构造方法摘要
DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)
           
DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory, Connection connection, String catalog, String schema)
           
 
方法摘要
 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
<T> T
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)
           
<T> List<T>
findInCache(Class<T> entityClass)
           
<T> T
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)
           
<T extends PersistentObject>
List<T>
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()
           
<T extends PersistentObject>
T
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.