com.northconcepts.datapipeline.foundations.pipeline.output

Class JdbcPipelineOutput

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.PipelineOutput

com.northconcepts.datapipeline.foundations.pipeline.output.JdbcPipelineOutput

All Implemented Interfaces:

DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, DataWriterFactory, JavaCodeGenerator, Serializable

public class JdbcPipelineOutput
extends PipelineOutput

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

Method Summary

Modifier and Type	Method and Description
DataWriter	createDataWriter()
JdbcPipelineOutput	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
JdbcPipelineOutput	fromXmlElement(Element pipelineOutputElement)
void	generateJavaCode(JavaCodeBuilder code)
int	getBatchSize()
JdbcConnectionFactory	getJdbcConnectionFactory()
Integer	getJdbcType(String fieldName)
String	getName()
String	getTable() Deprecated. Use getTableName() instead.
String	getTableName()
boolean	isAutoCloseConnection()
boolean	isCommitBatch()
JdbcPipelineOutput	setAutoCloseConnection(boolean autoCloseConnection)
JdbcPipelineOutput	setBatchSize(int batchSize)
JdbcPipelineOutput	setCommitBatch(boolean commitBatch)
JdbcPipelineOutput	setJdbcConnectionFactory(Connection connection)
JdbcPipelineOutput	setJdbcConnectionFactory(DataSource dataSource)
JdbcPipelineOutput	setJdbcConnectionFactory(JdbcConnectionFactory jdbcConnectionFactory)
JdbcPipelineOutput	setJdbcType(String fieldName, int jdbcType) The given Java object will be converted to the given targetSqlType before being sent to the database.
JdbcPipelineOutput	setTable(String table) Deprecated. Use setTableName(String) instead.
JdbcPipelineOutput	setTableName(String tableName)
Record	toRecord()
Element	toXmlElement(Document document)

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

getNestedPipelineOutput, getRootPipelineOutput

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

JdbcPipelineOutput

public JdbcPipelineOutput()

Method Detail

getName

public String getName()

Specified by:

getName in class PipelineOutput

setJdbcType

public JdbcPipelineOutput setJdbcType(String fieldName,
                                      int jdbcType)

The given Java object will be converted to the given targetSqlType before being sent to the database.

Note that this method may be used to pass database-specific abstract data types.

Parameters:

fieldName -

jdbcType - - the object containing the JDBC Type parameter value

getJdbcType

public Integer getJdbcType(String fieldName)

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class Bean

fromRecord

public JdbcPipelineOutput 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 PipelineOutput

Returns:

this instance.

getJdbcConnectionFactory

public JdbcConnectionFactory getJdbcConnectionFactory()

setJdbcConnectionFactory

public JdbcPipelineOutput setJdbcConnectionFactory(JdbcConnectionFactory jdbcConnectionFactory)

setJdbcConnectionFactory

public JdbcPipelineOutput setJdbcConnectionFactory(Connection connection)

setJdbcConnectionFactory

public JdbcPipelineOutput setJdbcConnectionFactory(DataSource dataSource)

getTable

@Deprecated
public String getTable()

Deprecated. Use getTableName() instead.

getTableName

public String getTableName()

setTable

@Deprecated
public JdbcPipelineOutput setTable(String table)

Deprecated. Use setTableName(String) instead.

setTableName

public JdbcPipelineOutput setTableName(String tableName)

isAutoCloseConnection

public boolean isAutoCloseConnection()

setAutoCloseConnection

public JdbcPipelineOutput setAutoCloseConnection(boolean autoCloseConnection)

getBatchSize

public int getBatchSize()

setBatchSize

public JdbcPipelineOutput setBatchSize(int batchSize)

isCommitBatch

public boolean isCommitBatch()

setCommitBatch

public JdbcPipelineOutput setCommitBatch(boolean commitBatch)

generateJavaCode

public void generateJavaCode(JavaCodeBuilder code)

createDataWriter

public DataWriter createDataWriter()

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable

Overrides:

toXmlElement in class PipelineOutput

fromXmlElement

public JdbcPipelineOutput fromXmlElement(Element pipelineOutputElement)