org.camunda.bpm.engine.impl.db.sql

Class DbSqlSession

java.lang.Object

org.camunda.bpm.engine.impl.db.AbstractPersistenceSession

org.camunda.bpm.engine.impl.db.sql.DbSqlSession

All Implemented Interfaces:

PersistenceSession, Session

public class DbSqlSession
extends AbstractPersistenceSession

Author:

Tom Baeyens, Joram Barrez, Daniel Meyer, Sebastian Menski, Roman Smirnov

Field Summary

Fields

Modifier and Type	Field and Description
protected String	connectionMetadataDefaultCatalog
protected String	connectionMetadataDefaultSchema
protected DbSqlSessionFactory	dbSqlSessionFactory
static String[]	JDBC_METADATA_TABLE_TYPES
protected static EnginePersistenceLogger	LOG
protected org.apache.ibatis.session.SqlSession	sqlSession

Fields inherited from class org.camunda.bpm.engine.impl.db.AbstractPersistenceSession

listeners

Constructor Summary

Constructors

Constructor and Description
DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)
DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory, Connection connection, String catalog, String schema)

Method Summary

Methods

Modifier and Type	Method and Description
protected String	addSqlStatementPiece(String sqlStatement, String line)
void	close()
void	commit()
void	dbSchemaCheckVersion()
protected void	dbSchemaCreateCmmn()
protected void	dbSchemaCreateCmmnHistory()
protected void	dbSchemaCreateDmn()
protected void	dbSchemaCreateDmnHistory()
protected void	dbSchemaCreateEngine()
protected void	dbSchemaCreateHistory()
protected void	dbSchemaCreateIdentity()
protected void	dbSchemaDropCmmn()
protected void	dbSchemaDropCmmnHistory()
protected void	dbSchemaDropDmn()
protected void	dbSchemaDropDmnHistory()
protected void	dbSchemaDropEngine()
protected void	dbSchemaDropHistory()
protected void	dbSchemaDropIdentity()
protected void	deleteBulk(DbBulkOperation operation)
protected void	deleteEntity(DbEntityOperation operation)
protected void	entityDeleted(DbEntity entity)
protected void	entityInserted(DbEntity entity)
protected void	entityUpdated(DbEntity entity)
protected int	executeDelete(String deleteStatement, Object parameter)
protected void	executeInsertEntity(String insertStatement, Object parameter)
void	executeMandatorySchemaResource(String operation, String component)
int	executeNonEmptyUpdateStmt(String updateStmt, Object parameter)
void	executeSchemaResource(String schemaFileResourceName)
void	executeSchemaResource(String operation, String component, String resourceName, boolean isOptional)
int	executeUpdate(String updateStatement, Object parameter)
void	flush()
List<org.apache.ibatis.executor.BatchResult>	flushOperations()
DbSqlSessionFactory	getDbSqlSessionFactory()
protected String	getDbVersion()
String	getResourceForDbOperation(String directory, String operation, String component)
org.apache.ibatis.session.SqlSession	getSqlSession()
List<String>	getTableNamesPresent()
protected List<String>	getTablesPresentInOracleDatabase()
protected void	insertEntity(DbEntityOperation operation)
boolean	isCmmnHistoryTablePresent()
boolean	isCmmnTablePresent()
boolean	isDmnHistoryTablePresent()
boolean	isDmnTablePresent()
boolean	isEngineTablePresent()
boolean	isHistoryTablePresent()
boolean	isIdentityTablePresent()
protected boolean	isMissingTablesException(Exception e)
boolean	isTablePresent(String tableName)
void	lock(String statement, Object parameter)
String	prependDatabaseTablePrefix(String tableName)
protected String	readNextTrimmedLine(BufferedReader reader)
void	rollback()
<T extends DbEntity> T	selectById(Class<T> type, String id)
List<?>	selectList(String statement, Object parameter)
Object	selectOne(String statement, Object parameter)
protected void	updateBulk(DbBulkOperation operation)
protected void	updateEntity(DbEntityOperation operation)

Methods inherited from class org.camunda.bpm.engine.impl.db.AbstractPersistenceSession

addEntityLoadListener, dbSchemaCreate, dbSchemaDrop, dbSchemaPrune, dbSchemaUpdate, executeDbOperation, fireEntityLoaded

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final EnginePersistenceLogger LOG

sqlSession

protected org.apache.ibatis.session.SqlSession sqlSession

dbSqlSessionFactory

protected DbSqlSessionFactory dbSqlSessionFactory

connectionMetadataDefaultCatalog

protected String connectionMetadataDefaultCatalog

connectionMetadataDefaultSchema

protected String connectionMetadataDefaultSchema

JDBC_METADATA_TABLE_TYPES

public static String[] JDBC_METADATA_TABLE_TYPES

Constructor Detail

DbSqlSession

public DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory)

DbSqlSession

public DbSqlSession(DbSqlSessionFactory dbSqlSessionFactory,
            Connection connection,
            String catalog,
            String schema)

Method Detail

flushOperations

public List<org.apache.ibatis.executor.BatchResult> flushOperations()

selectList

public List<?> selectList(String statement,
                 Object parameter)

selectById

public <T extends DbEntity> T selectById(Class<T> type,
                                String id)

selectOne

public Object selectOne(String statement,
               Object parameter)

lock

public void lock(String statement,
        Object parameter)

insertEntity

protected void insertEntity(DbEntityOperation operation)

Specified by:

insertEntity in class AbstractPersistenceSession

executeInsertEntity

protected void executeInsertEntity(String insertStatement,
                       Object parameter)

entityInserted

protected void entityInserted(DbEntity entity)

deleteEntity

protected void deleteEntity(DbEntityOperation operation)

Specified by:

deleteEntity in class AbstractPersistenceSession

executeDelete

