DBReplicator

Open Source Database Replication

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

Home

JavaDoc

• Developer Documentation
• Resource

org.dbreplicator.replication
Class RepTable

java.lang.Object
  org.dbreplicator.replication.RepTable

public class RepTable
extends java.lang.Object

This Class stores all the relevant information for any replication table involved in the publication or subscription. A publisher or subscriber saves the objects of this class corresponding to all replication tables. This class is used to create Reptable table for the perticular publisher or sub.

Constructor Summary

RepTable(SchemaQualifiedName sName0, java.lang.String serverType0)

RepTable(SchemaQualifiedName sName0, java.lang.String filterClause0, java.lang.String serverType0)

Method Summary

java.lang.String	createDeleteQueryForSynchronise_ShadowTable(long lastConisderedId, java.lang.String remoteServerName)
java.lang.String	createDeleteQueryForSynchronise()
java.lang.String	createInsertQueryForSnapShot()
java.lang.String	createUpdateQueryForSnapShot()
java.lang.String	createUpdateQueryForSynchronize()
java.util.TreeMap	getAllColumns()
java.lang.String[]	getColumnsToBeIgnored()
java.util.TreeMap	getColumnTreeMap(java.sql.Connection connection, AbstractDataBaseHandler dbDatatypeHandler) Return a Treemap containg column Names and their respective data type.
java.lang.String	getConflictResolver()
java.lang.String	getCreateShadowTable()
java.lang.String	getCyclicDependency()
java.lang.String	getFilterClause()
java.lang.String[]	getForeignKeyCols()
java.lang.String[]	getPrimaryColumns() Return the array of all primary columns that are declared in table which is included in publication.
java.lang.String	getRepTableQualifiedIdentifier()
SchemaQualifiedName	getSchemaQualifiedName()
java.lang.String	getServerType()
java.lang.String	getUpdatePreStmt(java.util.ArrayList loaclColumnNames, java.lang.String[] primaryColumnName) Retunrs a query for Update in Main table This method is called for performing update operation when Replicator found the update operation in XML file.
boolean	isForeignKeyColumn(java.lang.String columnName)
boolean	isIgnoredColumn(java.lang.String columnName)
boolean	isLocalServerWinner() Retunrs weather local server is conflict resolver or not.
void	setAllColumns(java.lang.String[] allColumns0)
void	setColumnsToBeIgnored(java.lang.String[] columnsToBeIgnored)
void	setConflictResolver(java.lang.String conflictResolver0)
void	setCreateShadowTable(java.lang.String createShadowTable)
void	setCyclicDependency(java.lang.String cyclicDependency0)
void	setFilterClause(java.lang.String filterClause0)
void	setForeignKeyCols(java.lang.String[] foreignKeyCols0)
void	setPrimaryColumns(java.lang.String[] primCols0)
void	setServerType(java.lang.String serverType)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RepTable

public RepTable(SchemaQualifiedName sName0,
                java.lang.String serverType0)

RepTable

public RepTable(SchemaQualifiedName sName0,
                java.lang.String filterClause0,
                java.lang.String serverType0)

Method Detail

getFilterClause

public java.lang.String getFilterClause()

setFilterClause

public void setFilterClause(java.lang.String filterClause0)

getConflictResolver

public java.lang.String getConflictResolver()

setConflictResolver

public void setConflictResolver(java.lang.String conflictResolver0)

getCreateShadowTable

public java.lang.String getCreateShadowTable()

getForeignKeyCols

public java.lang.String[] getForeignKeyCols()

setCreateShadowTable

public void setCreateShadowTable(java.lang.String createShadowTable)

setForeignKeyCols

public void setForeignKeyCols(java.lang.String[] foreignKeyCols0)

getSchemaQualifiedName

public SchemaQualifiedName getSchemaQualifiedName()

getColumnTreeMap

public java.util.TreeMap getColumnTreeMap(java.sql.Connection connection,
                                          AbstractDataBaseHandler dbDatatypeHandler)
                                   throws java.sql.SQLException,
                                          RepException

Return a Treemap containg column Names and their respective data type.

Parameters:

connection -

dbDatatypeHandler -

Returns:

columnTypeInfo

Throws:

java.sql.SQLException

RepException

isIgnoredColumn

public boolean isIgnoredColumn(java.lang.String columnName)

createInsertQueryForSnapShot

public java.lang.String createInsertQueryForSnapShot()

createDeleteQueryForSynchronise

public java.lang.String createDeleteQueryForSynchronise()

createUpdateQueryForSnapShot

public java.lang.String createUpdateQueryForSnapShot()

isForeignKeyColumn

public boolean isForeignKeyColumn(java.lang.String columnName)

createDeleteQueryForSynchronise_ShadowTable

public java.lang.String createDeleteQueryForSynchronise_ShadowTable(long lastConisderedId,
                                                                    java.lang.String remoteServerName)

getPrimaryColumns

public java.lang.String[] getPrimaryColumns()

Return the array of all primary columns that are declared in table which is included in publication.

Returns:

String[] Array of primary columns.

isLocalServerWinner

public boolean isLocalServerWinner()

Retunrs weather local server is conflict resolver or not.

Returns:

boolean

getUpdatePreStmt

public java.lang.String getUpdatePreStmt(java.util.ArrayList loaclColumnNames,
                                         java.lang.String[] primaryColumnName)

Retunrs a query for Update in Main table This method is called for performing update operation when Replicator found the update operation in XML file.

Parameters:

loaclColumnNames -

primaryColumnName -

Returns:

string preparedStatement

setPrimaryColumns

public void setPrimaryColumns(java.lang.String[] primCols0)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getRepTableQualifiedIdentifier

public java.lang.String getRepTableQualifiedIdentifier()

getCyclicDependency

public java.lang.String getCyclicDependency()

setCyclicDependency

public void setCyclicDependency(java.lang.String cyclicDependency0)

getColumnsToBeIgnored

public java.lang.String[] getColumnsToBeIgnored()

getServerType

public java.lang.String getServerType()

setColumnsToBeIgnored

public void setColumnsToBeIgnored(java.lang.String[] columnsToBeIgnored)

setServerType

public void setServerType(java.lang.String serverType)

createUpdateQueryForSynchronize

public java.lang.String createUpdateQueryForSynchronize()

setAllColumns

public void setAllColumns(java.lang.String[] allColumns0)

getAllColumns

public java.util.TreeMap getAllColumns()