liquibase.database

Interface Database

All Superinterfaces:

PrioritizedService

All Known Implementing Classes:

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

public interface Database
extends PrioritizedService

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	databaseChangeLogLockTableName
static java.lang.String	databaseChangeLogTableName

Fields inherited from interface liquibase.servicelocator.PrioritizedService

PRIORITY_DATABASE, PRIORITY_DEFAULT

Method Summary

Methods

Modifier and Type	Method and Description
void	addReservedWords(java.util.Collection<java.lang.String> words)
void	close()
void	commit()
java.lang.String	correctObjectName(java.lang.String name, 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.
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 schema)
void	enableForeignKeyChecks()
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)
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
java.lang.String	getAutoIncrementClause(java.math.BigInteger startWith, java.math.BigInteger incrementBy)
java.lang.String	getConcatSql(java.lang.String... values) Returns SQL to concat the passed values.
DatabaseConnection	getConnection()
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()
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 defaultDateValue)
java.lang.String	getDateLiteral(java.lang.String isoDate)
java.lang.String	getDateTimeLiteral(java.sql.Timestamp timeStamp)
java.lang.String	getDefaultCatalogName()
java.lang.String	getDefaultDriver(java.lang.String url) If this database understands the given url, return the default driver class name.
java.lang.Integer	getDefaultPort()
CatalogAndSchema	getDefaultSchema()
java.lang.String	getDefaultSchemaName()
java.lang.String	getLineComment()
java.lang.String	getLiquibaseCatalogName()
java.lang.String	getLiquibaseSchemaName()
java.lang.String	getLiquibaseTablespaceName()
ObjectQuotingStrategy	getObjectQuotingStrategy()
boolean	getOutputDefaultCatalog()
boolean	getOutputDefaultSchema()
RanChangeSet	getRanChangeSet(ChangeSet changeSet)
java.util.List<RanChangeSet>	getRanChangeSetList()
java.util.Date	getRanDate(ChangeSet changeSet)
ChangeSet.RunStatus	getRunStatus(ChangeSet changeSet)
java.lang.String	getShortName() Returns an all-lower-case short name of the product.
java.lang.String	getSystemSchema()
java.lang.String	getTimeLiteral(java.sql.Time time)
java.lang.String	getViewDefinition(CatalogAndSchema schema, java.lang.String name)
boolean	isAutoCommit()
boolean	isCaseSensitive()
boolean	isCorrectDatabaseImplementation(DatabaseConnection conn) Is this AbstractDatabase subclass the correct one to use for the given connection.
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()
boolean	isSystemObject(DatabaseObject example)
void	markChangeSetExecStatus(ChangeSet changeSet, ChangeSet.ExecType execType)
java.util.Date	parseDate(java.lang.String dateAsString)
void	removeRanStatus(ChangeSet changeSet)
boolean	requiresPassword()
boolean	requiresUsername()
void	resetInternalState()
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 catalogName)
void	setDefaultSchemaName(java.lang.String schemaName)
void	setLiquibaseCatalogName(java.lang.String catalogName)
void	setLiquibaseSchemaName(java.lang.String schemaName)
void	setLiquibaseTablespaceName(java.lang.String tablespaceName)
void	setObjectQuotingStrategy(ObjectQuotingStrategy quotingStrategy)
void	setOutputDefaultCatalog(boolean outputDefaultCatalog)
void	setOutputDefaultSchema(boolean outputDefaultSchema) Whether the default schema should be included in generated SQL
boolean	supportsAutoIncrement()
boolean	supportsCatalogInObjectName(java.lang.Class<? extends DatabaseObject> type)
boolean	supportsCatalogs()
boolean	supportsDDLInTransaction() Determines if the database supports DDL within a transaction or not.
boolean	supportsDropTableCascadeConstraints()
boolean	supportsForeignKeyDisable()
boolean	supportsInitiallyDeferrableColumns() Returns whether this database support initially deferrable columns.
boolean	supportsPrimaryKeyNames()
boolean	supportsRestrictForeignKeys()
boolean	supportsSchemas()
boolean	supportsSequences()
boolean	supportsTablespaces()
void	tag(java.lang.String tagString)

Methods inherited from interface liquibase.servicelocator.PrioritizedService

getPriority

Field Detail

databaseChangeLogTableName

static final java.lang.String databaseChangeLogTableName

databaseChangeLogLockTableName

static final java.lang.String databaseChangeLogLockTableName

Method Detail

isCorrectDatabaseImplementation

boolean isCorrectDatabaseImplementation(DatabaseConnection conn)
                                        throws DatabaseException

Is this AbstractDatabase subclass the correct one to use for the given connection.

