DBReplicator

Open Source Database Replication

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

Home

JavaDoc

• Developer Documentation
• Resource

org.dbreplicator.replication
Interface _PubImpl

All Superinterfaces:

java.rmi.Remote

All Known Implementing Classes:

Publication

public interface _PubImpl
extends java.rmi.Remote

This is a remote interface which is implemented by the remote server class publication. This interface contains the declaration of all the methods which are needed by the subscriber at the time of 1. subscribing 2. taking snapshot 3. synchronization.

Method Summary

void	checkForLock(java.lang.String pubSubName)
void	createSnapShot(java.lang.String subName, boolean isSchemaSupported, _FileUpload fileUpload, java.lang.String remoteMachineAddress)
void	createSnapShotAfterUpdateSub(java.lang.String address, int portNo, java.lang.String subName, java.util.ArrayList tablesForSnapShot, boolean isSchemaSupported, _FileUpload fileUpload, java.lang.String remoteMachineAddress)
void	createStructure(int vendorName, java.lang.String subName, java.lang.String url, boolean isSchemaSupported, _FileUpload fileUpload, java.lang.String remoteMachineAddress)
java.lang.Object[]	createXMLForClient(java.lang.String subName, java.lang.String clientServerName, boolean isSchemaSupported, _FileUpload fileUpload, java.lang.String remoteMachineAddress)
void	dropSubscription(java.lang.String subName)
java.util.ArrayList	dropTableListForSub(java.lang.String subName)
java.lang.String	getConflictResolver()
_FileUpload	getFileUploader()
java.lang.String	getFilterClause(SchemaQualifiedName tableName)
java.lang.Object[]	getPublisherAddressAndPort()
int	getPubVendorName()
java.lang.String	getServerName()
void	push(java.lang.String subName, java.lang.String remoteServerName, boolean isCreateTransactionLogFile, java.lang.String remoteMachineAddress)
void	releaseLOCK()
void	saveSubscriptionData(java.lang.String subName)
void	saveSubscriptionNewData(java.lang.String subName)
void	synchronize(java.lang.String subName, java.lang.String remoteServerName, boolean isCreateTransactionLogFile, java.lang.String remoteMachineAddress)
void	updateBookMarkLastSyncId(java.lang.String remote_Pub_Sub_Name, java.lang.Object[] lastId)
void	updatePublisherShadowAndBookmarkTableAfterPullOnSubscriber(java.lang.String remote_Pub_Sub_Name, java.lang.Object[] lastId)

Method Detail

createStructure

void createStructure(int vendorName,
                     java.lang.String subName,
                     java.lang.String url,
                     boolean isSchemaSupported,
                     _FileUpload fileUpload,
                     java.lang.String remoteMachineAddress)
                     throws java.rmi.RemoteException,
                            java.sql.SQLException,
                            RepException

Throws:

java.rmi.RemoteException

java.sql.SQLException

RepException

createSnapShot

void createSnapShot(java.lang.String subName,
                    boolean isSchemaSupported,
                    _FileUpload fileUpload,
                    java.lang.String remoteMachineAddress)
                    throws java.rmi.RemoteException,
                           java.sql.SQLException,
                           RepException

Throws:

java.rmi.RemoteException

java.sql.SQLException

RepException

synchronize

void synchronize(java.lang.String subName,
                 java.lang.String remoteServerName,
                 boolean isCreateTransactionLogFile,
                 java.lang.String remoteMachineAddress)
                 throws java.rmi.RemoteException,
                        RepException

Throws:

java.rmi.RemoteException

RepException

push

void push(java.lang.String subName,
          java.lang.String remoteServerName,
          boolean isCreateTransactionLogFile,
          java.lang.String remoteMachineAddress)
          throws java.rmi.RemoteException,
                 RepException

Throws:

java.rmi.RemoteException

RepException

createXMLForClient

java.lang.Object[] createXMLForClient(java.lang.String subName,
                                      java.lang.String clientServerName,
                                      boolean isSchemaSupported,
                                      _FileUpload fileUpload,
                                      java.lang.String remoteMachineAddress)
                                      throws java.rmi.RemoteException,
                                             RepException

Throws:

java.rmi.RemoteException

RepException

getPublisherAddressAndPort

java.lang.Object[] getPublisherAddressAndPort()
                                              throws java.rmi.RemoteException,
                                                     RepException

Throws:

java.rmi.RemoteException

RepException

getConflictResolver

java.lang.String getConflictResolver()
                                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getFilterClause

java.lang.String getFilterClause(SchemaQualifiedName tableName)
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getServerName

java.lang.String getServerName()
                               throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

dropSubscription

void dropSubscription(java.lang.String subName)
                      throws java.rmi.RemoteException,
                             java.sql.SQLException,
                             RepException

Throws:

java.rmi.RemoteException

java.sql.SQLException

RepException

releaseLOCK

void releaseLOCK()
                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

checkForLock

void checkForLock(java.lang.String pubSubName)
                  throws RepException,
                         java.rmi.RemoteException

Throws:

RepException

java.rmi.RemoteException

saveSubscriptionData

void saveSubscriptionData(java.lang.String subName)
                          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getPubVendorName

int getPubVendorName()
                     throws java.rmi.RemoteException,
                            RepException

Throws:

java.rmi.RemoteException

RepException

updateBookMarkLastSyncId

void updateBookMarkLastSyncId(java.lang.String remote_Pub_Sub_Name,
                              java.lang.Object[] lastId)
                              throws java.rmi.RemoteException,
                                     java.sql.SQLException,
                                     RepException

Throws:

java.rmi.RemoteException

java.sql.SQLException

RepException

saveSubscriptionNewData

void saveSubscriptionNewData(java.lang.String subName)
                             throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

createSnapShotAfterUpdateSub

void createSnapShotAfterUpdateSub(java.lang.String address,
                                  int portNo,
                                  java.lang.String subName,
                                  java.util.ArrayList tablesForSnapShot,
                                  boolean isSchemaSupported,
                                  _FileUpload fileUpload,
                                  java.lang.String remoteMachineAddress)
                                  throws java.sql.SQLException,
                                         java.rmi.RemoteException,
                                         RepException

Throws:

java.sql.SQLException

java.rmi.RemoteException

RepException

dropTableListForSub

java.util.ArrayList dropTableListForSub(java.lang.String subName)
                                        throws RepException,
                                               java.sql.SQLException,
                                               java.rmi.RemoteException

Throws:

RepException

java.sql.SQLException

java.rmi.RemoteException

updatePublisherShadowAndBookmarkTableAfterPullOnSubscriber

void updatePublisherShadowAndBookmarkTableAfterPullOnSubscriber(java.lang.String remote_Pub_Sub_Name,
                                                                java.lang.Object[] lastId)
                                                                throws java.rmi.RemoteException,
                                                                       java.sql.SQLException,
                                                                       RepException

Throws:

java.rmi.RemoteException

java.sql.SQLException

RepException

getFileUploader

_FileUpload getFileUploader()
                            throws RepException,
                                   java.sql.SQLException,
                                   java.rmi.RemoteException

Throws:

RepException

java.sql.SQLException

java.rmi.RemoteException