liquibase.database

Class AbstractJdbcDatabase

java.lang.Object

liquibase.database.AbstractJdbcDatabase

All Implemented Interfaces:

Database, PrioritizedService

Direct Known Subclasses:

CacheDatabase, DB2Database, DerbyDatabase, FirebirdDatabase, H2Database, HsqlDatabase, InformixDatabase, MaxDBDatabase, MSSQLDatabase, MySQLDatabase, OracleDatabase, PostgresDatabase, SQLiteDatabase, SybaseASADatabase, SybaseDatabase, UnsupportedDatabase

public abstract class AbstractJdbcDatabase
extends java.lang.Object
implements Database

AbstractJdbcDatabase is extended by all supported databases as a facade to the underlying database. The physical connection can be retrieved from the AbstractJdbcDatabase implementation, as well as any database-specific characteristics such as the datatype for "boolean" fields.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	currentDateTimeFunction
protected java.util.List<DatabaseFunction>	dateFunctions
protected java.math.BigInteger	defaultAutoIncrementBy
protected java.math.BigInteger	defaultAutoIncrementStartWith
protected java.lang.String	defaultCatalogName
protected java.lang.String	defaultSchemaName
protected java.lang.String	quotingEndCharacter
protected java.lang.String	quotingStartCharacter
protected ObjectQuotingStrategy	quotingStrategy
protected java.lang.String	sequenceCurrentValueFunction
protected java.lang.String	sequenceNextValueFunction The sequence name will be substituted into the string e.g.
protected java.util.List<java.lang.String>	unmodifiableDataTypes
protected java.lang.Boolean	unquotedObjectsAreUppercased

Fields inherited from interface liquibase.servicelocator.PrioritizedService

PRIORITY_DATABASE, PRIORITY_DEFAULT

Constructor Summary

Constructors

