com.northconcepts.datapipeline.foundations.jdbc

Class JdbcQuery

java.lang.Object

com.northconcepts.datapipeline.foundations.core.Bean

com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery

All Implemented Interfaces:

JsonSerializable, RecordSerializable, XmlSerializable, JdbcSource, Serializable

public class JdbcQuery
extends Bean
implements JdbcSource

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcQuery.Cardinality

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
JdbcQuery()
JdbcQuery(String name, String query)

Method Summary

Modifier and Type	Method and Description
JdbcQuery	addColumn(JdbcQueryColumn column)
JdbcQuery	addParameter(JdbcQueryParameter parameter)
JdbcQuery	addParameter(String name, Class<?> javaType, Integer sqlType, String exampleValueExpression)
JdbcQuery	addParameter(String name, Class<?> javaType, String exampleValueExpression)
JdbcQuery	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
JdbcQuery.Cardinality	getCardinality()
List<JdbcQueryColumn>	getColumns()
JdbcConnection	getConnection()
String	getName()
List<JdbcQueryParameter>	getParameters()
String	getQuery()
JdbcSourceType	getSourceType()
JdbcQuery	setCardinality(JdbcQuery.Cardinality cardinality)
JdbcQuery	setColumns(Collection<JdbcQueryColumn> columns)
protected JdbcQuery	setConnection(JdbcConnection connection)
JdbcQuery	setName(String name)
JdbcQuery	setParameters(Collection<JdbcQueryParameter> parameters)
JdbcQuery	setQuery(String query)
JdbcQuery	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

Constructor Detail

JdbcQuery

public JdbcQuery()

JdbcQuery

public JdbcQuery(String name,
                 String query)

Method Detail

getConnection

public JdbcConnection getConnection()

setConnection

protected JdbcQuery setConnection(JdbcConnection connection)

getName

public String getName()

Specified by:

getName in interface JdbcSource

setName

public JdbcQuery setName(String name)

getQuery

public String getQuery()

Specified by:

getQuery in interface JdbcSource

setQuery

public JdbcQuery setQuery(String query)

getParameters

public List<JdbcQueryParameter> getParameters()

setParameters

public JdbcQuery setParameters(Collection<JdbcQueryParameter> parameters)

addParameter

public JdbcQuery addParameter(JdbcQueryParameter parameter)

addParameter

public JdbcQuery addParameter(String name,
                              Class<?> javaType,
                              Integer sqlType,
                              String exampleValueExpression)

addParameter

public JdbcQuery addParameter(String name,
                              Class<?> javaType,
                              String exampleValueExpression)

getColumns

public List<JdbcQueryColumn> getColumns()

setColumns

public JdbcQuery setColumns(Collection<JdbcQueryColumn> columns)

addColumn

public JdbcQuery addColumn(JdbcQueryColumn column)

getCardinality

public JdbcQuery.Cardinality getCardinality()

setCardinality

public JdbcQuery setCardinality(JdbcQuery.Cardinality cardinality)

getSourceType

public JdbcSourceType getSourceType()

Specified by:

getSourceType in interface JdbcSource

sortColumns

public JdbcQuery sortColumns()

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class Bean

fromRecord

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