com.exalead.papi.connectors.jdbc

Class DatabaseConnectorConfig

java.lang.Object

com.exalead.config.bean.BeanConfig

com.exalead.config.bean.DynamicBeanConfig

com.exalead.papi.framework.connectors.v10.ConnectorConfig

com.exalead.papi.framework.connectors.ConnectorConfig

com.exalead.papi.connectors.jdbc.DatabaseConnectorConfig

All Implemented Interfaces:

BeanSample, CallAfterFill, CVComponentConfig, CVComponentConfigSamplify, ConnectorConfigCheckInterface

public class DatabaseConnectorConfig
extends ConnectorConfig

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DatabaseConnectorConfig.ConnectionProperty

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String[]	allUrisPostQueries
java.lang.String[]	allUrisPreQueries
java.lang.String	allUrisQuery
java.lang.Boolean	autoCommit
boolean	checkForMissing
java.lang.String	checkpointColumn
java.lang.String	checkpointQuery
VariableReplacementMode	checkpointVariableReplacementMode
DatabaseConnectorConfig.ConnectionProperty[]	connectionProperties
java.lang.String	driverClass
java.lang.Integer	fetchDirection
java.lang.String	fetcherClass
java.lang.String	fetchQuery
java.lang.String[]	incrementalDeleteQueries
java.lang.String[]	incrementalPostQueries
java.lang.String[]	incrementalPreQueries
java.lang.String	incrementalQuery
java.lang.String	incrementalStartVariable
java.lang.String	incrementalVariable
java.lang.String[]	initialPostQueries
java.lang.String[]	initialPreQueries
java.lang.String	initialQuery
java.lang.String	interconnectorServerInstanceName
java.lang.String	login
DatabaseColumnMappingConfig[]	mappings
java.lang.Integer	maxFieldSize
java.lang.Integer	maxRowsInRAM
DatabaseConnectorMode	mode
java.lang.String	password
java.lang.Integer	queryTimeout
java.lang.Boolean	readOnly
java.lang.Integer	resultSetConcurrency
ResultSetPolicyMode	resultSetPolicy
java.lang.Integer	resultSetType
java.lang.String	slaveConnector
java.lang.String	url
boolean	verbose
boolean	warningsAsError

Fields inherited from class com.exalead.papi.framework.connectors.ConnectorConfig

customPushAPIFilters, thresholds

Constructor Summary

Constructors

Constructor and Description
DatabaseConnectorConfig()

Method Summary

Modifier and Type	Method and Description
void	callAfterFill() override this method to do some task before creating connector
DatabaseConnectorConfig.ConnectionProperty[]	getConnectionProperties()
java.util.Map<java.lang.String,java.lang.String>	getConnectionPropertiesAsMap()
java.lang.String	getInterconnectorServerInstanceName()
java.lang.String	getMaxRowsInRAM()
java.lang.String	getReplacementMode()
java.lang.String	getResultSetMemoize()
void	setAllUrisPostQueries(java.lang.String[] allUrisPostQueries)
void	setAllUrisPreQueries(java.lang.String[] allUrisPreQueries)
void	setAllUrisQuery(java.lang.String allUrisQuery)
void	setAutoCommit(java.lang.String autoCommit)
void	setCheckForMissing(boolean checkForMissing)
void	setCheckpointColumn(java.lang.String checkpointColumn)
void	setCheckpointQuery(java.lang.String checkpointQuery)
void	setConnectionProperties(DatabaseConnectorConfig.ConnectionProperty[] connectionProperties)
void	setDriverClass(java.lang.String className)
void	setFetchDirection(java.lang.String fetchDirection)
void	setFetcherClass(java.lang.String fetcherClass)
void	setFetchQuery(java.lang.String fetchQuery)
void	setIncrementalDeleteQueries(java.lang.String[] incrementalDeleteQueries)
void	setIncrementalPostQueries(java.lang.String[] incrementalPostQueries)
void	setIncrementalPreQueries(java.lang.String[] incrementalPreQueries)
void	setIncrementalQuery(java.lang.String incrementalQuery)
void	setIncrementalStartVariable(java.lang.String incrementalStartVariable)
void	setIncrementalVariable(java.lang.String incrementalVariable)
void	setInitialPostQueries(java.lang.String[] initialPostQueries)
void	setInitialPreQueries(java.lang.String[] initialPreQueries)
void	setInitialQuery(java.lang.String request)
void	setInterconnectorServerInstanceName(java.lang.String instanceName)
void	setLogin(java.lang.String login)
void	setMappings(DatabaseColumnMappingConfig[] mappings)
void	setMaxFieldSize(java.lang.String maxFieldSize)
void	setMaxRowsInRAM(java.lang.String maxRowsInRAM)
void	setMode(java.lang.String mode)
void	setPassword(java.lang.String password)
void	setQueryTimeout(java.lang.String queryTimeout)
void	setReadOnly(java.lang.String readOnly)
void	setReplacementMode(java.lang.String replacementMode)
void	setResultSetConcurrency(java.lang.String resultSetConcurrency)
void	setResultSetMemoize(java.lang.String str)
void	setResultSetType(java.lang.String resultSetType)
void	setSlaveConnector(java.lang.String connectorName)
void	setUrl(java.lang.String url)
void	setVerbose(java.lang.String verboseStr)
void	setWarningsAsError(boolean warningsAsError)

