Package org.jumpmind.db.platform

Class AbstractJdbcDdlReader

java.lang.Object

org.jumpmind.db.platform.AbstractJdbcDdlReader

All Implemented Interfaces:

IDdlReader

Direct Known Subclasses:

AseDdlReader, Db2DdlReader, DerbyDdlReader, FirebirdDdlReader, GenericJdbcSqlDdlReader, H2DdlReader, HanaDdlReader, HsqlDb2DdlReader, HsqlDbDdlReader, InformixDdlReader, IngresDdlReader, InterbaseDdlReader, MsSqlDdlReader, MySqlDdlReader, NuoDbDdlReader, OracleDdlReader, PostgreSqlDdlReader, RaimaDdlReader, RedshiftDdlReader, SqlAnywhereDdlReader, VoltDbDdlReader

public abstract class AbstractJdbcDdlReader
extends Object
implements IDdlReader

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log
protected IDatabasePlatform	platform

Constructor Summary

Constructors

Constructor	Description
AbstractJdbcDdlReader(IDatabasePlatform platform)

Method Summary

Modifier and Type	Method	Description
protected void	adjustColumnSize(Column column, int amount)
protected void	adjustColumnSize(Column column, int amount, int maxSize)
protected StringBuilder	appendColumn(StringBuilder query, String identifier)
protected StringBuilder	appendIdentifier(StringBuilder query, String identifier)
protected void	close(ResultSet rs)
protected void	close(Statement stmt)
protected void	determineAutoIncrementFromResultSetMetaData(Connection conn, Table table, Column[] columnsToCheck)
protected void	determineAutoIncrementFromResultSetMetaData(Connection conn, Table table, Column[] columnsToCheck, String catalogSeparator)
protected void	genericizeDefaultValuesAndUpdatePlatformColumn(Column column)
List<Trigger>	getApplicationTriggersForModel(String catalog, String schema, String tableName, String triggerPrefix)
List<String>	getCatalogNames()
List<String>	getColumnNames(String catalog, String schema, String tableName)
protected List<MetaDataColumnDescriptor>	getColumnsForColumn()
protected List<MetaDataColumnDescriptor>	getColumnsForFK()
protected List<MetaDataColumnDescriptor>	getColumnsForIndex()
protected List<MetaDataColumnDescriptor>	getColumnsForPK()
protected List<MetaDataColumnDescriptor>	getColumnsForTable()
protected IConnectionHandler	getConnectionHandler(String catalog)
Database	getDatabase(Connection connection)
String	getDefaultCatalogPattern()
String	getDefaultColumnPattern()
String	getDefaultSchemaPattern()
String	getDefaultTablePattern()
String[]	getDefaultTableTypes()
List<TableRow>	getExportedForeignTableRows(ISqlTransaction transaction, List<TableRow> tableRows, Set<TableRow> visited, BinaryEncoding encoding)
Collection<ForeignKey>	getExportedKeys(Table table)
Collection<ForeignKey>	getForeignKeys(String catalog, String schema, String tableName)
List<TableRow>	getImportedForeignTableRows(List<TableRow> tableRows, Set<TableRow> visited, BinaryEncoding encoding)
protected List<TableRow>	getImportedForeignTableRows(List<TableRow> tableRows, Set<TableRow> visited, BinaryEncoding encoding, int depth, int maxDepth)
List<String>	getListOfTriggers()
protected String	getName(String defaultName)
IDatabasePlatform	getPlatform()
DatabaseInfo	getPlatformInfo()
PlatformTrigger	getPlatformTrigger(IDatabasePlatform platform, Trigger trigger)
protected String	getResultSetCatalogName()
protected String	getResultSetSchemaName()
List<String>	getSchemaNames(String catalog)
protected ResultSet	getSchemasHandleException(Connection connection, DatabaseMetaData meta, String catalog, String schemaPattern)
protected String	getTableNamePattern(String tableName)
protected String	getTableNamePatternForConstraints(String tableName)
List<String>	getTableNames(String catalog, String schema, String[] tableTypes)
List<String>	getTableTypes()
Trigger	getTriggerFor(Table table, String triggerName)
List<Trigger>	getTriggers(String catalog, String schema, String tableName)
protected String[]	getUnsupportedTableTypes()
protected String	getWithNoLockHint()
protected List<MetaDataColumnDescriptor>	initColumnsForColumn()
protected List<MetaDataColumnDescriptor>	initColumnsForFK()
protected List<MetaDataColumnDescriptor>	initColumnsForIndex()
protected List<MetaDataColumnDescriptor>	initColumnsForPK()
protected List<MetaDataColumnDescriptor>	initColumnsForTable()
protected boolean	isInternalForeignKeyIndex(Connection connection, DatabaseMetaDataWrapper metaData, Table table, ForeignKey fk, IIndex index)
protected boolean	isInternalPrimaryKeyIndex(Connection connection, DatabaseMetaDataWrapper metaData, Table table, IIndex index)
protected Integer	mapUnknownJdbcTypeForColumn(Map<String,Object> values)
protected boolean	matches(IIndex index, List<String> columnsToSearchFor)
protected Database	postprocessModelFromDatabase(Database model)
protected Table	postprocessTableFromDatabase(Table table)
protected ArrayList<String>	processSchemaResultSet(ResultSet rs, String catalog)
protected Column	readColumn(DatabaseMetaDataWrapper metaData, Map<String,Object> values)
protected Collection<Column>	readColumns(DatabaseMetaDataWrapper metaData, String tableName)
protected void	readExportedKey(DatabaseMetaDataWrapper metaData, Map<String,Object> values, Map<String,ForeignKey> knownFks)
protected Collection<ForeignKey>	readExportedKeys(Connection connection, DatabaseMetaDataWrapper metaData, String tableName)
protected void	readForeignKey(DatabaseMetaDataWrapper metaData, Map<String,Object> values, Map<String,ForeignKey> knownFks)
protected void	readForeignKeyDeleteRule(Map<String,Object> values, ForeignKey fk)
protected Collection<ForeignKey>	readForeignKeys(Connection connection, DatabaseMetaDataWrapper metaData, String tableName)
protected void	readForeignKeyUpdateRule(Map<String,Object> values, ForeignKey fk)
protected void	readIndex(DatabaseMetaDataWrapper metaData, Map<String,Object> values, Map<String,IIndex> knownIndices)
protected Collection<IIndex>	readIndices(Connection connection, DatabaseMetaDataWrapper metaData, String tableName)
protected Map<String,Object>	readMetaData(ResultSet resultSet, List<MetaDataColumnDescriptor> columnDescriptors)
protected String	readPrimaryKeyName(DatabaseMetaDataWrapper metaData, Map<String,Object> values)
protected Collection<String>	readPrimaryKeyNames(DatabaseMetaDataWrapper metaData, String tableName)
protected Integer	readPrimaryKeySequence(Map<String,Object> values)
Table	readTable(String catalog, String schema, String table)
protected Table	readTable(Connection connection, DatabaseMetaDataWrapper metaData, Map<String,Object> values)
Table	readTable(ISqlTransaction transaction, String catalog, String schema, String table)
protected Table	readTableFromConnection(Connection connection, String catalog, String schema, String table)
Database	readTables(String catalog, String schema, String[] tableTypes)
protected Collection<Table>	readTables(Connection connection, String catalog, String schemaPattern, String[] tableTypes)
protected void	removeColumnSize(Column column)
protected void	removeGeneratedColumns(Connection connection, DatabaseMetaDataWrapper metaData, Table table)
protected void	removeInternalForeignKeyIndex(Connection connection, DatabaseMetaDataWrapper metaData, Table table, ForeignKey fk)
protected void	removeInternalPrimaryKeyIndex(Connection connection, DatabaseMetaDataWrapper metaData, Table table)
protected void	removePlatformColumnSize(Column column)
protected void	removeSystemIndices(Connection connection, DatabaseMetaDataWrapper metaData, Table table)
protected void	resetColumnSize(Column column, String size)
void	setDefaultCatalogPattern(String catalogPattern)
void	setDefaultColumnPattern(String columnPattern)
void	setDefaultSchemaPattern(String schemaPattern)
void	setDefaultTablePattern(String tablePattern)
void	setDefaultTableTypes(String[] types)
protected String	unescape(String text, String unescaped, String escaped)

