com.atlassian.bamboo.utils.db

Class AbstractDbmsBean

java.lang.Object

com.atlassian.bamboo.utils.db.AbstractDbmsBean

All Implemented Interfaces:

DbmsBean

Direct Known Subclasses:

HsqlDbmsBean, MsSqlDbmsBean, MySqlDbmsBean, OracleDbmsBean, PostgreSqlDbmsBean

public abstract class AbstractDbmsBean
extends Object
implements DbmsBean

Nested Class Summary

Nested classes/interfaces inherited from interface com.atlassian.bamboo.utils.db.DbmsBean

DbmsBean.ColumnDefinition, DbmsBean.ConstraintDefinition

Field Summary

Fields

Modifier and Type	Field and Description
static int	LARGE_STRING_TYPE

Constructor Summary

Constructors

Constructor and Description
AbstractDbmsBean()

Method Summary

Modifier and Type	Method and Description
protected void	actuallyChangeColumnToNotNull(Connection c, String tableName, String columnName)
void	addColumn(Connection c, String tableName, String columnName, int columnType, Integer columnSize) Add a column to a table.
protected void	changeColumnDefinition(Connection c, String table, String column, String sqlType, boolean isNullable)
void	changeColumnToNotNull(Connection c, String tableName, String columnName) Changes column to not null, unless it's already not null.
void	changeColumnType(Connection c, String table, String column, int type, Integer columnSize, boolean isNullable) Changes column type to the new type (see Types.
void	changeTableNameToUpperCase(Connection connection, String oldName) Rename table from lower case to upper case.
void	createIndex(Connection c, String index, String table, String column)
protected void	createPrimaryKey(Connection c, String table, String pkName, Collection<String> columns)
void	createUniqueConstraint(Connection c, String uniqueKey, String table, String column) Create unique key
boolean	dropColumn(Connection connection, String tableName, String columnName) Checks whether given table contains the specified column and drops it Checks whether given table contains the specified column and drops it, as well as foreign key constraints and index on the column.
void	dropConstraint(Connection c, String tableName, String constraint) Drop constraint
protected void	dropConstraints(Connection connection, String tableName, String columnName)
void	dropForeignKeyConstraint(Connection c, String tableName, String foreignKey)
void	dropIndex(Connection c, String table, String index)
boolean	dropIndexIfExists(Connection c, String table, String index)
void	dropTable(Connection c, String tableName) Drop table.
protected DbmsBean.ColumnDefinition	getColumnDefinition(Connection connection, String tableName, String columnName)
List<DbmsBean.ColumnDefinition>	getColumns(Connection c, String table, String column)
protected List<DbmsBean.ConstraintDefinition>	getConstraintDefinitions(Connection connection, String query, String column)
protected DbmsBean.ConstraintDefinition.ConstraintType	getConstraintType(String typeName)
List<String>	getIndexNames(Connection c, String table, String column) Returns indices set up on a given table, optionally narrowed down to a column.
String	getSchema(Connection c) Schema name, retrieved from connection or cache
protected String	getSchemaUncached(Connection c)
boolean	isColumnPresent(Connection connection, String tableName, String columnName) Checks whether given table contains the specified column.
boolean	isColumnPresent(Statement statement, String tableName, String columnName) Checks whether given table contains the specified column.
boolean	isHsqldb()
boolean	isMsSqlServer()
boolean	isMySql()
boolean	isOracle()
boolean	isPostgreSql()
boolean	isTablePresent(Connection c, String tableName) Checks whether given table is present in the database
void	migrateColumnType(Connection c, String table, String column, int columnType, Integer columnSize) Changes column type to the new type (see Types.
protected DbmsBean.ColumnDefinition	newColumnDefinition(String columnName, int dataType, String dataTypeName, OptionalInt columnSize, Optional<Boolean> isNullable)
abstract void	renameColumn(Connection c, String tableName, String oldName, String newName) Rename columns.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.bamboo.utils.db.DbmsBean

dropPrimaryKey, getCatalog, getConcat, getConstraints, getDatabaseType, getQuery, prepareStatement, resizeVarcharColumn

Field Detail

LARGE_STRING_TYPE

public static final int LARGE_STRING_TYPE

See Also:

Constant Field Values

Constructor Detail

AbstractDbmsBean

public AbstractDbmsBean()

Method Detail

isColumnPresent

public boolean isColumnPresent(@NotNull
                               Connection connection,
                               @NotNull
                               String tableName,
                               @NotNull
                               String columnName)
                        throws SQLException

Description copied from interface: DbmsBean

Checks whether given table contains the specified column.

Specified by:

isColumnPresent in interface DbmsBean

Returns:

Throws:

SQLException

isColumnPresent

public boolean isColumnPresent(@NotNull
                               Statement statement,
                               @NotNull
                               String tableName,
                               @NotNull
                               String columnName)
                        throws SQLException

Description copied from interface: DbmsBean

Checks whether given table contains the specified column.

Specified by:

isColumnPresent in interface DbmsBean

Returns:

Throws:

SQLException

changeColumnType

public void changeColumnType(Connection c,
                             String table,
                             String column,
                             int type,
                             @Nullable
                             Integer columnSize,
                             boolean isNullable)
                      throws SQLException

Description copied from interface: DbmsBean

Changes column type to the new type (see Types. Uses alter table, so won't cope with all type conversions.

Specified by:

changeColumnType in interface DbmsBean

Throws:

SQLException

getConstraintType

protected DbmsBean.ConstraintDefinition.ConstraintType getConstraintType(String typeName)

getConstraintDefinitions

protected List<DbmsBean.ConstraintDefinition> getConstraintDefinitions(Connection connection,
                                                                       String query,
                                                                       @Nullable
                                                                       String column)
                                                                throws SQLException

Throws:

SQLException

changeColumnDefinition

protected void changeColumnDefinition(Connection c,
                                      String table,
                                      String column,
                                      String sqlType,
                                      boolean isNullable)
                               throws SQLException

Throws:

SQLException

migrateColumnType

public void migrateColumnType(Connection c,
                              String table,
                              String column,
                              int columnType,
                              @Nullable
                              Integer columnSize)
                       throws SQLException

Description copied from interface: DbmsBean

Changes column type to the new type (see Types. Uses rename + add + copy + drop for maximum compatibility.

Specified by:

migrateColumnType in interface DbmsBean

Throws:

SQLException

dropColumn

public boolean dropColumn(@NotNull
                          Connection connection,
                          @NotNull
                          String tableName,
                          @NotNull
                          String columnName)
                   throws SQLException

Description copied from interface: DbmsBean

Checks whether given table contains the specified column and drops it Checks whether given table contains the specified column and drops it, as well as foreign key constraints and index on the column. The method will automatically detect constraint names on DBMS that supports it or use provided names on DBMS that don't.

Specified by:

dropColumn in interface DbmsBean

Returns:

Throws:

SQLException

dropConstraints

protected void dropConstraints(Connection connection,
                               String tableName,
                               String columnName)

dropIndex

public void dropIndex(Connection c,
                      String table,
                      String index)
               throws SQLException

Specified by:

dropIndex in interface DbmsBean

Throws:

SQLException

dropIndexIfExists

public boolean dropIndexIfExists(Connection c,
                                 String table,
                                 String index)
                          throws SQLException

Specified by:

dropIndexIfExists in interface DbmsBean

Throws:

SQLException

createIndex

public void createIndex(Connection c,
                        String index,
                        String table,
                        String column)
                 throws SQLException

Specified by:

createIndex in interface DbmsBean

Throws:

SQLException

createUniqueConstraint

public void createUniqueConstraint(Connection c,
                                   String uniqueKey,
                                   String table,
                                   String column)
                            throws SQLException

Description copied from interface: DbmsBean

Create unique key

Specified by:

createUniqueConstraint in interface DbmsBean

Throws:

SQLException - if the operation fails (ie. key exists or data in the column is not unique)

isTablePresent

public boolean isTablePresent(@NotNull
                              Connection c,
                              @NotNull
                              String tableName)
                       throws SQLException

Description copied from interface: DbmsBean

Checks whether given table is present in the database

Specified by:

isTablePresent in interface DbmsBean

Parameters:

c - connection used to verify DB table existence

tableName - name of DB table

Returns:

true if database is accessible and table exists, false otherwise

Throws:

SQLException - if a database error occurs or connection is closed

changeTableNameToUpperCase

public void changeTableNameToUpperCase(Connection connection,
                                       String oldName)
                                throws SQLException

Description copied from interface: DbmsBean

Rename table from lower case to upper case. No-op if database is table names are case insensitive.

Specified by:

changeTableNameToUpperCase in interface DbmsBean

Throws:

SQLException

renameColumn

public abstract void renameColumn(Connection c,
                                  String tableName,
                                  String oldName,
                                  String newName)
                           throws SQLException

Description copied from interface: DbmsBean

Rename columns.

Specified by:

renameColumn in interface DbmsBean

Throws:

SQLException

addColumn

public void addColumn(Connection c,
                      String tableName,
                      String columnName,
                      int columnType,
                      Integer columnSize)
               throws SQLException

Description copied from interface: DbmsBean

Add a column to a table.

Specified by:

addColumn in interface DbmsBean

Throws:

SQLException

dropConstraint

public void dropConstraint(Connection c,
                           String tableName,
                           String constraint)
                    throws SQLException

Description copied from interface: DbmsBean

Drop constraint

Specified by:

dropConstraint in interface DbmsBean

Throws:

SQLException - if constraint does not exist

dropForeignKeyConstraint

public void dropForeignKeyConstraint(Connection c,
                                     String tableName,
                                     String foreignKey)
                              throws SQLException

Specified by:

dropForeignKeyConstraint in interface DbmsBean

Throws:

SQLException

dropTable

public void dropTable(Connection c,
                      String tableName)
               throws SQLException

Description copied from interface: DbmsBean

Drop table.

Specified by:

dropTable in interface DbmsBean

Throws:

SQLException

changeColumnToNotNull

public void changeColumnToNotNull(Connection c,
                                  String tableName,
                                  String columnName)
                           throws SQLException

Description copied from interface: DbmsBean

Changes column to not null, unless it's already not null.

Specified by:

changeColumnToNotNull in interface DbmsBean

Throws:

SQLException

actuallyChangeColumnToNotNull

protected void actuallyChangeColumnToNotNull(Connection c,
                                             String tableName,
                                             String columnName)
                                      throws SQLException

Throws:

SQLException

getIndexNames

public List<String> getIndexNames(Connection c,
                                  String table,
                                  String column)
                           throws SQLException

Description copied from interface: DbmsBean

Returns indices set up on a given table, optionally narrowed down to a column. For HSQLDB, it will also return implicit indices set up to support FK relationships. For SQL Server, it will return implicit PK indices. Case of returned index names is database specific - all comparisons should be case-independent.

Specified by:

getIndexNames in interface DbmsBean

Throws:

SQLException

getColumns

public List<DbmsBean.ColumnDefinition> getColumns(Connection c,
                                                  @NotNull
                                                  String table,
                                                  @Nullable
                                                  String column)
                                           throws SQLException

Specified by:

getColumns in interface DbmsBean

Throws:

SQLException

createPrimaryKey

protected void createPrimaryKey(Connection c,
                                String table,
                                String pkName,
                                Collection<String> columns)
                         throws SQLException

Throws:

SQLException

newColumnDefinition

protected DbmsBean.ColumnDefinition newColumnDefinition(String columnName,
                                                        int dataType,
                                                        String dataTypeName,
                                                        OptionalInt columnSize,
                                                        Optional<Boolean> isNullable)

getColumnDefinition

@Nullable
protected DbmsBean.ColumnDefinition getColumnDefinition(Connection connection,
                                                                  String tableName,
                                                                  @Nullable
                                                                  String columnName)
                                                           throws SQLException

Throws:

SQLException

getSchema

@Nullable
public String getSchema(Connection c)
                           throws SQLException

Description copied from interface: DbmsBean

Schema name, retrieved from connection or cache

Specified by:

getSchema in interface DbmsBean

Returns:

schema name

Throws:

SQLException

getSchemaUncached

@Nullable
protected String getSchemaUncached(Connection c)
                                      throws SQLException

Throws:

SQLException

isHsqldb

public boolean isHsqldb()

Specified by:

isHsqldb in interface DbmsBean

Returns:

true if db configured in Hibernate is HSQL

isMsSqlServer

public boolean isMsSqlServer()

Specified by:

isMsSqlServer in interface DbmsBean

Returns:

true if db configured in Hibernate is Microsoft SQL Server

isMySql

public boolean isMySql()

Specified by:

isMySql in interface DbmsBean

Returns:

true if db configured in Hibernate is MySQL

isOracle

public boolean isOracle()

Specified by:

isOracle in interface DbmsBean

Returns:

true if db configured in Hibernate is Oracle

isPostgreSql

public boolean isPostgreSql()

Specified by:

isPostgreSql in interface DbmsBean

Returns:

true if db configured in Hibernate is PostgreSQL