Methods inherited from class com.exalead.papi.framework.connectors.ConnectorConfig

getMethods, getPushAPIFilters, samplify, setPushAPIFilters

Methods inherited from class com.exalead.papi.framework.connectors.v10.ConnectorConfig

checkConfig, getPropertiesDefinition, setProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.exalead.papi.framework.connectors.v10.ConnectorConfigCheckInterface

checkConfig

Field Detail

mode

public DatabaseConnectorMode mode

initialQuery

public java.lang.String initialQuery

initialPreQueries

public java.lang.String[] initialPreQueries

initialPostQueries

public java.lang.String[] initialPostQueries

fetchQuery

public java.lang.String fetchQuery

allUrisQuery

public java.lang.String allUrisQuery

allUrisPreQueries

public java.lang.String[] allUrisPreQueries

allUrisPostQueries

public java.lang.String[] allUrisPostQueries

incrementalQuery

public java.lang.String incrementalQuery

incrementalDeleteQueries

public java.lang.String[] incrementalDeleteQueries

incrementalPreQueries

public java.lang.String[] incrementalPreQueries

incrementalPostQueries

public java.lang.String[] incrementalPostQueries

checkpointQuery

public java.lang.String checkpointQuery

checkpointColumn

public java.lang.String checkpointColumn

driverClass

public java.lang.String driverClass

login

public java.lang.String login

password

public java.lang.String password

url

public java.lang.String url

incrementalVariable

public java.lang.String incrementalVariable

incrementalStartVariable

public java.lang.String incrementalStartVariable

resultSetType

public java.lang.Integer resultSetType

resultSetConcurrency

public java.lang.Integer resultSetConcurrency

fetchDirection

public java.lang.Integer fetchDirection

maxRowsInRAM

public java.lang.Integer maxRowsInRAM

maxFieldSize

public java.lang.Integer maxFieldSize

queryTimeout

public java.lang.Integer queryTimeout

autoCommit

public java.lang.Boolean autoCommit

readOnly

public java.lang.Boolean readOnly

mappings

public DatabaseColumnMappingConfig[] mappings

verbose

public boolean verbose

warningsAsError

public boolean warningsAsError

checkForMissing

public boolean checkForMissing

checkpointVariableReplacementMode

public VariableReplacementMode checkpointVariableReplacementMode

resultSetPolicy

public ResultSetPolicyMode resultSetPolicy

connectionProperties

public DatabaseConnectorConfig.ConnectionProperty[] connectionProperties

fetcherClass

public java.lang.String fetcherClass

slaveConnector

public java.lang.String slaveConnector

interconnectorServerInstanceName

public java.lang.String interconnectorServerInstanceName

Constructor Detail

DatabaseConnectorConfig

public DatabaseConnectorConfig()

Method Detail

setMode

public void setMode(java.lang.String mode)

