com.northconcepts.datapipeline.foundations.jdbc

Class JdbcConnection

java.lang.Object

com.northconcepts.datapipeline.foundations.core.Bean

com.northconcepts.datapipeline.foundations.core.FoundationObject

com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

All Implemented Interfaces:

DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, JdbcConnectionFactory, Serializable

public class JdbcConnection
extends FoundationObject
implements JdbcConnectionFactory

See Also:

Serialized Form

Field Summary

Fields inherited from class com.northconcepts.datapipeline.foundations.core.FoundationObject

internalId, internalName, log, TIMESTAMP_FORMAT

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
JdbcConnection()

Method Summary

Modifier and Type	Method and Description
JdbcConnection	addProperty(Property property)
JdbcConnection	addProperty(String name, String value)
JdbcConnection	addQuery(JdbcQuery query)
JdbcConnection	addQuery(String name, String query)
JdbcConnection	addSchema(JdbcSchema jdbcSchema)
JdbcConnection	addTable(JdbcTable table)
Connection	createConnection()
JdbcConnection	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
List<String>	getCatalogNames()
JdbcConnectionFactory	getConnectionFactory()
String	getDriverClassName()
String	getEncodedPassword()
Boolean	getIsCatalogAtStart()
Class<?>	getJavaTypeOverride(String databaseTypeName)
Map<String,Class<?>>	getJavaTypeOverrides()
JdbcConnectionListener	getListener()
String	getName()
Encoder<String,String>	getPasswordEncoder()
String	getPlainTextPassword()
List<Property>	getProperties()
List<JdbcQuery>	getQueries()
static List<JdbcQueryColumn>	getQueryColumns(ResultSetMetaData resultSetMetaData, JdbcConnection jdbcConnection)
List<JdbcSchema>	getSchemas()
static String	getSqlOrderBy(String column)
JdbcValueReader	getSqlToJavaTypeMapper()
Boolean	getSupportsCatalogsInDataManipulation()
Boolean	getSupportsCatalogsInPrivilegeDefinitions()
Boolean	getSupportsCatalogsInTableDefinitions()
JdbcTable	getTable(String name)
JdbcTable	getTable(String schemaName, String name)
JdbcTable	getTable(String catalogName, String schemaName, String name)
List<JdbcTable>	getTables()
List<JdbcTable>	getTablesSorted() Returns a list of of tables sorted alphabetically.
List<JdbcTable>	getTablesSortedTopologically() Returns a list of of tables sorted alphabetically, but with dependencies first.
String	getUrl()
String	getUsername()
boolean	isUseCatalog()
JdbcConnection	loadCatalogAndSchemas()
JdbcConnection	loadQueries()
JdbcConnection	loadTables()
JdbcConnection	loadTables(LoadTablesRequest request)
JdbcConnection	loadTables(String catalog, String schemaPattern, String tableNamePattern, String... types)
JdbcConnection	setConnectionFactory(JdbcConnectionFactory connectionFactory)
JdbcConnection	setDriverClassName(String driverClassName)
JdbcConnection	setEncodedPassword(String password)
JdbcConnection	setJavaTypeOverride(String databaseTypeName, Class<?> javaType)
JdbcConnection	setListener(JdbcConnectionListener listener)
JdbcConnection	setName(String name)
JdbcConnection	setPasswordEncoder(Encoder<String,String> passwordEncoder)
JdbcConnection	setPlainTextPassword(String password)
JdbcConnection	setSqlToJavaTypeMapper(JdbcValueReader sqlToJavaTypeMapper)
JdbcConnection	setUrl(String url)
JdbcConnection	setUseCatalog(boolean useCatalog)
JdbcConnection	setUsername(String username)
Record	toRecord()

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

addExceptionProperties, assertValid, assertValid, clone, exception, exception, exception, getInternalId, getInternalName, resetInternalId

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

toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.northconcepts.datapipeline.jdbc.JdbcConnectionFactory

close, closeConnection, wrap, wrap, wrap, wrap, wrap

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

Constructor Detail

JdbcConnection

public JdbcConnection()

Method Detail

getListener

public JdbcConnectionListener getListener()

setListener

public JdbcConnection setListener(JdbcConnectionListener listener)