Methods inherited from class java.lang.Object

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

Field Details

log

protected org.slf4j.Logger log

platform

protected IDatabasePlatform platform

Constructor Details

AbstractJdbcDdlReader

public AbstractJdbcDdlReader(IDatabasePlatform platform)

Method Details

getTriggers

public List<Trigger> getTriggers(String catalog,
 String schema,
 String tableName)

Specified by:

getTriggers in interface IDdlReader

getApplicationTriggersForModel

public List<Trigger> getApplicationTriggersForModel(String catalog,
 String schema,
 String tableName,
 String triggerPrefix)

Specified by:

getApplicationTriggersForModel in interface IDdlReader

getPlatformTrigger

public PlatformTrigger getPlatformTrigger(IDatabasePlatform platform,
 Trigger trigger)

Specified by:

getPlatformTrigger in interface IDdlReader

getPlatform

public IDatabasePlatform getPlatform()

getPlatformInfo

public DatabaseInfo getPlatformInfo()

initColumnsForTable

protected List<MetaDataColumnDescriptor> initColumnsForTable()

initColumnsForColumn

protected List<MetaDataColumnDescriptor> initColumnsForColumn()

initColumnsForPK

protected List<MetaDataColumnDescriptor> initColumnsForPK()

initColumnsForFK

