org.apache.ambari.server.orm.helpers.dbms

Class GenericDbmsHelper

java.lang.Object

org.apache.ambari.server.orm.helpers.dbms.GenericDbmsHelper

All Implemented Interfaces:

DbmsHelper

Direct Known Subclasses:

DerbyHelper, MySqlHelper, OracleHelper, PostgresHelper

public class GenericDbmsHelper
extends Object
implements DbmsHelper

Field Summary

Fields

Modifier and Type	Field and Description
protected org.eclipse.persistence.platform.database.DatabasePlatform	databasePlatform

Constructor Summary

Constructors

Constructor and Description
GenericDbmsHelper(org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform)

Method Summary

Modifier and Type	Method and Description
org.eclipse.persistence.tools.schemaframework.FieldDefinition	convertToFieldDefinition(DBAccessor.DBColumnInfo columnInfo)
org.eclipse.persistence.internal.sessions.AbstractSession	createStubAbstractSessionFromPlatform(org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform)
String	getAddColumnStatement(String tableName, DBAccessor.DBColumnInfo columnInfo)
String	getAddForeignKeyStatement(String tableName, String constraintName, List<String> keyColumns, String referenceTableName, List<String> referenceColumns)
String	getAlterColumnStatement(String tableName, DBAccessor.DBColumnInfo columnInfo) Generate alter column statement
String	getCreateIndexStatement(String indexName, String tableName, String... columnNames) get create index statement
String	getCreateTableStatement(String tableName, List<DBAccessor.DBColumnInfo> columns, List<String> primaryKeyColumns) get create table statement
String	getDropConstraintStatement(String tableName, String constraintName)
String	getDropSequenceStatement(String sequenceName)
String	getDropTableStatement(String tableName)
String	getRenameColumnStatement(String tableName, String oldName, DBAccessor.DBColumnInfo columnInfo) Generate rename column statement
String	getRenameColumnStatement(String tableName, String oldColumnName, String newColumnName)
boolean	supportsColumnTypeChange() Check if column type can be modified directly
StringBuilder	writeAlterTableClause(StringBuilder builder, String tableName)
StringBuilder	writeColumnModifyString(StringBuilder builder, DBAccessor.DBColumnInfo columnInfo)
StringBuilder	writeColumnRenameString(StringBuilder builder, String oldName, DBAccessor.DBColumnInfo newColumnInfo)
StringBuilder	writeColumnType(StringBuilder builder, DBAccessor.DBColumnInfo columnInfo)
Writer	writeCreateTableStatement(Writer writer, String tableName, List<DBAccessor.DBColumnInfo> columns, List<String> primaryKeyColumns) Write create table statement to writer TODO default Value of column not supported

Methods inherited from class java.lang.Object

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

Field Detail

databasePlatform

protected final org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform

Constructor Detail

GenericDbmsHelper

public GenericDbmsHelper(org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform)

Method Detail

supportsColumnTypeChange

public boolean supportsColumnTypeChange()

Description copied from interface: DbmsHelper

Check if column type can be modified directly

Specified by:

supportsColumnTypeChange in interface DbmsHelper

Returns:

getRenameColumnStatement

public String getRenameColumnStatement(String tableName,
                                       String oldName,
                                       DBAccessor.DBColumnInfo columnInfo)

Description copied from interface: DbmsHelper

Generate rename column statement

Specified by:

getRenameColumnStatement in interface DbmsHelper

columnInfo - definition of new column

Returns:

getAlterColumnStatement

public String getAlterColumnStatement(String tableName,
                                      DBAccessor.DBColumnInfo columnInfo)

Description copied from interface: DbmsHelper

Generate alter column statement

Specified by:

getAlterColumnStatement in interface DbmsHelper

Returns:

writeAlterTableClause

public StringBuilder writeAlterTableClause(StringBuilder builder,
                                           String tableName)

writeColumnModifyString

public StringBuilder writeColumnModifyString(StringBuilder builder,
                                             DBAccessor.DBColumnInfo columnInfo)

writeColumnRenameString

public StringBuilder writeColumnRenameString(StringBuilder builder,
                                             String oldName,
                                             DBAccessor.DBColumnInfo newColumnInfo)

writeColumnType

public StringBuilder writeColumnType(StringBuilder builder,
                                     DBAccessor.DBColumnInfo columnInfo)

getCreateTableStatement

public String getCreateTableStatement(String tableName,
                                      List<DBAccessor.DBColumnInfo> columns,
                                      List<String> primaryKeyColumns)

get create table statement

Specified by:

getCreateTableStatement in interface DbmsHelper

Parameters:

tableName -

columns -

primaryKeyColumns -

Returns:

writeCreateTableStatement

public Writer writeCreateTableStatement(Writer writer,
                                        String tableName,
                                        List<DBAccessor.DBColumnInfo> columns,
                                        List<String> primaryKeyColumns)

Write create table statement to writer TODO default Value of column not supported

convertToFieldDefinition

public org.eclipse.persistence.tools.schemaframework.FieldDefinition convertToFieldDefinition(DBAccessor.DBColumnInfo columnInfo)

getCreateIndexStatement

public String getCreateIndexStatement(String indexName,
                                      String tableName,
                                      String... columnNames)

get create index statement

Specified by:

getCreateIndexStatement in interface DbmsHelper

Parameters:

indexName -

tableName -

columnNames -

Returns:

getAddForeignKeyStatement

public String getAddForeignKeyStatement(String tableName,
                                        String constraintName,
                                        List<String> keyColumns,
                                        String referenceTableName,
                                        List<String> referenceColumns)

Specified by:

getAddForeignKeyStatement in interface DbmsHelper

getAddColumnStatement

public String getAddColumnStatement(String tableName,
                                    DBAccessor.DBColumnInfo columnInfo)

Specified by:

getAddColumnStatement in interface DbmsHelper

getRenameColumnStatement

public String getRenameColumnStatement(String tableName,
                                       String oldColumnName,
                                       String newColumnName)

Specified by:

getRenameColumnStatement in interface DbmsHelper

getDropTableStatement

public String getDropTableStatement(String tableName)

Specified by:

getDropTableStatement in interface DbmsHelper

getDropConstraintStatement

public String getDropConstraintStatement(String tableName,
                                         String constraintName)

Specified by:

getDropConstraintStatement in interface DbmsHelper

getDropSequenceStatement

public String getDropSequenceStatement(String sequenceName)

Specified by:

getDropSequenceStatement in interface DbmsHelper

createStubAbstractSessionFromPlatform

public org.eclipse.persistence.internal.sessions.AbstractSession createStubAbstractSessionFromPlatform(org.eclipse.persistence.platform.database.DatabasePlatform databasePlatform)