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:

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	addQuery(JdbcQuery query)
JdbcConnection	addQuery(String name, String query)
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).
JdbcConnectionFactory	getConnectionFactory()
String	getDriverClassName()
String	getEncodedPassword()
Class<?>	getJavaTypeOverride(String databaseTypeName)
Map<String,Class<?>>	getJavaTypeOverrides()
String	getName()
Encoder<String,String>	getPasswordEncoder()
String	getPlainTextPassword()
List<Property>	getProperties()
List<JdbcQuery>	getQueries()
static List<JdbcQueryColumn>	getQueryColumns(ResultSetMetaData resultSetMetaData, JdbcConnection jdbcConnection)
static String	getSqlOrderBy(String column)
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	loadQueries()
JdbcConnection	loadTables()
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	setName(String name)
JdbcConnection	setPasswordEncoder(Encoder<String,String> passwordEncoder)
JdbcConnection	setPlainTextPassword(String password)
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

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

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

Constructor Detail

JdbcConnection

public JdbcConnection()

Method Detail

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)

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)

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)

loadQueries

public JdbcConnection loadQueries()

getQueryColumns

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

getSqlOrderBy

public static String getSqlOrderBy(String column)

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.