protected List<MetaDataColumnDescriptor> initColumnsForFK()

initColumnsForIndex

protected List<MetaDataColumnDescriptor> initColumnsForIndex()

getName

protected String getName(String defaultName)

getDefaultCatalogPattern

public String getDefaultCatalogPattern()

setDefaultCatalogPattern

public void setDefaultCatalogPattern(String catalogPattern)

getDefaultSchemaPattern

public String getDefaultSchemaPattern()

setDefaultSchemaPattern

public void setDefaultSchemaPattern(String schemaPattern)

getDefaultTablePattern

public String getDefaultTablePattern()

setDefaultTablePattern

public void setDefaultTablePattern(String tablePattern)

getDefaultColumnPattern

public String getDefaultColumnPattern()

setDefaultColumnPattern

public void setDefaultColumnPattern(String columnPattern)

getDefaultTableTypes

public String[] getDefaultTableTypes()

setDefaultTableTypes

public void setDefaultTableTypes(String[] types)

getColumnsForTable

protected List<MetaDataColumnDescriptor> getColumnsForTable()

getColumnsForColumn

protected List<MetaDataColumnDescriptor> getColumnsForColumn()

getColumnsForPK

protected List<MetaDataColumnDescriptor> getColumnsForPK()

getColumnsForFK

protected List<MetaDataColumnDescriptor> getColumnsForFK()

getColumnsForIndex

protected List<MetaDataColumnDescriptor> getColumnsForIndex()

getDatabase

public Database getDatabase(Connection connection)
                     throws SQLException

Throws:

SQLException

getResultSetSchemaName

protected String getResultSetSchemaName()

getResultSetCatalogName

protected String getResultSetCatalogName()

readTables

public Database readTables(String catalog,
 String schema,
 String[] tableTypes)

Specified by:

readTables in interface IDdlReader

postprocessModelFromDatabase

protected Database postprocessModelFromDatabase(Database model)

readTables

protected Collection<Table> readTables(Connection connection,
 String catalog,
 String schemaPattern,
 String[] tableTypes)
                                throws SQLException

Throws:

SQLException

readTable

public Table readTable(String catalog,
 String schema,
 String table)

Specified by:

readTable in interface IDdlReader

readTable

public Table readTable(ISqlTransaction transaction,
 String catalog,
 String schema,
 String table)

Specified by:

readTable in interface IDdlReader

readTableFromConnection

protected Table readTableFromConnection(Connection connection,
 String catalog,
 String schema,
 String table)
                                 throws SQLException

