com.continuent.tungsten.replicator.applier
Class PostgreSQLApplier

java.lang.Object
  com.continuent.tungsten.replicator.applier.JdbcApplier
      com.continuent.tungsten.replicator.applier.PostgreSQLApplier

All Implemented Interfaces:

RawApplier, ReplicatorPlugin

public class PostgreSQLApplier
extends JdbcApplier

Field Summary

protected java.lang.String	host
protected int	port

Fields inherited from class com.continuent.tungsten.replicator.applier.JdbcApplier

commitCount, commitSeqnoTable, conn, consistencySelect, consistencyTable, currentOptions, currentSchema, currentTimestamp, driver, eventCount, heartbeatTable, ignoreSessionPattern, ignoreSessionVars, lastSessionId, maxSQLLogLength, metadataSchema, password, runtime, statement, taskId, url, user

Constructor Summary

PostgreSQLApplier()

Method Summary

protected Column	addColumn(java.sql.ResultSet rs, java.lang.String columnName) Returns a new column definition.
void	configure(PluginContext context) Generate URL suitable for PostgreSQL and then delegate remaining configuration to superclass.
void	setHost(java.lang.String host)
protected void	setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
void	setPort(java.lang.String portAsString)

Methods inherited from class com.continuent.tungsten.replicator.applier.JdbcApplier

apply, applyLoadDataLocal, applyOneRowChangePrepared, applyRowChangeData, applyRowIdData, applySessionVariables, applySetTimestamp, applyStatementData, applyUseSchema, bindColumnValues, commit, fillColumnNames, getDatabase, getLastEvent, logFailedStatementSQL, logFailedStatementSQL, needNewSQLStatement, prepare, printColumnSpec, release, rollback, setDriver, setGetColumnMetadataFromDB, setIgnoreSessionVars, setPassword, setTaskId, setUrl, setUser

Methods inherited from class java.lang.Object

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

Field Detail

host

protected java.lang.String host

port

protected int port

Constructor Detail

PostgreSQLApplier

public PostgreSQLApplier()

Method Detail

setHost

public void setHost(java.lang.String host)

setPort

public void setPort(java.lang.String portAsString)

configure

public void configure(PluginContext context)
               throws ReplicatorException

Generate URL suitable for PostgreSQL and then delegate remaining configuration to superclass.

Specified by:

configure in interface ReplicatorPlugin

Overrides:

configure in class JdbcApplier

Throws:

ReplicatorException - Thrown if configuration is incomplete or fails

See Also:

ReplicatorPlugin.configure(PluginContext context)

setObject

protected void setObject(java.sql.PreparedStatement prepStatement,
                         int bindLoc,
                         OneRowChange.ColumnVal value,
                         OneRowChange.ColumnSpec columnSpec)
                  throws java.sql.SQLException

Overrides:

setObject in class JdbcApplier

Throws:

java.sql.SQLException

See Also:

JdbcApplier.setObject(java.sql.PreparedStatement, int, com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnVal, com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnSpec)

addColumn

protected Column addColumn(java.sql.ResultSet rs,
                           java.lang.String columnName)
                    throws java.sql.SQLException

Description copied from class: JdbcApplier

Returns a new column definition.

Overrides:

addColumn in class JdbcApplier

Parameters:

rs - Metadata resultset

columnName - Name of the column to be added

Returns:

the column definition

Throws:

java.sql.SQLException - if an error occurs