com.northconcepts.datapipeline.foundations.jdbc

Class JdbcTable

java.lang.Object

com.northconcepts.datapipeline.foundations.core.Bean

com.northconcepts.datapipeline.foundations.jdbc.JdbcTable

All Implemented Interfaces:

DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, JdbcSink, JdbcSource, Serializable

public class JdbcTable
extends Bean
implements JdbcSource, JdbcSink

See Also:

Serialized Form

Field Summary

Fields inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

SERIALIZED_CLASS_NAME, TYPE

Fields inherited from interface com.northconcepts.datapipeline.core.XmlSerializable

XML_SERIALIZED_CLASS_NAME

Constructor Summary

Constructors

Constructor and Description
JdbcTable()

Method Summary

Modifier and Type	Method and Description
JdbcTable	addColumn(JdbcTableColumn column)
JdbcTable	addExportedKey(JdbcExportedKey key)
JdbcTable	addImportedKey(JdbcImportedKey key)
JdbcTable	addIndex(JdbcIndex index)
JdbcTable	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
String	getCatalogName()
JdbcTableColumn	getColumn(String name)
List<JdbcTableColumn>	getColumns()
List<JdbcTableColumn>	getColumns(Collection<String> names)
List<JdbcTableColumn>	getColumns(String... names)
JdbcConnection	getConnection()
JdbcExportedKey	getExportedKey(String primaryKeyName)
List<JdbcTableColumn>	getExportedKeyColumns(String foreignKeyName)
List<JdbcExportedKey>	getExportedKeys()
JdbcImportedKey	getImportedKey(String foriegnKeyName)
List<JdbcTableColumn>	getImportedKeyColumns(String foreignKeyName)
List<JdbcImportedKey>	getImportedKeys()
JdbcIndex	getIndex(String indexName)
List<JdbcIndex>	getIndexes()
String	getName()
String	getNameAsJavaClassName()
String	getNameAsJavaIdentifier()
List<JdbcTableColumn>	getNonPrimaryKeyColumns()
List<JdbcTableColumn>	getPrimaryKeyColumns()
String	getPrimaryKeyName()
String	getQualifiedName()
String	getQuery()
String	getRemarks()
String	getSchemaName()
JdbcSourceType	getSourceType()
String	getType()
boolean	isDependentOn(JdbcTable table) Returns true if this table is either directly or indirectly dependent on the supplied table.
boolean	isDirectlyDependentOn(JdbcTable table) Returns true if this table is directly dependent on the supplied table (i.e they have a direct public-foreign key relationship).
JdbcTable	setCatalogName(String catalogName)
protected JdbcTable	setConnection(JdbcConnection connection)
JdbcTable	setName(String name)
JdbcTable	setPrimaryKeyName(String primaryKeyName)
JdbcTable	setRemarks(String remarks)
JdbcTable	setSchemaName(String schemaName)
JdbcTable	setType(String type)
JdbcTable	sortColumns()
Record	toRecord()

Methods inherited from class com.northconcepts.datapipeline.foundations.core.Bean

addExceptionProperties, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

fromArrayValue, fromArrayValue, fromArrayValue, fromJson, fromJson, newInstanceFromRecord, newInstanceFromRecord, toArrayValue, toJson, toJson, toJson, toRecord

Methods inherited from interface com.northconcepts.datapipeline.core.JsonSerializable

newInstanceFromJson

Methods inherited from interface com.northconcepts.datapipeline.core.XmlSerializable

forEachGrandChildElement, fromXml, fromXml, fromXmlElement, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getChildElement, getChildElements, newInstanceFromXml, newInstanceFromXml, setAttribute, toXml, toXml, toXml, toXml, toXml, toXmlElement, writeXml, writeXml

Methods inherited from interface com.northconcepts.datapipeline.core.DataExceptionContributor

addExceptionProperties, contributeExceptionProperties, contributeExceptionProperties, exception, exception, exception

Constructor Detail

JdbcTable

public JdbcTable()

Method Detail

getConnection

public JdbcConnection getConnection()

setConnection

protected JdbcTable setConnection(JdbcConnection connection)

getQualifiedName

public String getQualifiedName()

getName

public String getName()

Specified by:

getName in interface JdbcSink

Specified by:

getName in interface JdbcSource

setName

public JdbcTable setName(String name)

getNameAsJavaClassName

public String getNameAsJavaClassName()

getNameAsJavaIdentifier

public String getNameAsJavaIdentifier()

getCatalogName

public String getCatalogName()

setCatalogName

public JdbcTable setCatalogName(String catalogName)

getSchemaName

public String getSchemaName()

setSchemaName

public JdbcTable setSchemaName(String schemaName)

getType

public String getType()

setType

public JdbcTable setType(String type)

getRemarks

public String getRemarks()

setRemarks

public JdbcTable setRemarks(String remarks)

getColumn

public JdbcTableColumn getColumn(String name)

getColumns

public List<JdbcTableColumn> getColumns()

addColumn

public JdbcTable addColumn(JdbcTableColumn column)

sortColumns

public JdbcTable sortColumns()

getPrimaryKeyName

public String getPrimaryKeyName()

setPrimaryKeyName

public JdbcTable setPrimaryKeyName(String primaryKeyName)

getImportedKey

public JdbcImportedKey getImportedKey(String foriegnKeyName)

getImportedKeys

public List<JdbcImportedKey> getImportedKeys()

addImportedKey

public JdbcTable addImportedKey(JdbcImportedKey key)

getExportedKey

public JdbcExportedKey getExportedKey(String primaryKeyName)

getExportedKeys

public List<JdbcExportedKey> getExportedKeys()

addExportedKey

public JdbcTable addExportedKey(JdbcExportedKey key)

getIndexes

public List<JdbcIndex> getIndexes()

getIndex

public JdbcIndex getIndex(String indexName)

addIndex

public JdbcTable addIndex(JdbcIndex index)

getPrimaryKeyColumns

public List<JdbcTableColumn> getPrimaryKeyColumns()

getNonPrimaryKeyColumns

public List<JdbcTableColumn> getNonPrimaryKeyColumns()

getImportedKeyColumns

public List<JdbcTableColumn> getImportedKeyColumns(String foreignKeyName)

getExportedKeyColumns

public List<JdbcTableColumn> getExportedKeyColumns(String foreignKeyName)

getColumns

public List<JdbcTableColumn> getColumns(String... names)

getColumns

public List<JdbcTableColumn> getColumns(Collection<String> names)

getQuery

public String getQuery()

Specified by:

getQuery in interface JdbcSink

Specified by:

getQuery in interface JdbcSource

getSourceType

public JdbcSourceType getSourceType()

Specified by:

getSourceType in interface JdbcSource

isDirectlyDependentOn

public boolean isDirectlyDependentOn(JdbcTable table)

Returns true if this table is directly dependent on the supplied table (i.e they have a direct public-foreign key relationship).

See #isDependentOn(JdbcTable))

Parameters:

table -

Returns:

isDependentOn

public boolean isDependentOn(JdbcTable table)

Returns true if this table is either directly or indirectly dependent on the supplied table.

See isDirectlyDependentOn(JdbcTable)

Parameters:

table -

Returns:

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class Bean

fromRecord

public JdbcTable fromRecord(Record source)

Description copied from interface: RecordSerializable

Loads this instance's state from a record and returns this (for fluid API call chaining). For fluid API call chaining, the overridden method should change the declared return type to its class.

Specified by:

fromRecord in interface RecordSerializable

Overrides:

fromRecord in class Bean

Returns:

this instance.