com.liferay.portal.kernel.dao.db

Class BaseDBProcess

Object

com.liferay.portal.kernel.dao.db.BaseDBProcess

All Implemented Interfaces:

DBProcess

Direct Known Subclasses:

UpgradeProcess

public abstract class BaseDBProcess
extends Object
implements DBProcess

Author:

Hugo Huijser, Brian Wing Shun Chan

Field Summary

Fields

Modifier and Type	Field and Description
protected Connection	connection

Constructor Summary

Constructors

Constructor and Description
BaseDBProcess()

Method Summary

Modifier and Type	Method and Description
protected void	addIndexes(Connection connection, List<IndexMetadata> indexMetadatas)
protected void	alterColumnName(String tableName, String oldColumnName, String newColumnDefinition)
protected void	alterColumnType(String tableName, String columnName, String newColumnType)
protected void	alterTableAddColumn(String tableName, String columnName, String columnType)
protected void	alterTableDropColumn(String tableName, String columnName)
protected void	alterTableName(String tableName, String newTableName)
protected boolean	doHasTable(String tableName) Deprecated. As of Cavanaugh (7.4.x), replaced by hasTable(String)
protected List<IndexMetadata>	dropIndexes(String tableName, String columnName)
protected void	dropTable(String tableName)
protected Connection	getConnection()
protected String[]	getPrimaryKeyColumnNames(Connection connection, String tableName)
protected boolean	hasColumn(String tableName, String columnName)
protected boolean	hasColumnType(String tableName, String columnName, String columnType)
protected boolean	hasIndex(String tableName, String indexName)
protected boolean	hasRows(Connection connection, String tableName)
protected boolean	hasRows(String tableName)
protected boolean	hasTable(String tableName)
protected void	process(com.liferay.petra.function.UnsafeConsumer<Long,Exception> unsafeConsumer)
protected void	processConcurrently(String sql, String updateSQL, com.liferay.petra.function.UnsafeFunction<ResultSet,Object[],Exception> unsafeFunction, com.liferay.petra.function.UnsafeBiConsumer<Object[],PreparedStatement,Exception> unsafeBiConsumer, String exceptionMessage)
protected void	processConcurrently(String sql, com.liferay.petra.function.UnsafeConsumer<PreparedStatement,Exception> unsafeConsumer, String updateSQL, com.liferay.petra.function.UnsafeFunction<ResultSet,Object[],Exception> unsafeFunction, com.liferay.petra.function.UnsafeBiConsumer<Object[],PreparedStatement,Exception> unsafeBiConsumer, String exceptionMessage)
protected void	processConcurrently(String sql, com.liferay.petra.function.UnsafeFunction<ResultSet,Object[],Exception> unsafeFunction, com.liferay.petra.function.UnsafeConsumer<Object[],Exception> unsafeConsumer, String exceptionMessage)
protected <T> void	processConcurrently(T[] array, com.liferay.petra.function.UnsafeConsumer<T,Exception> unsafeConsumer, String exceptionMessage)
protected void	removePrimaryKey(String tableName)
void	runSQL(Connection connection, String template)
void	runSQL(DBTypeToSQLMap dbTypeToSQLMap)
void	runSQL(String template)
void	runSQL(String[] templates)
void	runSQLTemplate(String path)
void	runSQLTemplate(String path, boolean failOnError)
void	runSQLTemplateString(String template, boolean failOnError)

Methods inherited from class Object

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

Field Detail

connection

protected Connection connection

Constructor Detail

BaseDBProcess

public BaseDBProcess()

Method Detail

runSQL

public void runSQL(Connection connection,
                   String template)
            throws IOException,
                   SQLException

Specified by:

runSQL in interface DBProcess

Throws:

IOException

SQLException

runSQL

public void runSQL(DBTypeToSQLMap dbTypeToSQLMap)
            throws IOException,
                   SQLException

Specified by:

runSQL in interface DBProcess

Throws:

IOException

SQLException

runSQL

public void runSQL(String template)
            throws IOException,
                   SQLException

Specified by:

runSQL in interface DBProcess

Throws:

IOException

SQLException

runSQL

public void runSQL(String[] templates)
            throws IOException,
                   SQLException

Specified by:

runSQL in interface DBProcess

Throws:

IOException

SQLException

runSQLTemplate

public void runSQLTemplate(String path)
                    throws IOException,
                           javax.naming.NamingException,
                           SQLException

Specified by:

runSQLTemplate in interface DBProcess

Throws:

IOException

javax.naming.NamingException

SQLException

runSQLTemplate

