org.xmlBlaster.contrib.replication.impl
Class RsToSqlInfo

java.lang.Object
  org.xmlBlaster.contrib.replication.impl.RsToSqlInfo

All Implemented Interfaces:

I_ResultCb

public class RsToSqlInfo
extends java.lang.Object
implements I_ResultCb

Field Summary

private java.util.Set	cancelledUpdates
private java.lang.String	destination
private InitialUpdater	initialUpdater
private static java.util.logging.Logger	log
private long	newReplKey
private int	rowsPerMessage
private SqlInfo	sqlInfo
private I_AttributeTransformer	transformer

Constructor Summary

RsToSqlInfo(InitialUpdater initialUpdater, SqlInfo sqlInfo, java.util.Set cancelledUpdates, I_AttributeTransformer transformer, long newReplKey, int rowsPerMessage, java.lang.String destination)

Method Summary

void	result(java.sql.Connection conn, java.sql.ResultSet rs) Can handle all sort of tables (not REPL_ITEM) for initial scan.

Methods inherited from class java.lang.Object

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

Field Detail

log

private static java.util.logging.Logger log

rowsPerMessage

private int rowsPerMessage

initialUpdater

private InitialUpdater initialUpdater

sqlInfo

private SqlInfo sqlInfo

cancelledUpdates

private java.util.Set cancelledUpdates

transformer

private I_AttributeTransformer transformer

newReplKey

private long newReplKey

destination

private java.lang.String destination

Constructor Detail

RsToSqlInfo

public RsToSqlInfo(InitialUpdater initialUpdater,
                   SqlInfo sqlInfo,
                   java.util.Set cancelledUpdates,
                   I_AttributeTransformer transformer,
                   long newReplKey,
                   int rowsPerMessage,
                   java.lang.String destination)

Method Detail

result

public final void result(java.sql.Connection conn,
                         java.sql.ResultSet rs)
                  throws java.lang.Exception

Can handle all sort of tables (not REPL_ITEM) for initial scan.

Specified by:

result in interface I_ResultCb

rs - The current ResultSet, is null if table or view does not exist

Throws:

java.lang.Exception - Can be of any type

See Also:

I_ResultCb#init(ResultSet)