public class JdbcManager
extends java.lang.Object
Constructor and Description |
---|
JdbcManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o)
Test for equality.
|
java.lang.String |
getBlob()
Returns the blob type.
|
java.lang.String |
getConsumerSequence()
Returns the consumer sequence
|
java.lang.String |
getConsumerTable()
Returns the consumer table
|
javax.sql.DataSource |
getDataSource()
Gets the data source.
|
java.lang.String |
getDestinationSequence()
Returns the destination sequence
|
java.lang.String |
getDestinationTable()
Returns the destination table
|
JdbcMessage |
getJdbcMessage()
Returns the JDBC message manager.
|
java.lang.String |
getLongType()
Returns the blob type.
|
java.lang.String |
getMessageTable()
Returns the message table
|
JdbcMetaData |
getMetaData()
Returns the meta-data.
|
long |
getPollInterval()
Returns the poll interval.
|
long |
getPurgeInterval()
Gets the purge interval.
|
java.lang.String |
getTablespace()
Gets the oracle tablespace
|
int |
hashCode()
Returns a hash code.
|
void |
init()
Initializes the JdbcManager
|
protected void |
initConsumerTable()
Initializes the consumer table.
|
protected void |
initDestinationTable()
Initializes the destination table.
|
boolean |
isTruncateBlob()
Return true if blobs need to be truncated before deletion.
|
void |
setConsumerTable(java.lang.String tableName)
Sets the consumer table
|
void |
setDataSource(javax.sql.DataSource dataSource)
Sets the data source.
|
void |
setDestinationTable(java.lang.String tableName)
Sets the destination table
|
void |
setMessageTable(java.lang.String tableName)
Sets the message table
|
void |
setPollInterval(Period pollInterval)
Sets the poll interval for destinations that have a listener, default
is to do no polling.
|
void |
setPurgeInterval(Period period)
Sets the purge interval.
|
void |
setTablespace(java.lang.String tablespace)
Sets the oracle tablespace.
|
public void setDataSource(javax.sql.DataSource dataSource)
public javax.sql.DataSource getDataSource()
public java.lang.String getMessageTable()
public void setMessageTable(java.lang.String tableName)
public java.lang.String getDestinationTable()
public void setDestinationTable(java.lang.String tableName)
public java.lang.String getDestinationSequence()
public java.lang.String getConsumerTable()
public void setConsumerTable(java.lang.String tableName)
public java.lang.String getConsumerSequence()
public JdbcMetaData getMetaData()
public java.lang.String getBlob()
public void setTablespace(java.lang.String tablespace)
public java.lang.String getTablespace()
public java.lang.String getLongType()
public void setPurgeInterval(Period period)
public long getPurgeInterval()
public void setPollInterval(Period pollInterval)
public long getPollInterval()
public JdbcMessage getJdbcMessage()
public boolean isTruncateBlob()
@PostConstruct public void init() throws ConfigException, java.sql.SQLException
ConfigException
java.sql.SQLException
protected void initDestinationTable() throws java.sql.SQLException
java.sql.SQLException
protected void initConsumerTable() throws java.sql.SQLException
java.sql.SQLException
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object