Throws:

DatabaseException

getDefaultDriver

java.lang.String getDefaultDriver(java.lang.String url)

If this database understands the given url, return the default driver class name. Otherwise return null.

getConnection

DatabaseConnection getConnection()

setConnection

void setConnection(DatabaseConnection conn)

requiresUsername

boolean requiresUsername()

requiresPassword

boolean requiresPassword()

getAutoCommitMode

boolean getAutoCommitMode()

Auto-commit mode to run in

supportsDDLInTransaction

boolean supportsDDLInTransaction()

Determines if the database supports DDL within a transaction or not.

Returns:

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

getDatabaseProductName

java.lang.String getDatabaseProductName()

getDatabaseProductVersion

java.lang.String getDatabaseProductVersion()
                                           throws DatabaseException

Throws:

DatabaseException

getDatabaseMajorVersion

int getDatabaseMajorVersion()
                            throws DatabaseException

Throws:

DatabaseException

getDatabaseMinorVersion

int getDatabaseMinorVersion()
                            throws DatabaseException

Throws:

DatabaseException

getShortName

java.lang.String getShortName()

Returns an all-lower-case short name of the product. Used for end-user selecting of database type such as the DBMS precondition.

getDefaultCatalogName

java.lang.String getDefaultCatalogName()

setDefaultCatalogName

void setDefaultCatalogName(java.lang.String catalogName)
                           throws DatabaseException

Throws:

DatabaseException

getDefaultSchemaName

java.lang.String getDefaultSchemaName()

setDefaultSchemaName

void setDefaultSchemaName(java.lang.String schemaName)
                          throws DatabaseException

Throws:

DatabaseException

getDefaultPort

java.lang.Integer getDefaultPort()

getLiquibaseCatalogName

java.lang.String getLiquibaseCatalogName()

setLiquibaseCatalogName

void setLiquibaseCatalogName(java.lang.String catalogName)

getLiquibaseSchemaName

java.lang.String getLiquibaseSchemaName()

setLiquibaseSchemaName

void setLiquibaseSchemaName(java.lang.String schemaName)

supportsInitiallyDeferrableColumns

boolean supportsInitiallyDeferrableColumns()

Returns whether this database support initially deferrable columns.

supportsSequences

boolean supportsSequences()

supportsDropTableCascadeConstraints

boolean supportsDropTableCascadeConstraints()

supportsAutoIncrement

boolean supportsAutoIncrement()

getDateLiteral

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

getCurrentDateTimeFunction

java.lang.String getCurrentDateTimeFunction()

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

setCurrentDateTimeFunction

void setCurrentDateTimeFunction(java.lang.String function)

getLineComment

java.lang.String getLineComment()

getAutoIncrementClause

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

getDatabaseChangeLogTableName

java.lang.String getDatabaseChangeLogTableName()

getDatabaseChangeLogLockTableName

java.lang.String getDatabaseChangeLogLockTableName()

getLiquibaseTablespaceName

java.lang.String getLiquibaseTablespaceName()

setLiquibaseTablespaceName

void setLiquibaseTablespaceName(java.lang.String tablespaceName)

setDatabaseChangeLogTableName

void setDatabaseChangeLogTableName(java.lang.String tableName)

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

Parameters:

tableName -

setDatabaseChangeLogLockTableName

void setDatabaseChangeLogLockTableName(java.lang.String tableName)

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

Parameters:

tableName -

getConcatSql

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

Returns SQL to concat the passed values.

setCanCacheLiquibaseTableInfo

void setCanCacheLiquibaseTableInfo(boolean canCacheLiquibaseTableInfo)

dropDatabaseObjects

void dropDatabaseObjects(CatalogAndSchema schema)
                         throws LiquibaseException

Throws:

LiquibaseException

tag

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

Throws:

DatabaseException

doesTagExist

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

Throws:

DatabaseException

isSystemObject

boolean isSystemObject(DatabaseObject example)

isLiquibaseObject

boolean isLiquibaseObject(DatabaseObject object)

getViewDefinition

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

Throws:

DatabaseException

getDateLiteral

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

getTimeLiteral

java.lang.String getTimeLiteral(java.sql.Time time)

getDateTimeLiteral

java.lang.String getDateTimeLiteral(java.sql.Timestamp timeStamp)

getDateLiteral

java.lang.String getDateLiteral(java.util.Date defaultDateValue)

escapeObjectName

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

escapeTableName

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

escapeIndexName

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

escapeObjectName

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

escapeColumnName

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. "return").

Parameters:

schemaName -

tableName -

columnName - column name

Returns:

escaped column name

escapeColumnNameList

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. "return").

