org.apache.ambari.server.orm

Class DBAccessorImpl

java.lang.Object

org.apache.ambari.server.orm.DBAccessorImpl

All Implemented Interfaces:

DBAccessor

public class DBAccessorImpl
extends Object
implements DBAccessor

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ambari.server.orm.DBAccessor

DBAccessor.DBColumnInfo

Constructor Summary

Constructors

Constructor and Description
DBAccessorImpl(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	addColumn(String tableName, DBAccessor.DBColumnInfo columnInfo) Add column to existing table
void	addFKConstraint(String tableName, String constraintName, String[] keyColumns, String referenceTableName, String[] referenceColumns, boolean ignoreFailure) Add foreign key for a relation
void	addFKConstraint(String tableName, String constraintName, String keyColumn, String referenceTableName, String referenceColumn, boolean ignoreFailure) Add foreign key for a relation
void	alterColumn(String tableName, DBAccessor.DBColumnInfo columnInfo) Alter column from existing table, only supports varchar extension Use following sequence for more complex stuff: DBAccessor.addColumn(String, org.apache.ambari.server.orm.DBAccessor.DBColumnInfo) DBAccessor.updateTable(String, String, Object, String) DBAccessor.dropColumn(String, String) DBAccessor.renameColumn(String, String, org.apache.ambari.server.orm.DBAccessor.DBColumnInfo)
void	createIndex(String indexName, String tableName, String... columnNames) Create new index
void	createTable(String tableName, List<DBAccessor.DBColumnInfo> columnInfo, String... primaryKeyColumns) Create new table
void	dropColumn(String tableName, String columnName) Drop a column from table
void	dropConstraint(String tableName, String constraintName) Drop a constraint from table
void	dropConstraint(String tableName, String constraintName, boolean ignoreFailure) Drop a constraint from table
void	dropSequence(String sequenceName) Drop sequence
void	dropTable(String tableName) Drop table from schema
void	executeQuery(String query) Execute ad-hoc query on DB.
void	executeQuery(String query, boolean ignoreFailure) Execute query on DB
void	executeScript(String filePath) Helper method to run third party scripts like Quartz DDL
ResultSet	executeSelect(String query) Execute select query
protected Connection	getConnection()
protected DatabaseMetaData	getDatabaseMetaData()
protected String	getDbType()
org.eclipse.persistence.sessions.DatabaseSession	getNewDatabaseSession() Get a new DB session
boolean	insertRow(String tableName, String[] columnNames, String[] values, boolean ignoreFailure) Insert row into table
protected DbmsHelper	loadHelper(org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform)
void	renameColumn(String tableName, String oldColumnName, DBAccessor.DBColumnInfo columnInfo) Rename existing column
boolean	tableExists(String tableName) Verify if table exists by looking at metadata.
boolean	tableHasColumn(String tableName, String columnName) Verify if table already has a column defined.
boolean	tableHasData(String tableName) Verify if table has any data
boolean	tableHasForeignKey(String tableName, String fkName) Verify if table has a FK constraint.
boolean	tableHasForeignKey(String tableName, String referenceTableName, String[] keyColumns, String[] referenceColumns) Verify if table already has a FK constraint.
boolean	tableHasForeignKey(String tableName, String refTableName, String columnName, String refColumnName) Verify if table already has a FK constraint.
void	truncateTable(String tableName) Delete all table data
int	updateTable(String tableName, String columnName, Object value, String whereClause) Simple update operation on table

Methods inherited from class java.lang.Object

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

Constructor Detail

DBAccessorImpl

@Inject
public DBAccessorImpl(Configuration configuration)

Method Detail

loadHelper

protected DbmsHelper loadHelper(org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform)

getConnection

protected Connection getConnection()

createTable

public void createTable(String tableName,
                        List<DBAccessor.DBColumnInfo> columnInfo,
                        String... primaryKeyColumns)
                 throws SQLException

Description copied from interface: DBAccessor

Create new table

Specified by:

createTable in interface DBAccessor

Throws:

SQLException

getDatabaseMetaData

protected DatabaseMetaData getDatabaseMetaData()
                                        throws SQLException

Throws:

SQLException

tableExists

public boolean tableExists(String tableName)
                    throws SQLException

Description copied from interface: DBAccessor

Verify if table exists by looking at metadata.

Specified by:

tableExists in interface DBAccessor

Returns:

Throws:

SQLException

getDbType

protected String getDbType()

tableHasData

public boolean tableHasData(String tableName)
                     throws SQLException

Description copied from interface: DBAccessor

Verify if table has any data

Specified by:

tableHasData in interface DBAccessor

Returns:

Throws:

SQLException

tableHasColumn

public boolean tableHasColumn(String tableName,
                              String columnName)
                       throws SQLException

Description copied from interface: DBAccessor

Verify if table already has a column defined.

Specified by:

tableHasColumn in interface DBAccessor

Returns:

Throws:

SQLException

tableHasForeignKey

public boolean tableHasForeignKey(String tableName,
                                  String fkName)
                           throws SQLException

Description copied from interface: DBAccessor

Verify if table has a FK constraint.

Specified by:

tableHasForeignKey in interface DBAccessor

Returns:

true if FK with such name exists

Throws:

SQLException

tableHasForeignKey

public boolean tableHasForeignKey(String tableName,
                                  String refTableName,
                                  String columnName,
                                  String refColumnName)
                           throws SQLException

Description copied from interface: DBAccessor

Verify if table already has a FK constraint.

Specified by:

tableHasForeignKey in interface DBAccessor

Returns:

true if described relation exists

Throws:

SQLException

tableHasForeignKey

public boolean tableHasForeignKey(String tableName,
                                  String referenceTableName,
                                  String[] keyColumns,
                                  String[] referenceColumns)
                           throws SQLException

Description copied from interface: DBAccessor

Verify if table already has a FK constraint.

Specified by:

tableHasForeignKey in interface DBAccessor

Returns:

true if described relation exists

Throws:

SQLException

createIndex

public void createIndex(String indexName,
                        String tableName,
                        String... columnNames)
                 throws SQLException

Description copied from interface: DBAccessor

Create new index

Specified by:

createIndex in interface DBAccessor

Throws:

SQLException

addFKConstraint

public void addFKConstraint(String tableName,
                            String constraintName,
                            String keyColumn,
                            String referenceTableName,
                            String referenceColumn,
                            boolean ignoreFailure)
                     throws SQLException

Description copied from interface: DBAccessor

Add foreign key for a relation

Specified by:

addFKConstraint in interface DBAccessor

Throws:

SQLException

addFKConstraint

public void addFKConstraint(String tableName,
                            String constraintName,
                            String[] keyColumns,
                            String referenceTableName,
                            String[] referenceColumns,
                            boolean ignoreFailure)
                     throws SQLException

Description copied from interface: DBAccessor

Add foreign key for a relation

Specified by:

addFKConstraint in interface DBAccessor

Throws:

SQLException

renameColumn

public void renameColumn(String tableName,
                         String oldColumnName,
                         DBAccessor.DBColumnInfo columnInfo)
                  throws SQLException

Description copied from interface: DBAccessor

Rename existing column

Specified by:

renameColumn in interface DBAccessor

Throws:

SQLException

addColumn

public void addColumn(String tableName,
                      DBAccessor.DBColumnInfo columnInfo)
               throws SQLException

Description copied from interface: DBAccessor

Add column to existing table

Specified by:

addColumn in interface DBAccessor

Throws:

SQLException

alterColumn

public void alterColumn(String tableName,
                        DBAccessor.DBColumnInfo columnInfo)
                 throws SQLException

Description copied from interface: DBAccessor

Alter column from existing table, only supports varchar extension
Use following sequence for more complex stuff:

DBAccessor.addColumn(String, org.apache.ambari.server.orm.DBAccessor.DBColumnInfo) DBAccessor.updateTable(String, String, Object, String) DBAccessor.dropColumn(String, String) DBAccessor.renameColumn(String, String, org.apache.ambari.server.orm.DBAccessor.DBColumnInfo)

Specified by:

alterColumn in interface DBAccessor

Throws:

SQLException

insertRow

public boolean insertRow(String tableName,
                         String[] columnNames,
                         String[] values,
                         boolean ignoreFailure)
                  throws SQLException

Description copied from interface: DBAccessor

Insert row into table

Specified by:

insertRow in interface DBAccessor

Returns:

Throws:

SQLException

updateTable

public int updateTable(String tableName,
                       String columnName,
                       Object value,
                       String whereClause)
                throws SQLException

Description copied from interface: DBAccessor

Simple update operation on table

Specified by:

updateTable in interface DBAccessor

Returns:

Throws:

SQLException

executeQuery

public void executeQuery(String query)
                  throws SQLException

Description copied from interface: DBAccessor

Execute ad-hoc query on DB.

Specified by:

executeQuery in interface DBAccessor

Throws:

SQLException

executeSelect

public ResultSet executeSelect(String query)
                        throws SQLException

Description copied from interface: DBAccessor

Execute select query

Specified by:

executeSelect in interface DBAccessor

Returns:

Throws:

SQLException

executeQuery

public void executeQuery(String query,
                         boolean ignoreFailure)
                  throws SQLException

Description copied from interface: DBAccessor

Execute query on DB

Specified by:

executeQuery in interface DBAccessor

Throws:

SQLException

dropTable

public void dropTable(String tableName)
               throws SQLException

Description copied from interface: DBAccessor

Drop table from schema

Specified by:

dropTable in interface DBAccessor

Throws:

SQLException

truncateTable

public void truncateTable(String tableName)
                   throws SQLException

Description copied from interface: DBAccessor

Delete all table data

Specified by:

truncateTable in interface DBAccessor

Throws:

SQLException

dropColumn

public void dropColumn(String tableName,
                       String columnName)
                throws SQLException

Description copied from interface: DBAccessor

Drop a column from table

Specified by:

dropColumn in interface DBAccessor

Throws:

SQLException

dropSequence

public void dropSequence(String sequenceName)
                  throws SQLException

Description copied from interface: DBAccessor

Drop sequence

Specified by:

dropSequence in interface DBAccessor

Throws:

SQLException

dropConstraint

public void dropConstraint(String tableName,
                           String constraintName)
                    throws SQLException

Description copied from interface: DBAccessor

Drop a constraint from table

Specified by:

dropConstraint in interface DBAccessor

Throws:

SQLException

dropConstraint

public void dropConstraint(String tableName,
                           String constraintName,
                           boolean ignoreFailure)
                    throws SQLException

Description copied from interface: DBAccessor

Drop a constraint from table

Specified by:

dropConstraint in interface DBAccessor

Throws:

SQLException

executeScript

public void executeScript(String filePath)
                   throws SQLException,
                          IOException

Description copied from interface: DBAccessor

Helper method to run third party scripts like Quartz DDL

Specified by:

executeScript in interface DBAccessor

Throws:

SQLException

IOException

getNewDatabaseSession

public org.eclipse.persistence.sessions.DatabaseSession getNewDatabaseSession()

Description copied from interface: DBAccessor

Get a new DB session

Specified by:

getNewDatabaseSession in interface DBAccessor

Returns: