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 AbstractSynchronize

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

Direct Known Subclasses:

OperationDelete, OperationInsert, OperationUpdate

public class AbstractSynchronize
extends java.lang.Object

Field Summary

int	deleteCount
int	insertCount
int	updateCount

Constructor Summary

AbstractSynchronize()

Method Summary

boolean	checkAutocommit(AbstractDataBaseHandler dbHandler, AbstractColumnObject aco) This has been implemented to handle the problem related to CLOB and BLOB data type.
void	setAutocomitTrueAndCommitRecord(java.sql.Connection conn)
static void	writeDateInTransactionLogFile(java.io.BufferedWriter bw)
static void	writeOperationInTransactionLogFile(java.io.BufferedWriter bw, int insertOperation, int updateOperation, int deleteOperation, java.lang.String replicationType)
static void	writeUnsuccessfullOperationInTransaction(java.io.BufferedWriter bw)

Methods inherited from class java.lang.Object

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

Field Detail

insertCount

public int insertCount

updateCount

public int updateCount

deleteCount

public int deleteCount

Constructor Detail

AbstractSynchronize

public AbstractSynchronize()

Method Detail

writeOperationInTransactionLogFile

public static void writeOperationInTransactionLogFile(java.io.BufferedWriter bw,
                                                      int insertOperation,
                                                      int updateOperation,
                                                      int deleteOperation,
                                                      java.lang.String replicationType)
                                               throws java.lang.Exception

Throws:

java.lang.Exception

writeDateInTransactionLogFile

public static void writeDateInTransactionLogFile(java.io.BufferedWriter bw)
                                          throws java.lang.Exception

Throws:

java.lang.Exception

writeUnsuccessfullOperationInTransaction

public static void writeUnsuccessfullOperationInTransaction(java.io.BufferedWriter bw)

checkAutocommit

public boolean checkAutocommit(AbstractDataBaseHandler dbHandler,
                               AbstractColumnObject aco)

This has been implemented to handle the problem related to CLOB and BLOB data type. Postgre do not to insert LOB object in autocommit mode.

Parameters:

dbHandler - AbstractDataBaseHandler

aco - AbstractColumnObject

Returns:

boolean

setAutocomitTrueAndCommitRecord

public void setAutocomitTrueAndCommitRecord(java.sql.Connection conn)
                                     throws java.sql.SQLException

Throws:

java.sql.SQLException