protected int executeDelete(String deleteStatement,
                Object parameter)

entityDeleted

protected void entityDeleted(DbEntity entity)

deleteBulk

protected void deleteBulk(DbBulkOperation operation)

Specified by:

deleteBulk in class AbstractPersistenceSession

updateEntity

protected void updateEntity(DbEntityOperation operation)

Specified by:

updateEntity in class AbstractPersistenceSession

executeUpdate

public int executeUpdate(String updateStatement,
                Object parameter)

executeNonEmptyUpdateStmt

public int executeNonEmptyUpdateStmt(String updateStmt,
                            Object parameter)

entityUpdated

protected void entityUpdated(DbEntity entity)

updateBulk

protected void updateBulk(DbBulkOperation operation)

Specified by:

updateBulk in class AbstractPersistenceSession

flush

public void flush()

close

public void close()

commit

public void commit()

rollback

public void rollback()

dbSchemaCheckVersion

public void dbSchemaCheckVersion()

getDbVersion

protected String getDbVersion()

Specified by:

getDbVersion in class AbstractPersistenceSession

dbSchemaCreateIdentity

protected void dbSchemaCreateIdentity()

Specified by:

dbSchemaCreateIdentity in class AbstractPersistenceSession

dbSchemaCreateHistory

protected void dbSchemaCreateHistory()

Specified by:

dbSchemaCreateHistory in class AbstractPersistenceSession

dbSchemaCreateEngine

protected void dbSchemaCreateEngine()

Specified by:

dbSchemaCreateEngine in class AbstractPersistenceSession

dbSchemaCreateCmmn

protected void dbSchemaCreateCmmn()

Specified by:

dbSchemaCreateCmmn in class AbstractPersistenceSession

dbSchemaCreateCmmnHistory

protected void dbSchemaCreateCmmnHistory()

Specified by:

dbSchemaCreateCmmnHistory in class AbstractPersistenceSession

dbSchemaCreateDmn

protected void dbSchemaCreateDmn()

Specified by:

dbSchemaCreateDmn in class AbstractPersistenceSession

dbSchemaCreateDmnHistory

protected void dbSchemaCreateDmnHistory()

Specified by:

dbSchemaCreateDmnHistory in class AbstractPersistenceSession

dbSchemaDropIdentity

protected void dbSchemaDropIdentity()

Specified by:

dbSchemaDropIdentity in class AbstractPersistenceSession

dbSchemaDropHistory

protected void dbSchemaDropHistory()

Specified by:

dbSchemaDropHistory in class AbstractPersistenceSession

dbSchemaDropEngine

protected void dbSchemaDropEngine()

Specified by:

dbSchemaDropEngine in class AbstractPersistenceSession

dbSchemaDropCmmn

protected void dbSchemaDropCmmn()

Specified by:

dbSchemaDropCmmn in class AbstractPersistenceSession

dbSchemaDropCmmnHistory

protected void dbSchemaDropCmmnHistory()

Specified by:

dbSchemaDropCmmnHistory in class AbstractPersistenceSession

dbSchemaDropDmn

protected void dbSchemaDropDmn()

Specified by:

dbSchemaDropDmn in class AbstractPersistenceSession

dbSchemaDropDmnHistory

protected void dbSchemaDropDmnHistory()

Specified by:

dbSchemaDropDmnHistory in class AbstractPersistenceSession

executeMandatorySchemaResource

public void executeMandatorySchemaResource(String operation,
                                  String component)

isEngineTablePresent

public boolean isEngineTablePresent()

Specified by:

isEngineTablePresent in class AbstractPersistenceSession

isHistoryTablePresent

public boolean isHistoryTablePresent()

Specified by:

isHistoryTablePresent in class AbstractPersistenceSession

isIdentityTablePresent

public boolean isIdentityTablePresent()

Specified by:

isIdentityTablePresent in class AbstractPersistenceSession

isCmmnTablePresent

public boolean isCmmnTablePresent()

Specified by:

isCmmnTablePresent in class AbstractPersistenceSession

isCmmnHistoryTablePresent

public boolean isCmmnHistoryTablePresent()

Specified by:

isCmmnHistoryTablePresent in class AbstractPersistenceSession

isDmnTablePresent

public boolean isDmnTablePresent()

Specified by:

isDmnTablePresent in class AbstractPersistenceSession

isDmnHistoryTablePresent

public boolean isDmnHistoryTablePresent()

Specified by:

isDmnHistoryTablePresent in class AbstractPersistenceSession

isTablePresent

public boolean isTablePresent(String tableName)

getTableNamesPresent

public List<String> getTableNamesPresent()

Specified by:

getTableNamesPresent in interface PersistenceSession

Overrides:

getTableNamesPresent in class AbstractPersistenceSession

getTablesPresentInOracleDatabase

protected List<String> getTablesPresentInOracleDatabase()
                                                 throws SQLException

Throws:

SQLException

prependDatabaseTablePrefix

public String prependDatabaseTablePrefix(String tableName)

getResourceForDbOperation

public String getResourceForDbOperation(String directory,
                               String operation,
                               String component)

executeSchemaResource

public void executeSchemaResource(String operation,
                         String component,
                         String resourceName,
                         boolean isOptional)

executeSchemaResource

public void executeSchemaResource(String schemaFileResourceName)

addSqlStatementPiece

protected String addSqlStatementPiece(String sqlStatement,
                          String line)

readNextTrimmedLine

protected String readNextTrimmedLine(BufferedReader reader)
                              throws IOException

Throws:

IOException

isMissingTablesException

protected boolean isMissingTablesException(Exception e)

getSqlSession

public org.apache.ibatis.session.SqlSession getSqlSession()

getDbSqlSessionFactory

public DbSqlSessionFactory getDbSqlSessionFactory()