Parameters:

columnNames - list of column names

Returns:

escaped column name list

supportsTablespaces

boolean supportsTablespaces()

supportsCatalogs

boolean supportsCatalogs()

supportsSchemas

boolean supportsSchemas()

supportsCatalogInObjectName

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

generatePrimaryKeyName

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

escapeSequenceName

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

escapeViewName

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

getRunStatus

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

Throws:

DatabaseException

DatabaseHistoryException

getRanChangeSet

RanChangeSet getRanChangeSet(ChangeSet changeSet)
                             throws DatabaseException,
                                    DatabaseHistoryException

Throws:

DatabaseException

DatabaseHistoryException

markChangeSetExecStatus

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

Throws:

DatabaseException

getRanChangeSetList

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

Throws:

DatabaseException

getRanDate

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

Throws:

DatabaseException

DatabaseHistoryException

removeRanStatus

void removeRanStatus(ChangeSet changeSet)
                     throws DatabaseException

Throws:

DatabaseException

commit

void commit()
            throws DatabaseException

Throws:

DatabaseException

rollback

void rollback()
              throws DatabaseException

Throws:

DatabaseException

escapeStringForDatabase

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

close

void close()
           throws DatabaseException

Throws:

DatabaseException

supportsRestrictForeignKeys

boolean supportsRestrictForeignKeys()

escapeConstraintName

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

isAutoCommit

boolean isAutoCommit()
                     throws DatabaseException

Throws:

DatabaseException

setAutoCommit

void setAutoCommit(boolean b)
                   throws DatabaseException

Throws:

DatabaseException

isSafeToRunUpdate

boolean isSafeToRunUpdate()
                          throws DatabaseException

Throws:

DatabaseException

executeStatements

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

Throws:

LiquibaseException

execute

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

Throws:

LiquibaseException

saveStatements

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

Throws:

java.io.IOException

StatementNotSupportedOnDatabaseException

LiquibaseException

executeRollbackStatements

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

Throws:

LiquibaseException

RollbackImpossibleException

saveRollbackStatement

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

Throws:

java.io.IOException

RollbackImpossibleException

StatementNotSupportedOnDatabaseException

LiquibaseException

parseDate

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

Throws:

DateParseException

getDateFunctions

java.util.List<DatabaseFunction> getDateFunctions()

Returns list of database native date functions

resetInternalState

void resetInternalState()

supportsForeignKeyDisable

boolean supportsForeignKeyDisable()

disableForeignKeyChecks

boolean disableForeignKeyChecks()
                                throws DatabaseException

Throws:

DatabaseException

enableForeignKeyChecks

void enableForeignKeyChecks()
                            throws DatabaseException

Throws:

DatabaseException

isCaseSensitive

boolean isCaseSensitive()

isReservedWord

boolean isReservedWord(java.lang.String string)

correctSchema

CatalogAndSchema correctSchema(CatalogAndSchema schema)

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

Parameters:

schema -

Returns:

correctObjectName

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

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

isFunction

boolean isFunction(java.lang.String string)

getDataTypeMaxParameters

int getDataTypeMaxParameters(java.lang.String dataTypeName)

getDefaultSchema

CatalogAndSchema getDefaultSchema()

dataTypeIsNotModifiable

boolean dataTypeIsNotModifiable(java.lang.String typeName)

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

Parameters:

typeName - type name

Returns:

Whether data type can have a modifier

generateDatabaseFunctionValue

java.lang.String generateDatabaseFunctionValue(DatabaseFunction databaseFunction)

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

Parameters:

databaseFunction - database function to check.

Returns:

the string value to use for an update or generate

setObjectQuotingStrategy

void setObjectQuotingStrategy(ObjectQuotingStrategy quotingStrategy)

getObjectQuotingStrategy

ObjectQuotingStrategy getObjectQuotingStrategy()

createsIndexesForForeignKeys

boolean createsIndexesForForeignKeys()

setOutputDefaultSchema

void setOutputDefaultSchema(boolean outputDefaultSchema)

Whether the default schema should be included in generated SQL

getOutputDefaultSchema

boolean getOutputDefaultSchema()

isDefaultSchema

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

isDefaultCatalog

boolean isDefaultCatalog(java.lang.String catalog)

getOutputDefaultCatalog

boolean getOutputDefaultCatalog()

setOutputDefaultCatalog

void setOutputDefaultCatalog(boolean outputDefaultCatalog)

supportsPrimaryKeyNames

boolean supportsPrimaryKeyNames()

getSystemSchema

java.lang.String getSystemSchema()

addReservedWords

void addReservedWords(java.util.Collection<java.lang.String> words)