Constructor and Description
AbstractJdbcDatabase()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	canCreateChangeLogTable()
void	checkDatabaseChangeLogLockTable() This method will check the database ChangeLogLock table used to keep track of if a machine is updating the database.
void	checkDatabaseChangeLogTable(boolean updateExistingNullChecksums, DatabaseChangeLog databaseChangeLog, java.lang.String... contexts) This method will check the database ChangeLog table used to keep track of the changes in the file.
void	close()
void	commit()
java.lang.String	correctObjectName(java.lang.String objectName, java.lang.Class<? extends DatabaseObject> objectType) Fix the object name to the format the database expects, handling changes in case, etc.
CatalogAndSchema	correctSchema(CatalogAndSchema schema) Returns a new CatalogAndSchema adjusted for this database.
CatalogAndSchema	correctSchema(java.lang.String catalog, java.lang.String schema)
boolean	createsIndexesForForeignKeys()
boolean	dataTypeIsNotModifiable(java.lang.String typeName) Types like int4 in postgres cannot have a modifier.
boolean	disableForeignKeyChecks()
boolean	doesTagExist(java.lang.String tag)
void	dropDatabaseObjects(CatalogAndSchema schemaToDrop) Drops all objects owned by the connected user.
void	enableForeignKeyChecks()
boolean	equals(java.lang.Object o)
java.lang.String	escapeColumnName(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String columnName) Escapes a single column name in a database-dependent manner so reserved words can be used as a column name (i.e.
java.lang.String	escapeColumnNameList(java.lang.String columnNames) Escapes a list of column names in a database-dependent manner so reserved words can be used as a column name (i.e.
java.lang.String	escapeConstraintName(java.lang.String constraintName)
java.lang.String	escapeIndexName(java.lang.String catalogName, java.lang.String schemaName, java.lang.String indexName)
java.lang.String	escapeObjectName(java.lang.String objectName, java.lang.Class<? extends DatabaseObject> objectType)
java.lang.String	escapeObjectName(java.lang.String catalogName, java.lang.String schemaName, java.lang.String objectName, java.lang.Class<? extends DatabaseObject> objectType)
java.lang.String	escapeSequenceName(java.lang.String catalogName, java.lang.String schemaName, java.lang.String sequenceName)
java.lang.String	escapeStringForDatabase(java.lang.String string)
java.lang.String	escapeTableName(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName)
java.lang.String	escapeViewName(java.lang.String catalogName, java.lang.String schemaName, java.lang.String viewName)
void	execute(SqlStatement[] statements, java.util.List<SqlVisitor> sqlVisitors)
void	executeRollbackStatements(Change change, java.util.List<SqlVisitor> sqlVisitors)
void	executeStatements(Change change, DatabaseChangeLog changeLog, java.util.List<SqlVisitor> sqlVisitors)
protected boolean	generateAutoIncrementBy(java.math.BigInteger incrementBy)
protected boolean	generateAutoIncrementStartWith(java.math.BigInteger startWith)
java.lang.String	generateDatabaseFunctionValue(DatabaseFunction databaseFunction) Some function names are placeholders that need to be replaced with the specific database value.
java.lang.String	generatePrimaryKeyName(java.lang.String tableName)
boolean	getAutoCommitMode() Auto-commit mode to run in
protected java.lang.String	getAutoIncrementByClause()
protected java.lang.String	getAutoIncrementClause()
java.lang.String	getAutoIncrementClause(java.math.BigInteger startWith, java.math.BigInteger incrementBy) Returns database-specific auto-increment DDL clause.
protected java.lang.String	getAutoIncrementClosing()
protected java.lang.String	getAutoIncrementOpening()
protected java.lang.String	getAutoIncrementStartWithClause()
java.lang.String	getConcatSql(java.lang.String... values) Returns SQL to concat the passed values.
DatabaseConnection	getConnection()
protected java.lang.String	getConnectionCatalogName()
protected java.lang.String	getConnectionSchemaName() Overwrite this method to get the default schema name for the connection.
DatabaseObject[]	getContainingObjects()
java.lang.String	getCurrentDateTimeFunction() Returns database-specific function for generating the current date/time.
java.lang.String	getDatabaseChangeLogLockTableName()
java.lang.String	getDatabaseChangeLogTableName()
int	getDatabaseMajorVersion()
int	getDatabaseMinorVersion()
java.lang.String	getDatabaseProductName() Returns the name of the database product according to the underlying database.
java.lang.String	getDatabaseProductVersion()
int	getDataTypeMaxParameters(java.lang.String dataTypeName)
java.util.List<DatabaseFunction>	getDateFunctions() Returns list of database native date functions
java.lang.String	getDateLiteral(java.sql.Date date)
java.lang.String	getDateLiteral(java.util.Date date)
java.lang.String	getDateLiteral(java.lang.String isoDate) Return a date literal with the same value as a string formatted using ISO 8601.
java.lang.String	getDateTimeLiteral(java.sql.Timestamp date)
java.lang.String	getDefaultCatalogName()
protected abstract java.lang.String	getDefaultDatabaseProductName()
CatalogAndSchema	getDefaultSchema()
java.lang.String	getDefaultSchemaName()
java.lang.String	getJdbcCatalogName(CatalogAndSchema schema)
java.lang.String	getJdbcCatalogName(Schema schema)
java.lang.String	getJdbcSchemaName(CatalogAndSchema schema)
java.lang.String	getJdbcSchemaName(Schema schema)
java.lang.String	getLineComment() Returns database-specific line comment string.
java.lang.String	getLiquibaseCatalogName()
java.lang.String	getLiquibaseSchemaName()
java.lang.String	getLiquibaseTablespaceName()
java.lang.String	getName()
int	getNextChangeSetSequenceValue()
ObjectQuotingStrategy	getObjectQuotingStrategy()
boolean	getOutputDefaultCatalog()
boolean	getOutputDefaultSchema()
RanChangeSet	getRanChangeSet(ChangeSet changeSet)
java.util.List<RanChangeSet>	getRanChangeSetList() Returns the ChangeSets that have been run against the current database.
java.util.Date	getRanDate(ChangeSet changeSet)
ChangeSet.RunStatus	getRunStatus(ChangeSet changeSet) Returns the run status for the given ChangeSet
CatalogAndSchema	getSchemaFromJdbcInfo(java.lang.String rawCatalogName, java.lang.String rawSchemaName)
protected java.util.Set<java.lang.String>	getSystemTables() Returns system (undroppable) views.
protected java.util.Set<java.lang.String>	getSystemViews() Returns system (undroppable) views.
java.lang.String	getTimeLiteral(java.sql.Time date)
java.lang.String	getViewDefinition(CatalogAndSchema schema, java.lang.String viewName)
boolean	hasDatabaseChangeLogLockTable()
boolean	hasDatabaseChangeLogTable()
int	hashCode()
boolean	isAutoCommit()
boolean	isCaseSensitive()
boolean	isDatabaseChangeLogLockTableInitialized(boolean tableJustCreated)
protected boolean	isDateOnly(java.lang.String isoDate)
protected boolean	isDateTime(java.lang.String isoDate)
boolean	isDefaultCatalog(java.lang.String catalog)
boolean	isDefaultSchema(java.lang.String catalog, java.lang.String schema)
boolean	isFunction(java.lang.String string)
boolean	isLiquibaseObject(DatabaseObject object)
boolean	isReservedWord(java.lang.String string)
boolean	isSafeToRunUpdate() Default implementation, just look for "local" IPs.
boolean	isSystemObject(DatabaseObject example)
boolean	isSystemView(CatalogAndSchema schema, java.lang.String viewName)
protected boolean	isTimeOnly(java.lang.String isoDate)
boolean	jdbcCallsCatalogsSchemas()
void	markChangeSetExecStatus(ChangeSet changeSet, ChangeSet.ExecType execType) After the change set has been ran against the database this method will update the change log table with the information.
java.util.Date	parseDate(java.lang.String dateAsString)
java.lang.String	quoteObject(java.lang.String objectName, java.lang.Class<? extends DatabaseObject> objectType)
void	removeRanStatus(ChangeSet changeSet)
boolean	requiresPassword()
boolean	requiresUsername()
void	resetInternalState()
protected void	resetRanChangeSetList()
void	rollback()
void	saveRollbackStatement(Change change, java.util.List<SqlVisitor> sqlVisitors, java.io.Writer writer)
void	saveStatements(Change change, java.util.List<SqlVisitor> sqlVisitors, java.io.Writer writer)
void	setAutoCommit(boolean b)
void	setCanCacheLiquibaseTableInfo(boolean canCacheLiquibaseTableInfo)
void	setConnection(DatabaseConnection conn)
void	setCurrentDateTimeFunction(java.lang.String function)
void	setDatabaseChangeLogLockTableName(java.lang.String tableName) Set the table name of the change log lock to the given table name
void	setDatabaseChangeLogTableName(java.lang.String tableName) Set the table name of the change log to the given table name
void	setDefaultCatalogName(java.lang.String defaultCatalogName)
void	setDefaultSchemaName(java.lang.String schemaName)
void	setLiquibaseCatalogName(java.lang.String catalogName)
void	setLiquibaseSchemaName(java.lang.String schemaName)
void	setLiquibaseTablespaceName(java.lang.String tablespace)
void	setObjectQuotingStrategy(ObjectQuotingStrategy quotingStrategy)
void	setOutputDefaultCatalog(boolean outputDefaultCatalog)
void	setOutputDefaultSchema(boolean outputDefaultSchema) Whether the default schema should be included in generated SQL
protected boolean	startsWithNumeric(java.lang.String objectName)
boolean	supportsAutoIncrement()
boolean	supportsCatalogInObjectName(java.lang.Class<? extends DatabaseObject> type)
boolean	supportsCatalogs()
boolean	supportsDDLInTransaction() By default databases should support DDL within a transaction.
boolean	supportsDropTableCascadeConstraints()
boolean	supportsForeignKeyDisable()
boolean	supportsPrimaryKeyNames()
boolean	supportsRestrictForeignKeys()
boolean	supportsSchemas()
boolean	supportsSequences() Does the database type support sequence.
void	tag(java.lang.String tagString) Tags the database changelog with the given string.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface liquibase.database.Database

getDefaultDriver, getDefaultPort, getShortName, isCorrectDatabaseImplementation, supportsInitiallyDeferrableColumns, supportsTablespaces

Methods inherited from interface liquibase.servicelocator.PrioritizedService

getPriority

Field Detail

defaultCatalogName

protected java.lang.String defaultCatalogName

defaultSchemaName

protected java.lang.String defaultSchemaName

currentDateTimeFunction

protected java.lang.String currentDateTimeFunction

sequenceNextValueFunction

protected java.lang.String sequenceNextValueFunction

The sequence name will be substituted into the string e.g. NEXTVAL('%s')

sequenceCurrentValueFunction

protected java.lang.String sequenceCurrentValueFunction

quotingStartCharacter

protected java.lang.String quotingStartCharacter

quotingEndCharacter

protected java.lang.String quotingEndCharacter

dateFunctions

protected java.util.List<DatabaseFunction> dateFunctions

unmodifiableDataTypes

protected java.util.List<java.lang.String> unmodifiableDataTypes

defaultAutoIncrementStartWith

protected java.math.BigInteger defaultAutoIncrementStartWith

defaultAutoIncrementBy

protected java.math.BigInteger defaultAutoIncrementBy

unquotedObjectsAreUppercased

protected java.lang.Boolean unquotedObjectsAreUppercased

quotingStrategy

protected ObjectQuotingStrategy quotingStrategy

Constructor Detail

AbstractJdbcDatabase

public AbstractJdbcDatabase()

Method Detail

resetRanChangeSetList

protected void resetRanChangeSetList()

getName

public java.lang.String getName()

requiresPassword

public boolean requiresPassword()

Specified by:

requiresPassword in interface Database

requiresUsername

public boolean requiresUsername()

Specified by:

requiresUsername in interface Database

getContainingObjects

public DatabaseObject[] getContainingObjects()

getConnection

public DatabaseConnection getConnection()

Specified by:

getConnection in interface Database

setConnection

public void setConnection(DatabaseConnection conn)

Specified by:

setConnection in interface Database

getAutoCommitMode

public boolean getAutoCommitMode()

Auto-commit mode to run in

Specified by:

getAutoCommitMode in interface Database

supportsDDLInTransaction

public boolean supportsDDLInTransaction()

By default databases should support DDL within a transaction.

Specified by:

supportsDDLInTransaction in interface Database

Returns:

True if the database supports DDL within a transaction, otherwise false.

getDatabaseProductName

public java.lang.String getDatabaseProductName()

Returns the name of the database product according to the underlying database.

Specified by:

getDatabaseProductName in interface Database

getDefaultDatabaseProductName

protected abstract java.lang.String getDefaultDatabaseProductName()

getDatabaseProductVersion

public java.lang.String getDatabaseProductVersion()
                                           throws DatabaseException

Specified by:

getDatabaseProductVersion in interface Database

Throws:

DatabaseException

getDatabaseMajorVersion

public int getDatabaseMajorVersion()
                            throws DatabaseException

Specified by:

getDatabaseMajorVersion in interface Database

Throws:

DatabaseException

getDatabaseMinorVersion

public int getDatabaseMinorVersion()
                            throws DatabaseException

Specified by:

getDatabaseMinorVersion in interface Database

Throws:

DatabaseException

getDefaultCatalogName

public java.lang.String getDefaultCatalogName()

Specified by:

getDefaultCatalogName in interface Database

getConnectionCatalogName

protected java.lang.String getConnectionCatalogName()
                                             throws DatabaseException

Throws:

DatabaseException

correctSchema

public CatalogAndSchema correctSchema(java.lang.String catalog,
                             java.lang.String schema)

correctSchema

public CatalogAndSchema correctSchema(CatalogAndSchema schema)

Description copied from interface: Database

Returns a new CatalogAndSchema adjusted for this database. Examples of adjustments include: fixes for case issues, replacing null schema or catalog names with the default values removing set schema or catalog names if they are not supported

Specified by:

correctSchema in interface Database

Returns:

correctObjectName

public java.lang.String correctObjectName(java.lang.String objectName,
                                 java.lang.Class<? extends DatabaseObject> objectType)

Description copied from interface: Database

Fix the object name to the format the database expects, handling changes in case, etc.

Specified by:

correctObjectName in interface Database

getDefaultSchema

public CatalogAndSchema getDefaultSchema()

Specified by:

getDefaultSchema in interface Database

getDefaultSchemaName

public java.lang.String getDefaultSchemaName()

Specified by:

getDefaultSchemaName in interface Database

getConnectionSchemaName

protected java.lang.String getConnectionSchemaName()

Overwrite this method to get the default schema name for the connection.

Returns:

setDefaultCatalogName

public void setDefaultCatalogName(java.lang.String defaultCatalogName)

Specified by:

setDefaultCatalogName in interface Database

setDefaultSchemaName

public void setDefaultSchemaName(java.lang.String schemaName)

Specified by:

setDefaultSchemaName in interface Database

getSystemTables

protected java.util.Set<java.lang.String> getSystemTables()

Returns system (undroppable) views.

getSystemViews

protected java.util.Set<java.lang.String> getSystemViews()

Returns system (undroppable) views.

supportsSequences

public boolean supportsSequences()

Does the database type support sequence.

Specified by:

supportsSequences in interface Database

supportsAutoIncrement

public boolean supportsAutoIncrement()

Specified by:

supportsAutoIncrement in interface Database

setCurrentDateTimeFunction

public void setCurrentDateTimeFunction(java.lang.String function)

Specified by:

setCurrentDateTimeFunction in interface Database

getDateLiteral

public java.lang.String getDateLiteral(java.lang.String isoDate)

Return a date literal with the same value as a string formatted using ISO 8601.

Note: many databases accept date literals in ISO8601 format with the 'T' replaced with a space. Only databases which do not accept these strings should need to override this method.

Implementation restriction: Currently, only the following subsets of ISO8601 are supported: yyyy-MM-dd hh:mm:ss yyyy-MM-ddThh:mm:ss

Specified by:

getDateLiteral in interface Database

getDateTimeLiteral

public java.lang.String getDateTimeLiteral(java.sql.Timestamp date)

Specified by:

getDateTimeLiteral in interface Database

getDateLiteral

public java.lang.String getDateLiteral(java.sql.Date date)

Specified by:

getDateLiteral in interface Database

getTimeLiteral

public java.lang.String getTimeLiteral(java.sql.Time date)

Specified by:

getTimeLiteral in interface Database

getDateLiteral

public java.lang.String getDateLiteral(java.util.Date date)

Specified by:

getDateLiteral in interface Database

parseDate

public java.util.Date parseDate(java.lang.String dateAsString)
                         throws DateParseException

Specified by:

parseDate in interface Database

Throws:

DateParseException

isDateOnly

protected boolean isDateOnly(java.lang.String isoDate)

isDateTime

protected boolean isDateTime(java.lang.String isoDate)

isTimeOnly

protected boolean isTimeOnly(java.lang.String isoDate)

getLineComment

public java.lang.String getLineComment()

Returns database-specific line comment string.

Specified by:

getLineComment in interface Database

getAutoIncrementClause

public java.lang.String getAutoIncrementClause(java.math.BigInteger startWith,
                                      java.math.BigInteger incrementBy)

Returns database-specific auto-increment DDL clause.

Specified by:

getAutoIncrementClause in interface Database

getAutoIncrementClause

protected java.lang.String getAutoIncrementClause()

generateAutoIncrementStartWith

protected boolean generateAutoIncrementStartWith(java.math.BigInteger startWith)

generateAutoIncrementBy

protected boolean generateAutoIncrementBy(java.math.BigInteger incrementBy)

getAutoIncrementOpening

protected java.lang.String getAutoIncrementOpening()

getAutoIncrementClosing

protected java.lang.String getAutoIncrementClosing()

getAutoIncrementStartWithClause

protected java.lang.String getAutoIncrementStartWithClause()

getAutoIncrementByClause

protected java.lang.String getAutoIncrementByClause()

getConcatSql

public java.lang.String getConcatSql(java.lang.String... values)

Description copied from interface: Database

Returns SQL to concat the passed values.

Specified by:

getConcatSql in interface Database

getDatabaseChangeLogTableName

public java.lang.String getDatabaseChangeLogTableName()

Specified by:

getDatabaseChangeLogTableName in interface Database

See Also:

Database.getDatabaseChangeLogTableName()

getDatabaseChangeLogLockTableName

public java.lang.String getDatabaseChangeLogLockTableName()

Specified by:

getDatabaseChangeLogLockTableName in interface Database

See Also:

Database.getDatabaseChangeLogLockTableName()

getLiquibaseTablespaceName

public java.lang.String getLiquibaseTablespaceName()

Specified by:

getLiquibaseTablespaceName in interface Database

See Also:

Database.getLiquibaseTablespaceName()

setDatabaseChangeLogTableName

public void setDatabaseChangeLogTableName(java.lang.String tableName)

Description copied from interface: Database

Set the table name of the change log to the given table name

Specified by:

setDatabaseChangeLogTableName in interface Database

See Also:

Database.setDatabaseChangeLogTableName(java.lang.String)

setDatabaseChangeLogLockTableName

public void setDatabaseChangeLogLockTableName(java.lang.String tableName)

Description copied from interface: Database

Set the table name of the change log lock to the given table name

Specified by:

setDatabaseChangeLogLockTableName in interface Database

See Also:

Database.setDatabaseChangeLogLockTableName(java.lang.String)

setLiquibaseTablespaceName

public void setLiquibaseTablespaceName(java.lang.String tablespace)

Specified by:

setLiquibaseTablespaceName in interface Database

See Also:

Database.setLiquibaseTablespaceName(java.lang.String)

checkDatabaseChangeLogTable

public void checkDatabaseChangeLogTable(boolean updateExistingNullChecksums,
                               DatabaseChangeLog databaseChangeLog,
                               java.lang.String... contexts)
                                 throws DatabaseException

This method will check the database ChangeLog table used to keep track of the changes in the file. If the table does not exist it will create one otherwise it will not do anything besides outputting a log message.

Specified by:

checkDatabaseChangeLogTable in interface Database

Parameters:

updateExistingNullChecksums -

contexts -

Throws:

DatabaseException

canCreateChangeLogTable

protected boolean canCreateChangeLogTable()
                                   throws DatabaseException

Throws:

DatabaseException

setCanCacheLiquibaseTableInfo

public void setCanCacheLiquibaseTableInfo(boolean canCacheLiquibaseTableInfo)

Specified by:

setCanCacheLiquibaseTableInfo in interface Database

hasDatabaseChangeLogTable

public boolean hasDatabaseChangeLogTable()
                                  throws DatabaseException

Specified by:

hasDatabaseChangeLogTable in interface Database

Throws:

DatabaseException

hasDatabaseChangeLogLockTable

public boolean hasDatabaseChangeLogLockTable()
                                      throws DatabaseException

Specified by:

hasDatabaseChangeLogLockTable in interface Database

Throws:

DatabaseException

isDatabaseChangeLogLockTableInitialized

public boolean isDatabaseChangeLogLockTableInitialized(boolean tableJustCreated)
                                                throws DatabaseException

Throws:

DatabaseException

getLiquibaseCatalogName

public java.lang.String getLiquibaseCatalogName()

Specified by:

getLiquibaseCatalogName in interface Database

setLiquibaseCatalogName

public void setLiquibaseCatalogName(java.lang.String catalogName)

Specified by:

setLiquibaseCatalogName in interface Database

getLiquibaseSchemaName

public java.lang.String getLiquibaseSchemaName()

Specified by:

getLiquibaseSchemaName in interface Database

setLiquibaseSchemaName

public void setLiquibaseSchemaName(java.lang.String schemaName)

Specified by:

setLiquibaseSchemaName in interface Database

checkDatabaseChangeLogLockTable

public void checkDatabaseChangeLogLockTable()
                                     throws DatabaseException

This method will check the database ChangeLogLock table used to keep track of if a machine is updating the database. If the table does not exist it will create one otherwise it will not do anything besides outputting a log message.

Specified by:

checkDatabaseChangeLogLockTable in interface Database

Throws:

DatabaseException

isCaseSensitive

public boolean isCaseSensitive()

Specified by:

isCaseSensitive in interface Database

isReservedWord

public boolean isReservedWord(java.lang.String string)

Specified by:

isReservedWord in interface Database

startsWithNumeric

protected boolean startsWithNumeric(java.lang.String objectName)

dropDatabaseObjects

public void dropDatabaseObjects(CatalogAndSchema schemaToDrop)
                         throws LiquibaseException

Drops all objects owned by the connected user.

Specified by:

dropDatabaseObjects in interface Database

Throws:

LiquibaseException

supportsDropTableCascadeConstraints

public boolean supportsDropTableCascadeConstraints()

Specified by:

supportsDropTableCascadeConstraints in interface Database

isSystemObject

public boolean isSystemObject(DatabaseObject example)

Specified by:

isSystemObject in interface Database

isSystemView

public boolean isSystemView(CatalogAndSchema schema,
                   java.lang.String viewName)

isLiquibaseObject

public boolean isLiquibaseObject(DatabaseObject object)

Specified by:

isLiquibaseObject in interface Database

tag

public void tag(java.lang.String tagString)
         throws DatabaseException

Tags the database changelog with the given string.

Specified by:

tag in interface Database

Throws:

DatabaseException

doesTagExist

public boolean doesTagExist(java.lang.String tag)
                     throws DatabaseException

Specified by:

doesTagExist in interface Database

Throws:

DatabaseException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getViewDefinition

public java.lang.String getViewDefinition(CatalogAndSchema schema,
                                 java.lang.String viewName)
                                   throws DatabaseException

Specified by:

getViewDefinition in interface Database

Throws:

DatabaseException

escapeTableName

public java.lang.String escapeTableName(java.lang.String catalogName,
                               java.lang.String schemaName,
                               java.lang.String tableName)

Specified by:

escapeTableName in interface Database

escapeObjectName

public java.lang.String escapeObjectName(java.lang.String catalogName,
                                java.lang.String schemaName,
                                java.lang.String objectName,
                                java.lang.Class<? extends DatabaseObject> objectType)

Specified by:

escapeObjectName in interface Database

escapeObjectName

public java.lang.String escapeObjectName(java.lang.String objectName,
                                java.lang.Class<? extends DatabaseObject> objectType)

Specified by:

escapeObjectName in interface Database

quoteObject

public java.lang.String quoteObject(java.lang.String objectName,
                           java.lang.Class<? extends DatabaseObject> objectType)

escapeIndexName

public java.lang.String escapeIndexName(java.lang.String catalogName,
                               java.lang.String schemaName,
                               java.lang.String indexName)

Specified by:

escapeIndexName in interface Database

escapeSequenceName

public java.lang.String escapeSequenceName(java.lang.String catalogName,
                                  java.lang.String schemaName,
                                  java.lang.String sequenceName)

Specified by:

escapeSequenceName in interface Database

escapeConstraintName

public java.lang.String escapeConstraintName(java.lang.String constraintName)

Specified by:

escapeConstraintName in interface Database

escapeColumnName

public java.lang.String escapeColumnName(java.lang.String catalogName,
                                java.lang.String schemaName,
                                java.lang.String tableName,
                                java.lang.String columnName)

Description copied from interface: Database

Escapes a single column name in a database-dependent manner so reserved words can be used as a column name (i.e. "return").

Specified by:

escapeColumnName in interface Database

columnName - column name

Returns:

escaped column name

escapeColumnNameList

public java.lang.String escapeColumnNameList(java.lang.String columnNames)

Description copied from interface: Database

Escapes a list of column names in a database-dependent manner so reserved words can be used as a column name (i.e. "return").

Specified by:

escapeColumnNameList in interface Database

Parameters:

columnNames - list of column names

Returns:

escaped column name list

supportsSchemas

public boolean supportsSchemas()

Specified by:

supportsSchemas in interface Database

supportsCatalogs

public boolean supportsCatalogs()

Specified by:

supportsCatalogs in interface Database

jdbcCallsCatalogsSchemas

public boolean jdbcCallsCatalogsSchemas()

supportsCatalogInObjectName

public boolean supportsCatalogInObjectName(java.lang.Class<? extends DatabaseObject> type)

Specified by:

supportsCatalogInObjectName in interface Database

generatePrimaryKeyName

public java.lang.String generatePrimaryKeyName(java.lang.String tableName)

Specified by:

generatePrimaryKeyName in interface Database

escapeViewName

public java.lang.String escapeViewName(java.lang.String catalogName,
                              java.lang.String schemaName,
                              java.lang.String viewName)

Specified by:

escapeViewName in interface Database

getRunStatus

public ChangeSet.RunStatus getRunStatus(ChangeSet changeSet)
                                 throws DatabaseException,
                                        DatabaseHistoryException

Returns the run status for the given ChangeSet

Specified by:

getRunStatus in interface Database

Throws:

DatabaseException

DatabaseHistoryException

getRanChangeSet

public RanChangeSet getRanChangeSet(ChangeSet changeSet)
                             throws DatabaseException,
                                    DatabaseHistoryException

Specified by:

getRanChangeSet in interface Database

Throws:

DatabaseException

DatabaseHistoryException

getRanChangeSetList

public java.util.List<RanChangeSet> getRanChangeSetList()
                                                 throws DatabaseException

Returns the ChangeSets that have been run against the current database.

Specified by:

getRanChangeSetList in interface Database

Throws:

DatabaseException

getRanDate

public java.util.Date getRanDate(ChangeSet changeSet)
                          throws DatabaseException,
                                 DatabaseHistoryException

Specified by:

getRanDate in interface Database

Throws:

DatabaseException

DatabaseHistoryException

markChangeSetExecStatus

public void markChangeSetExecStatus(ChangeSet changeSet,
                           ChangeSet.ExecType execType)
                             throws DatabaseException

After the change set has been ran against the database this method will update the change log table with the information.

Specified by:

markChangeSetExecStatus in interface Database

Throws:

DatabaseException

removeRanStatus

public void removeRanStatus(ChangeSet changeSet)
                     throws DatabaseException

Specified by:

removeRanStatus in interface Database

Throws:

DatabaseException

escapeStringForDatabase

public java.lang.String escapeStringForDatabase(java.lang.String string)

Specified by:

escapeStringForDatabase in interface Database

commit

public void commit()
            throws DatabaseException

Specified by:

commit in interface Database

Throws:

DatabaseException

rollback

public void rollback()
              throws DatabaseException

Specified by:

rollback in interface Database

Throws:

DatabaseException

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

close

public void close()
           throws DatabaseException

Specified by:

close in interface Database

Throws:

DatabaseException

supportsRestrictForeignKeys

public boolean supportsRestrictForeignKeys()

Specified by:

supportsRestrictForeignKeys in interface Database

isAutoCommit

public boolean isAutoCommit()
                     throws DatabaseException

Specified by:

isAutoCommit in interface Database

Throws:

DatabaseException

setAutoCommit

public void setAutoCommit(boolean b)
                   throws DatabaseException

Specified by:

setAutoCommit in interface Database

Throws:

DatabaseException

isSafeToRunUpdate

public boolean isSafeToRunUpdate()
                          throws DatabaseException

Default implementation, just look for "local" IPs. If the database returns a null URL we return false since we don't know it's safe to run the update.

Specified by:

isSafeToRunUpdate in interface Database

Throws:

DatabaseException

executeStatements

public void executeStatements(Change change,
                     DatabaseChangeLog changeLog,
                     java.util.List<SqlVisitor> sqlVisitors)
                       throws LiquibaseException

Specified by:

executeStatements in interface Database

Throws:

LiquibaseException

execute

public void execute(SqlStatement[] statements,
           java.util.List<SqlVisitor> sqlVisitors)
             throws LiquibaseException

Specified by:

execute in interface Database

Throws:

LiquibaseException

saveStatements

public void saveStatements(Change change,
                  java.util.List<SqlVisitor> sqlVisitors,
                  java.io.Writer writer)
                    throws java.io.IOException,
                           StatementNotSupportedOnDatabaseException,
                           LiquibaseException

Specified by:

saveStatements in interface Database

Throws:

java.io.IOException

StatementNotSupportedOnDatabaseException

LiquibaseException

executeRollbackStatements

public void executeRollbackStatements(Change change,
                             java.util.List<SqlVisitor> sqlVisitors)
                               throws LiquibaseException,
                                      RollbackImpossibleException

Specified by:

executeRollbackStatements in interface Database

Throws:

LiquibaseException

RollbackImpossibleException

saveRollbackStatement

public void saveRollbackStatement(Change change,
                         java.util.List<SqlVisitor> sqlVisitors,
                         java.io.Writer writer)
                           throws java.io.IOException,
                                  RollbackImpossibleException,
                                  StatementNotSupportedOnDatabaseException,
                                  LiquibaseException

Specified by:

saveRollbackStatement in interface Database

Throws:

java.io.IOException

RollbackImpossibleException

StatementNotSupportedOnDatabaseException

LiquibaseException

getNextChangeSetSequenceValue

public int getNextChangeSetSequenceValue()
                                  throws LiquibaseException

Specified by:

getNextChangeSetSequenceValue in interface Database

Throws:

LiquibaseException

getDateFunctions

public java.util.List<DatabaseFunction> getDateFunctions()

Description copied from interface: Database

Returns list of database native date functions

Specified by:

getDateFunctions in interface Database

isFunction

public boolean isFunction(java.lang.String string)

Specified by:

isFunction in interface Database

resetInternalState

public void resetInternalState()

Specified by:

resetInternalState in interface Database

supportsForeignKeyDisable

public boolean supportsForeignKeyDisable()

Specified by:

supportsForeignKeyDisable in interface Database

disableForeignKeyChecks

public boolean disableForeignKeyChecks()
                                throws DatabaseException

Specified by:

disableForeignKeyChecks in interface Database

Throws:

DatabaseException

enableForeignKeyChecks

public void enableForeignKeyChecks()
                            throws DatabaseException

Specified by:

enableForeignKeyChecks in interface Database

Throws:

DatabaseException

createsIndexesForForeignKeys

public boolean createsIndexesForForeignKeys()

Specified by:

createsIndexesForForeignKeys in interface Database

getDataTypeMaxParameters

public int getDataTypeMaxParameters(java.lang.String dataTypeName)

Specified by:

getDataTypeMaxParameters in interface Database

getSchemaFromJdbcInfo

public CatalogAndSchema getSchemaFromJdbcInfo(java.lang.String rawCatalogName,
                                     java.lang.String rawSchemaName)

getJdbcCatalogName

public java.lang.String getJdbcCatalogName(CatalogAndSchema schema)

getJdbcSchemaName

public java.lang.String getJdbcSchemaName(CatalogAndSchema schema)

getJdbcCatalogName

public final java.lang.String getJdbcCatalogName(Schema schema)

getJdbcSchemaName

public final java.lang.String getJdbcSchemaName(Schema schema)

dataTypeIsNotModifiable

public boolean dataTypeIsNotModifiable(java.lang.String typeName)

Description copied from interface: Database

Types like int4 in postgres cannot have a modifier. e.g. int4(10) Checks whether the type is allowed to have a modifier

Specified by:

dataTypeIsNotModifiable in interface Database

Parameters:

typeName - type name

Returns:

Whether data type can have a modifier

setObjectQuotingStrategy

public void setObjectQuotingStrategy(ObjectQuotingStrategy quotingStrategy)

Specified by:

setObjectQuotingStrategy in interface Database

getObjectQuotingStrategy

public ObjectQuotingStrategy getObjectQuotingStrategy()

Specified by:

getObjectQuotingStrategy in interface Database

generateDatabaseFunctionValue

public java.lang.String generateDatabaseFunctionValue(DatabaseFunction databaseFunction)

Description copied from interface: Database

Some function names are placeholders that need to be replaced with the specific database value. e.g. nextSequenceValue(sequenceName) should be replaced with NEXT_VAL('sequenceName') for Postgresql

Specified by:

generateDatabaseFunctionValue in interface Database

Parameters:

databaseFunction - database function to check.

Returns:

the string value to use for an update or generate

getCurrentDateTimeFunction

public java.lang.String getCurrentDateTimeFunction()

Description copied from interface: Database

Returns database-specific function for generating the current date/time.

Specified by:

getCurrentDateTimeFunction in interface Database

setOutputDefaultSchema

public void setOutputDefaultSchema(boolean outputDefaultSchema)

Description copied from interface: Database

Whether the default schema should be included in generated SQL

Specified by:

setOutputDefaultSchema in interface Database

isDefaultSchema

public boolean isDefaultSchema(java.lang.String catalog,
                      java.lang.String schema)

Specified by:

isDefaultSchema in interface Database

isDefaultCatalog

public boolean isDefaultCatalog(java.lang.String catalog)

Specified by:

isDefaultCatalog in interface Database

getOutputDefaultSchema

public boolean getOutputDefaultSchema()

Specified by:

getOutputDefaultSchema in interface Database

getOutputDefaultCatalog

public boolean getOutputDefaultCatalog()

Specified by:

getOutputDefaultCatalog in interface Database

setOutputDefaultCatalog

public void setOutputDefaultCatalog(boolean outputDefaultCatalog)

Specified by:

setOutputDefaultCatalog in interface Database

supportsPrimaryKeyNames

public boolean supportsPrimaryKeyNames()

Specified by:

supportsPrimaryKeyNames in interface Database