Throws:

SQLException

postprocessTableFromDatabase

protected Table postprocessTableFromDatabase(Table table)

close

protected void close(ResultSet rs)

close

protected void close(Statement stmt)

getTableNamePattern

protected String getTableNamePattern(String tableName)

getTableNamePatternForConstraints

protected String getTableNamePatternForConstraints(String tableName)

readTable

protected Table readTable(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Map<String,Object> values)
                   throws SQLException

Throws:

SQLException

getUnsupportedTableTypes

protected String[] getUnsupportedTableTypes()

removeSystemIndices

protected void removeSystemIndices(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Table table)
                            throws SQLException

Throws:

SQLException

removeGeneratedColumns

protected void removeGeneratedColumns(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Table table)
                               throws SQLException

Throws:

SQLException

removeInternalPrimaryKeyIndex

protected void removeInternalPrimaryKeyIndex(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Table table)
                                      throws SQLException

Throws:

SQLException

removeInternalForeignKeyIndex

protected void removeInternalForeignKeyIndex(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Table table,
 ForeignKey fk)
                                      throws SQLException

Throws:

SQLException

matches

protected boolean matches(IIndex index,
 List<String> columnsToSearchFor)

isInternalPrimaryKeyIndex

protected boolean isInternalPrimaryKeyIndex(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Table table,
 IIndex index)
                                     throws SQLException

Throws:

SQLException

isInternalForeignKeyIndex

protected boolean isInternalForeignKeyIndex(Connection connection,
 DatabaseMetaDataWrapper metaData,
 Table table,
 ForeignKey fk,
 IIndex index)
                                     throws SQLException

Throws:

SQLException

readColumns

protected Collection<Column> readColumns(DatabaseMetaDataWrapper metaData,
 String tableName)
                                  throws SQLException

Throws:

SQLException

genericizeDefaultValuesAndUpdatePlatformColumn

protected void genericizeDefaultValuesAndUpdatePlatformColumn(Column column)

mapUnknownJdbcTypeForColumn

protected Integer mapUnknownJdbcTypeForColumn(Map<String,Object> values)

readColumn

protected Column readColumn(DatabaseMetaDataWrapper metaData,
 Map<String,Object> values)
                     throws SQLException

Throws:

SQLException

readPrimaryKeyNames

protected Collection<String> readPrimaryKeyNames(DatabaseMetaDataWrapper metaData,
 String tableName)
                                          throws SQLException

Throws:

SQLException

readPrimaryKeyName

protected String readPrimaryKeyName(DatabaseMetaDataWrapper metaData,
 Map<String,Object> values)
                             throws SQLException

Throws:

SQLException

readPrimaryKeySequence

protected Integer readPrimaryKeySequence(Map<String,Object> values)
                                  throws SQLException

Throws:

SQLException

readForeignKeys

protected Collection<ForeignKey> readForeignKeys(Connection connection,
 DatabaseMetaDataWrapper metaData,
 String tableName)
                                          throws SQLException

Throws:

SQLException

readForeignKey

protected void readForeignKey(DatabaseMetaDataWrapper metaData,
 Map<String,Object> values,
 Map<String,ForeignKey> knownFks)
                       throws SQLException

Throws:

SQLException

readForeignKeyUpdateRule

protected void readForeignKeyUpdateRule(Map<String,Object> values,
 ForeignKey fk)

readForeignKeyDeleteRule

protected void readForeignKeyDeleteRule(Map<String,Object> values,
 ForeignKey fk)

readExportedKeys

protected Collection<ForeignKey> readExportedKeys(Connection connection,
 DatabaseMetaDataWrapper metaData,
 String tableName)
                                           throws SQLException

Throws:

SQLException

readExportedKey

protected void readExportedKey(DatabaseMetaDataWrapper metaData,
 Map<String,Object> values,
 Map<String,ForeignKey> knownFks)
                        throws SQLException

Throws:

SQLException

readIndices

protected Collection<IIndex> readIndices(Connection connection,
 DatabaseMetaDataWrapper metaData,
 String tableName)
                                  throws SQLException

