com.northconcepts.datapipeline.foundations.pipeline.input

Class JdbcPipelineInput

java.lang.Object

com.northconcepts.datapipeline.foundations.core.Bean

com.northconcepts.datapipeline.foundations.core.FoundationObject

com.northconcepts.datapipeline.foundations.pipeline.PipelineObject

com.northconcepts.datapipeline.foundations.pipeline.PipelineInput

com.northconcepts.datapipeline.foundations.pipeline.input.JdbcPipelineInput

All Implemented Interfaces:

DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, DataReaderFactory, JavaCodeGenerator, Serializable

public class JdbcPipelineInput
extends PipelineInput

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

Method Summary

Modifier and Type	Method and Description
DataReader	createDataReader()
JdbcPipelineInput	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
JdbcPipelineInput	fromXmlElement(Element pipelineInputElement)
void	generateJavaCode(JavaCodeBuilder code)
JdbcConnectionFactory	getJdbcConnectionFactory()
String	getName()
Object[]	getParameters()
int[]	getParameterSqlTypes()
String	getQuery() Deprecated. Use getQueryString() instead.
String	getQueryString()
boolean	isAutoCloseConnection()
boolean	isLineageSupported()
boolean	isUseColumnLabel()
JdbcPipelineInput	setAutoCloseConnection(boolean autoCloseConnection)
JdbcPipelineInput	setJdbcConnectionFactory(Connection connection)
JdbcPipelineInput	setJdbcConnectionFactory(DataSource dataSource)
JdbcPipelineInput	setJdbcConnectionFactory(JdbcConnectionFactory jdbcConnectionFactory)
JdbcPipelineInput	setParameters(Object[] parameters)
JdbcPipelineInput	setParameterSqlTypes(int[] parameterSqlTypes)
JdbcPipelineInput	setQuery(String query) Deprecated. Use setQueryString(String) instead.
JdbcPipelineInput	setQueryString(String queryString)
JdbcPipelineInput	setUseColumnLabel(boolean useColumnLabel)
Record	toRecord()
Element	toXmlElement(Document document)

Methods inherited from class com.northconcepts.datapipeline.foundations.pipeline.PipelineInput

getNestedPipelineInput, getRootPipelineInput, isSaveLineage, setSaveLineage

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.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, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getChildElement, getChildElements, newInstanceFromXml, newInstanceFromXml, setAttribute, toXml, toXml, toXml, toXml, toXml, writeXml, writeXml

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

addExceptionProperties, contributeExceptionProperties, contributeExceptionProperties

Constructor Detail

JdbcPipelineInput

public JdbcPipelineInput()

Method Detail

getName

public String getName()

Specified by:

getName in class PipelineInput

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class PipelineInput

fromRecord

public JdbcPipelineInput 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 PipelineInput

Returns:

this instance.

getJdbcConnectionFactory

public JdbcConnectionFactory getJdbcConnectionFactory()

setJdbcConnectionFactory

public JdbcPipelineInput setJdbcConnectionFactory(JdbcConnectionFactory jdbcConnectionFactory)

setJdbcConnectionFactory

public JdbcPipelineInput setJdbcConnectionFactory(Connection connection)

setJdbcConnectionFactory

public JdbcPipelineInput setJdbcConnectionFactory(DataSource dataSource)

getQuery

@Deprecated
public String getQuery()

Deprecated. Use getQueryString() instead.

getQueryString

public String getQueryString()

setQuery

@Deprecated
public JdbcPipelineInput setQuery(String query)

Deprecated. Use setQueryString(String) instead.

setQueryString

public JdbcPipelineInput setQueryString(String queryString)

isAutoCloseConnection

public boolean isAutoCloseConnection()

setAutoCloseConnection

public JdbcPipelineInput setAutoCloseConnection(boolean autoCloseConnection)

isUseColumnLabel

public boolean isUseColumnLabel()

setUseColumnLabel

public JdbcPipelineInput setUseColumnLabel(boolean useColumnLabel)

getParameters

public Object[] getParameters()

setParameters

public JdbcPipelineInput setParameters(Object[] parameters)

getParameterSqlTypes

public int[] getParameterSqlTypes()

setParameterSqlTypes

public JdbcPipelineInput setParameterSqlTypes(int[] parameterSqlTypes)

isLineageSupported

public boolean isLineageSupported()

Overrides:

isLineageSupported in class PipelineInput

createDataReader

public DataReader createDataReader()

generateJavaCode

public void generateJavaCode(JavaCodeBuilder code)

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable

Overrides:

toXmlElement in class PipelineInput

fromXmlElement

public JdbcPipelineInput fromXmlElement(Element pipelineInputElement)

Specified by:

fromXmlElement in interface XmlSerializable

Overrides:

fromXmlElement in class PipelineInput