getName

public String getName()

setName

public JdbcConnection setName(String name)

getConnectionFactory

public JdbcConnectionFactory getConnectionFactory()

setConnectionFactory

public JdbcConnection setConnectionFactory(JdbcConnectionFactory connectionFactory)

getDriverClassName

public String getDriverClassName()

setDriverClassName

public JdbcConnection setDriverClassName(String driverClassName)

getUrl

public String getUrl()

setUrl

public JdbcConnection setUrl(String url)

getUsername

public String getUsername()

setUsername

public JdbcConnection setUsername(String username)

getEncodedPassword

public String getEncodedPassword()

setEncodedPassword

public JdbcConnection setEncodedPassword(String password)

getPlainTextPassword

public String getPlainTextPassword()

setPlainTextPassword

public JdbcConnection setPlainTextPassword(String password)

setPasswordEncoder

public JdbcConnection setPasswordEncoder(Encoder<String,String> passwordEncoder)

getPasswordEncoder

public Encoder<String,String> getPasswordEncoder()

isUseCatalog

public boolean isUseCatalog()

setUseCatalog

public JdbcConnection setUseCatalog(boolean useCatalog)

getProperties

public List<Property> getProperties()

addProperty

public JdbcConnection addProperty(Property property)

addProperty

public JdbcConnection addProperty(String name,
                                  String value)

getTable

public JdbcTable getTable(String name)

getTable

public JdbcTable getTable(String schemaName,
                          String name)

getTable

public JdbcTable getTable(String catalogName,
                          String schemaName,
                          String name)

getTables

public List<JdbcTable> getTables()

getTablesSorted

public List<JdbcTable> getTablesSorted()

Returns a list of of tables sorted alphabetically.

getTablesSortedTopologically

public List<JdbcTable> getTablesSortedTopologically()

Returns a list of of tables sorted alphabetically, but with dependencies first. If table A depends on table B, table B will be placed above table A in the returned list.

addTable

public JdbcConnection addTable(JdbcTable table)

getQueries

public List<JdbcQuery> getQueries()

addQuery

public JdbcConnection addQuery(JdbcQuery query)

addQuery

public JdbcConnection addQuery(String name,
                               String query)

getJavaTypeOverrides

public Map<String,Class<?>> getJavaTypeOverrides()

setJavaTypeOverride

public JdbcConnection setJavaTypeOverride(String databaseTypeName,
                                          Class<?> javaType)

getJavaTypeOverride

public Class<?> getJavaTypeOverride(String databaseTypeName)

getSqlToJavaTypeMapper

public JdbcValueReader getSqlToJavaTypeMapper()

setSqlToJavaTypeMapper

public JdbcConnection setSqlToJavaTypeMapper(JdbcValueReader sqlToJavaTypeMapper)

getIsCatalogAtStart

public Boolean getIsCatalogAtStart()

getSupportsCatalogsInDataManipulation

public Boolean getSupportsCatalogsInDataManipulation()

getSupportsCatalogsInTableDefinitions

public Boolean getSupportsCatalogsInTableDefinitions()

getSupportsCatalogsInPrivilegeDefinitions

public Boolean getSupportsCatalogsInPrivilegeDefinitions()

getCatalogNames

public List<String> getCatalogNames()

addSchema

public JdbcConnection addSchema(JdbcSchema jdbcSchema)

getSchemas

public List<JdbcSchema> getSchemas()

createConnection

public Connection createConnection()

Specified by:

createConnection in interface JdbcConnectionFactory

loadTables

public JdbcConnection loadTables()

loadTables

public JdbcConnection loadTables(String catalog,
                                 String schemaPattern,
                                 String tableNamePattern,
                                 String... types)

loadTables

public JdbcConnection loadTables(LoadTablesRequest request)

loadQueries

public JdbcConnection loadQueries()

getQueryColumns

public static List<JdbcQueryColumn> getQueryColumns(ResultSetMetaData resultSetMetaData,
                                                    JdbcConnection jdbcConnection)

getSqlOrderBy

public static String getSqlOrderBy(String column)

loadCatalogAndSchemas

public JdbcConnection loadCatalogAndSchemas()

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class Bean

fromRecord

public JdbcConnection 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.