Throws:

SQLException

readIndex

protected void readIndex(DatabaseMetaDataWrapper metaData,
 Map<String,Object> values,
 Map<String,IIndex> knownIndices)
                  throws SQLException

Throws:

SQLException

readMetaData

protected Map<String,Object> readMetaData(ResultSet resultSet,
 List<MetaDataColumnDescriptor> columnDescriptors)
                                   throws SQLException

Throws:

SQLException

determineAutoIncrementFromResultSetMetaData

protected void determineAutoIncrementFromResultSetMetaData(Connection conn,
 Table table,
 Column[] columnsToCheck)
                                                    throws SQLException

Throws:

SQLException

determineAutoIncrementFromResultSetMetaData

protected void determineAutoIncrementFromResultSetMetaData(Connection conn,
 Table table,
 Column[] columnsToCheck,
 String catalogSeparator)
                                                    throws SQLException

Throws:

SQLException

getWithNoLockHint

protected String getWithNoLockHint()

appendIdentifier

protected StringBuilder appendIdentifier(StringBuilder query,
 String identifier)

appendColumn

protected StringBuilder appendColumn(StringBuilder query,
 String identifier)

unescape

protected String unescape(String text,
 String unescaped,
 String escaped)

getTableTypes

public List<String> getTableTypes()

Specified by:

getTableTypes in interface IDdlReader

getCatalogNames

public List<String> getCatalogNames()

Specified by:

getCatalogNames in interface IDdlReader

getSchemaNames

public List<String> getSchemaNames(String catalog)

Specified by:

getSchemaNames in interface IDdlReader

processSchemaResultSet

protected ArrayList<String> processSchemaResultSet(ResultSet rs,
 String catalog)
                                            throws SQLException

Throws:

SQLException

getSchemasHandleException

protected ResultSet getSchemasHandleException(Connection connection,
 DatabaseMetaData meta,
 String catalog,
 String schemaPattern)
                                       throws SQLException

Throws:

SQLException

getConnectionHandler

protected IConnectionHandler getConnectionHandler(String catalog)

getTableNames

public List<String> getTableNames(String catalog,
 String schema,
 String[] tableTypes)

Specified by:

getTableNames in interface IDdlReader

getColumnNames

public List<String> getColumnNames(String catalog,
 String schema,
 String tableName)

Specified by:

getColumnNames in interface IDdlReader

getListOfTriggers

public List<String> getListOfTriggers()

getTriggerFor

public Trigger getTriggerFor(Table table,
 String triggerName)

Specified by:

getTriggerFor in interface IDdlReader

getExportedKeys

public Collection<ForeignKey> getExportedKeys(Table table)

Specified by:

getExportedKeys in interface IDdlReader

getForeignKeys

public Collection<ForeignKey> getForeignKeys(String catalog,
 String schema,
 String tableName)

Specified by:

getForeignKeys in interface IDdlReader

getExportedForeignTableRows

public List<TableRow> getExportedForeignTableRows(ISqlTransaction transaction,
 List<TableRow> tableRows,
 Set<TableRow> visited,
 BinaryEncoding encoding)

Specified by:

getExportedForeignTableRows in interface IDdlReader

getImportedForeignTableRows

public List<TableRow> getImportedForeignTableRows(List<TableRow> tableRows,
 Set<TableRow> visited,
 BinaryEncoding encoding)

Specified by:

getImportedForeignTableRows in interface IDdlReader

getImportedForeignTableRows

protected List<TableRow> getImportedForeignTableRows(List<TableRow> tableRows,
 Set<TableRow> visited,
 BinaryEncoding encoding,
 int depth,
 int maxDepth)

resetColumnSize

protected void resetColumnSize(Column column,
 String size)

adjustColumnSize

protected void adjustColumnSize(Column column,
 int amount)

adjustColumnSize

protected void adjustColumnSize(Column column,
 int amount,
 int maxSize)

removeColumnSize

protected void removeColumnSize(Column column)

removePlatformColumnSize

protected void removePlatformColumnSize(Column column)