public void runSQLTemplate(String path,
                           boolean failOnError)
                    throws IOException,
                           javax.naming.NamingException,
                           SQLException

Specified by:

runSQLTemplate in interface DBProcess

Throws:

IOException

javax.naming.NamingException

SQLException

runSQLTemplateString

public void runSQLTemplateString(String template,
                                 boolean failOnError)
                          throws IOException,
                                 javax.naming.NamingException,
                                 SQLException

Specified by:

runSQLTemplateString in interface DBProcess

Throws:

IOException

javax.naming.NamingException

SQLException

addIndexes

protected void addIndexes(Connection connection,
                          List<IndexMetadata> indexMetadatas)
                   throws IOException,
                          SQLException

Throws:

IOException

SQLException

alterColumnName

protected void alterColumnName(String tableName,
                               String oldColumnName,
                               String newColumnDefinition)
                        throws Exception

Throws:

Exception

alterColumnType

protected void alterColumnType(String tableName,
                               String columnName,
                               String newColumnType)
                        throws Exception

Throws:

Exception

alterTableAddColumn

protected void alterTableAddColumn(String tableName,
                                   String columnName,
                                   String columnType)
                            throws Exception

Throws:

Exception

alterTableDropColumn

protected void alterTableDropColumn(String tableName,
                                    String columnName)
                             throws Exception

Throws:

Exception

alterTableName

protected void alterTableName(String tableName,
                              String newTableName)
                       throws Exception

Throws:

Exception

doHasTable

@Deprecated
protected boolean doHasTable(String tableName)
                                  throws Exception

Deprecated. As of Cavanaugh (7.4.x), replaced by hasTable(String)

Throws:

Exception

dropIndexes

protected List<IndexMetadata> dropIndexes(String tableName,
                                          String columnName)
                                   throws Exception

Throws:

Exception

dropTable

protected void dropTable(String tableName)
                  throws Exception

Throws:

Exception

getConnection

protected Connection getConnection()
                            throws Exception

Throws:

Exception

getPrimaryKeyColumnNames

protected String[] getPrimaryKeyColumnNames(Connection connection,
                                            String tableName)
                                     throws SQLException

Throws:

SQLException

hasColumn

protected boolean hasColumn(String tableName,
                            String columnName)
                     throws Exception

Throws:

Exception

hasColumnType

protected boolean hasColumnType(String tableName,
                                String columnName,
                                String columnType)
                         throws Exception

Throws:

Exception

hasIndex

protected boolean hasIndex(String tableName,
                           String indexName)
                    throws Exception

Throws:

Exception

hasRows

protected boolean hasRows(Connection connection,
                          String tableName)

hasRows

protected boolean hasRows(String tableName)
                   throws Exception

Throws:

Exception

hasTable

protected boolean hasTable(String tableName)
                    throws Exception

Throws:

Exception

process

protected void process(com.liferay.petra.function.UnsafeConsumer<Long,Exception> unsafeConsumer)
                throws Exception

Throws:

Exception

processConcurrently

protected void processConcurrently(String sql,
                                   String updateSQL,
                                   com.liferay.petra.function.UnsafeFunction<ResultSet,Object[],Exception> unsafeFunction,
                                   com.liferay.petra.function.UnsafeBiConsumer<Object[],PreparedStatement,Exception> unsafeBiConsumer,
                                   String exceptionMessage)
                            throws Exception

Throws:

Exception

processConcurrently

protected void processConcurrently(String sql,
                                   com.liferay.petra.function.UnsafeConsumer<PreparedStatement,Exception> unsafeConsumer,
                                   String updateSQL,
                                   com.liferay.petra.function.UnsafeFunction<ResultSet,Object[],Exception> unsafeFunction,
                                   com.liferay.petra.function.UnsafeBiConsumer<Object[],PreparedStatement,Exception> unsafeBiConsumer,
                                   String exceptionMessage)
                            throws Exception

Throws:

Exception

processConcurrently

protected void processConcurrently(String sql,
                                   com.liferay.petra.function.UnsafeFunction<ResultSet,Object[],Exception> unsafeFunction,
                                   com.liferay.petra.function.UnsafeConsumer<Object[],Exception> unsafeConsumer,
                                   String exceptionMessage)
                            throws Exception

Throws:

Exception

processConcurrently

protected <T> void processConcurrently(T[] array,
                                       com.liferay.petra.function.UnsafeConsumer<T,Exception> unsafeConsumer,
                                       String exceptionMessage)
                                throws Exception

Throws:

Exception

removePrimaryKey

protected void removePrimaryKey(String tableName)
                         throws Exception

Throws:

Exception