DBReplicator

Open Source Database Replication

• Home
• Documentation
• Downloads
• Supported Databases
• Community
• Site Help
• Contact
• Resources

Home

JavaDoc

• Developer Documentation
• Resource

org.dbreplicator.replication.synchronize
Class OperationUpdate

java.lang.Object
  org.dbreplicator.replication.synchronize.AbstractSynchronize
      org.dbreplicator.replication.synchronize.OperationUpdate

public class OperationUpdate
extends AbstractSynchronize

This is the main class which handles the synchronization operations on main table when merge handler reads Update operation from the XML file.

Field Summary

Fields inherited from class org.dbreplicator.replication.synchronize.AbstractSynchronize

deleteCount, insertCount, updateCount

Constructor Summary

OperationUpdate(RepTable repTable0, java.sql.Connection clientConnection0, java.util.TreeMap columnObjectTreeMap0, java.lang.Object conisderedId0, java.lang.Object lastSyncId0, java.lang.String remoteServerName0, AbstractDataBaseHandler dbHandler0, java.io.BufferedWriter bw0, java.lang.String replicationType0, java.lang.String transactionLogType0, MetaDataInfo mdi0, boolean isFirstPass0, boolean isCurrentTableCyclic0)
OperationUpdate handles the case related to update operation i.e.

Method Summary

void	closeAllStatments()
void	execute(XMLElement currentElement) searches the record for pk_key in shadow table and updates it in the corresponding main table.

Methods inherited from class org.dbreplicator.replication.synchronize.AbstractSynchronize

checkAutocommit, setAutocomitTrueAndCommitRecord, writeDateInTransactionLogFile, writeOperationInTransactionLogFile, writeUnsuccessfullOperationInTransaction

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationUpdate

public OperationUpdate(RepTable repTable0,
                       java.sql.Connection clientConnection0,
                       java.util.TreeMap columnObjectTreeMap0,
                       java.lang.Object conisderedId0,
                       java.lang.Object lastSyncId0,
                       java.lang.String remoteServerName0,
                       AbstractDataBaseHandler dbHandler0,
                       java.io.BufferedWriter bw0,
                       java.lang.String replicationType0,
                       java.lang.String transactionLogType0,
                       MetaDataInfo mdi0,
                       boolean isFirstPass0,
                       boolean isCurrentTableCyclic0)
                throws java.sql.SQLException

OperationUpdate handles the case related to update operation i.e. when a record with update operation is found in XML File.

Parameters:

repTable0 -

clientConnection0 -

columnObjectTreeMap0 -

conisderedId0 -

lastSyncId0 -

remoteServerName0 -

dbHandler0 - AbstractDataBaseHandler

bw0 - BufferedWriter

replicationType0 - String

transactionLogType0 - String

mdi0 - MetaDataInfo

isFirstPass0 - boolean

isCurrentTableCyclic0 - boolean

Throws:

java.lang.Exception

java.sql.SQLException

Method Detail

execute

public void execute(XMLElement currentElement)
             throws java.sql.SQLException,
                    RepException

searches the record for pk_key in shadow table and updates it in the corresponding main table.

Parameters:

currentElement -

Throws:

java.sql.SQLException

RepException

closeAllStatments

public void closeAllStatments()