setInitialQuery

public void setInitialQuery(java.lang.String request)

setDriverClass

public void setDriverClass(java.lang.String className)

setLogin

public void setLogin(java.lang.String login)

setPassword

public void setPassword(java.lang.String password)

setUrl

public void setUrl(java.lang.String url)

setFetchQuery

public void setFetchQuery(java.lang.String fetchQuery)

setAllUrisQuery

public void setAllUrisQuery(java.lang.String allUrisQuery)

setMappings

public void setMappings(DatabaseColumnMappingConfig[] mappings)

setIncrementalQuery

public void setIncrementalQuery(java.lang.String incrementalQuery)

setIncrementalDeleteQueries

public void setIncrementalDeleteQueries(java.lang.String[] incrementalDeleteQueries)

setCheckpointQuery

public void setCheckpointQuery(java.lang.String checkpointQuery)

setCheckpointColumn

public void setCheckpointColumn(java.lang.String checkpointColumn)

setIncrementalVariable

public void setIncrementalVariable(java.lang.String incrementalVariable)

setIncrementalStartVariable

public void setIncrementalStartVariable(java.lang.String incrementalStartVariable)

setFetcherClass

public void setFetcherClass(java.lang.String fetcherClass)

setSlaveConnector

public void setSlaveConnector(java.lang.String connectorName)

setInterconnectorServerInstanceName

public void setInterconnectorServerInstanceName(java.lang.String instanceName)

getInterconnectorServerInstanceName

public java.lang.String getInterconnectorServerInstanceName()

setQueryTimeout

public void setQueryTimeout(java.lang.String queryTimeout)

setResultSetType

public void setResultSetType(java.lang.String resultSetType)

setResultSetConcurrency

public void setResultSetConcurrency(java.lang.String resultSetConcurrency)

setFetchDirection

public void setFetchDirection(java.lang.String fetchDirection)

setMaxRowsInRAM

public void setMaxRowsInRAM(java.lang.String maxRowsInRAM)

getMaxRowsInRAM

public java.lang.String getMaxRowsInRAM()

setMaxFieldSize

public void setMaxFieldSize(java.lang.String maxFieldSize)

setAutoCommit

public void setAutoCommit(java.lang.String autoCommit)

setReadOnly

public void setReadOnly(java.lang.String readOnly)

setVerbose

public void setVerbose(java.lang.String verboseStr)

setWarningsAsError

public void setWarningsAsError(boolean warningsAsError)

setCheckForMissing

public void setCheckForMissing(boolean checkForMissing)

setReplacementMode

public void setReplacementMode(java.lang.String replacementMode)

getReplacementMode

public java.lang.String getReplacementMode()

setResultSetMemoize

public void setResultSetMemoize(java.lang.String str)

getResultSetMemoize

public java.lang.String getResultSetMemoize()

setInitialPreQueries

public void setInitialPreQueries(java.lang.String[] initialPreQueries)

setInitialPostQueries

public void setInitialPostQueries(java.lang.String[] initialPostQueries)

setIncrementalPreQueries

public void setIncrementalPreQueries(java.lang.String[] incrementalPreQueries)

setIncrementalPostQueries

public void setIncrementalPostQueries(java.lang.String[] incrementalPostQueries)

setAllUrisPreQueries

public void setAllUrisPreQueries(java.lang.String[] allUrisPreQueries)

setAllUrisPostQueries

public void setAllUrisPostQueries(java.lang.String[] allUrisPostQueries)

callAfterFill

public void callAfterFill()
                   throws java.lang.Exception

Description copied from class: BeanConfig

override this method to do some task before creating connector

Specified by:

callAfterFill in interface CallAfterFill

Overrides:

callAfterFill in class BeanConfig

Throws:

java.lang.Exception

setConnectionProperties

public void setConnectionProperties(DatabaseConnectorConfig.ConnectionProperty[] connectionProperties)

getConnectionProperties

public DatabaseConnectorConfig.ConnectionProperty[] getConnectionProperties()

getConnectionPropertiesAsMap

public java.util.Map<java.lang.String,java.lang.String> getConnectionPropertiesAsMap()