Modifier and Type | Class and Description |
---|---|
class |
DbSqlSession.BulkCheckedDeleteOperation
A bulk version of the
DbSqlSession.CheckedDeleteOperation . |
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 |
Modifier and Type | Field and Description |
---|---|
protected static List<ActivitiVersion> |
ACTIVITI_VERSIONS |
protected Map<Class<?>,Map<String,DbSqlSession.CachedObject>> |
cachedObjects |
protected static Pattern |
CLEAN_VERSION_REGEX |
protected String |
connectionMetadataDefaultCatalog |
protected String |
connectionMetadataDefaultSchema |
protected DbSqlSessionFactory |
dbSqlSessionFactory |
protected List<DbSqlSession.DeleteOperation> |
deleteOperations |
protected List<DeserializedObject> |
deserializedObjects |
protected Map<Class<? extends PersistentObject>,List<PersistentObject>> |
insertedObjects |
static String[] |
JDBC_METADATA_TABLE_TYPES |
protected org.apache.ibatis.session.SqlSession |
sqlSession |
Constructor and Description |
---|
DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory) |
DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory,
Connection connection,
String catalog,
String schema) |
protected static final Pattern CLEAN_VERSION_REGEX
protected static final List<ActivitiVersion> ACTIVITI_VERSIONS
protected org.apache.ibatis.session.SqlSession sqlSession
protected DbSqlSessionFactory dbSqlSessionFactory
protected Map<Class<? extends PersistentObject>,List<PersistentObject>> insertedObjects
protected Map<Class<?>,Map<String,DbSqlSession.CachedObject>> cachedObjects
protected List<DbSqlSession.DeleteOperation> deleteOperations
protected List<DeserializedObject> deserializedObjects
protected String connectionMetadataDefaultCatalog
protected String connectionMetadataDefaultSchema
public static String[] JDBC_METADATA_TABLE_TYPES
public DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)
public DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory, Connection connection, String catalog, String schema)
public void insert(PersistentObject persistentObject)
public void update(PersistentObject persistentObject)
public void delete(PersistentObject persistentObject)
public List selectList(String statement, ListQueryParameterObject parameter, Page page)
public List selectList(String statement, Object parameter, int firstResult, int maxResults)
public List selectList(String statement, ListQueryParameterObject parameter)
public List selectListWithRawParameter(String statement, Object parameter, int firstResult, int maxResults)
public List selectListWithRawParameterWithoutFilter(String statement, Object parameter, int firstResult, int maxResults)
public <T extends PersistentObject> T selectById(Class<T> entityClass, String id)
protected DbSqlSession.CachedObject cachePut(PersistentObject persistentObject, boolean storeState)
protected PersistentObject cacheFilter(PersistentObject persistentObject)
public void addDeserializedObject(DeserializedObject deserializedObject)
protected List<DbSqlSession.DeleteOperation> removeUnnecessaryOperations()
protected void flushDeserializedObjects()
public List<PersistentObject> getUpdatedObjects()
protected boolean isPersistentObjectDeleted(PersistentObject persistentObject)
public <T extends PersistentObject> List<T> pruneDeletedEntities(List<T> listToPrune)
protected void flushInserts()
protected void flushPersistentObjects(Class<? extends PersistentObject> persistentObjectClass, List<PersistentObject> persistentObjectsToInsert)
protected void flushRegularInsert(PersistentObject persistentObject, Class<? extends PersistentObject> clazz)
protected void flushBulkInsert(List<PersistentObject> persistentObjectList, Class<? extends PersistentObject> clazz)
protected void flushUpdates(List<PersistentObject> updatedObjects)
protected void flushDeletes(List<DbSqlSession.DeleteOperation> removedOperations)
protected void dispatchEventsForRemovedOperations(List<DbSqlSession.DeleteOperation> removedOperations)
protected static ActivitiVariableEvent createVariableDeleteEvent(VariableInstanceEntity variableInstance)
protected void flushRegularDeletes(boolean dispatchEvent)
public void commit()
public void rollback()
public void dbSchemaCheckVersion()
protected String addMissingComponent(String missingComponents, String component)
protected String getDbVersion()
public void dbSchemaCreate()
protected void dbSchemaCreateIdentity()
protected void dbSchemaCreateHistory()
protected void dbSchemaCreateEngine()
public void dbSchemaDrop()
public void dbSchemaPrune()
public void executeMandatorySchemaResource(String operation, String component)
public String dbSchemaUpdate()
public boolean isEngineTablePresent()
public boolean isHistoryTablePresent()
public boolean isIdentityTablePresent()
public boolean isTablePresent(String tableName)
protected boolean isUpgradeNeeded(String versionInDatabase)
protected void dbSchemaUpgrade(String component, int currentDatabaseVersionsIndex)
public String getResourceForDbOperation(String directory, String operation, String component)
public void executeSchemaResource(String operation, String component, String resourceName, boolean isOptional)
protected String updateDdlForMySqlVersionLowerThan56(String ddlStatements)
protected String readNextTrimmedLine(BufferedReader reader) throws IOException
IOException
protected boolean isMissingTablesException(Exception e)
public void performSchemaOperationsProcessEngineBuild()
public void performSchemaOperationsProcessEngineClose()
public <T> T getCustomMapper(Class<T> type)
public DeploymentQueryImpl createDeploymentQuery()
public ModelQueryImpl createModelQueryImpl()
public ProcessDefinitionQueryImpl createProcessDefinitionQuery()
public ProcessInstanceQueryImpl createProcessInstanceQuery()
public ExecutionQueryImpl createExecutionQuery()
public TaskQueryImpl createTaskQuery()
public JobQueryImpl createJobQuery()
public HistoricProcessInstanceQueryImpl createHistoricProcessInstanceQuery()
public HistoricActivityInstanceQueryImpl createHistoricActivityInstanceQuery()
public HistoricTaskInstanceQueryImpl createHistoricTaskInstanceQuery()
public HistoricDetailQueryImpl createHistoricDetailQuery()
public HistoricVariableInstanceQueryImpl createHistoricVariableInstanceQuery()
public UserQueryImpl createUserQuery()
public GroupQueryImpl createGroupQuery()
public org.apache.ibatis.session.SqlSession getSqlSession()
public DbSqlSessionFactory getDbSqlSessionFactory()
Copyright © 2016 Alfresco. All rights reserved.