DBReplicator

Open Source Database Replication

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

Home

JavaDoc

• Developer Documentation
• Resource

org.dbreplicator.replication.DBHandler
Class GeneralDataBaseHandler

java.lang.Object
  org.dbreplicator.replication.DBHandler.AbstractDataBaseHandler
      org.dbreplicator.replication.DBHandler.GeneralDataBaseHandler

public class GeneralDataBaseHandler
extends AbstractDataBaseHandler

Generic methods common to all databases.

Field Summary

Fields inherited from class org.dbreplicator.replication.DBHandler.AbstractDataBaseHandler

ignoredColumns_Table, trackPrimaryKeyUpdation_Table, trackReplicationTablesUpdation_Table

Constructor Summary

GeneralDataBaseHandler()

GeneralDataBaseHandler(ConnectionPool connectionPool0)

Method Summary

void	createShadowTable(java.lang.String pubsubName, java.lang.String tableName, java.lang.String allColSequence, java.lang.String[] primaryColumns) Creates Shadow Table as per the database.
void	createShadowTableTriggers(java.lang.String pubName, java.lang.String tableName, java.util.ArrayList colNameDataType, java.lang.String[] primCols) Creates ShadowTable triggers on different replication tables.
int	getAppropriateScale(int columnScale)
AbstractColumnObject	getColumnObject(TypeInfo typeInfo) According to the sqlType, different column's for different databases are handled saperately.
boolean	isDataTypeOptionalSizeSupported(TypeInfo typeInfo)
boolean	isForeignKeyException(java.sql.SQLException ex) To get the foreign key error code to resolve the Synchronization problem when tables have parent - child relationship.
boolean	isPrimaryKeyException(java.sql.SQLException ex)
boolean	isSchemaSupported() isSchemaSupported
java.sql.PreparedStatement	makeCommonPreparedStatement(java.lang.String shadowTable, java.lang.String local_pub_sub_name) makeCommonPreparedStatement
java.sql.PreparedStatement	makePrimaryPreperedStatement(java.sql.Connection pub_sub_Connection, java.lang.String[] primaryColumns, java.lang.String shadowTable, java.lang.String local_pub_sub_name)
java.sql.PreparedStatement	makePrimaryPreperedStatementBackwardTraversing(java.lang.String[] primaryColumns, long lastId, java.lang.String local_pub_sub_name, java.lang.String shadowTable)
void	setTypeInfo(TypeInfo typeInfo, java.sql.ResultSet rs) This is a very important function which sets the parameter (instance of Class TypeInfo) with the corresponding typeName of the sqlType for different databases.

Methods inherited from class org.dbreplicator.replication.DBHandler.AbstractDataBaseHandler

checkSchema, createClientSystemTables, createRemoteSystemTables, createSchemas, CreateSequenceOnLogTable, CreateSequenceOnRepTable, CreateSequenceOnShadowTable, createSubscribedTablesTriggersAndShadowTables, deleteRecordsFromSuperLogTable, dropGenerators, dropPublisherSystemTables, dropSequences, dropSubscriberSystemTables, dropTriggersAndShadowTable, fireDropQuery, getAppropriatePrecision, getBookMarkTableName, getColumnNamesAndDataTypes, getColumnNamesAndDataTypes1, getIgnoredColumns_Table, getLocalServerName, getLogTableName, getMinValOfSyncIdTodeleteRecordsFromShadowTable, getPublicationTableName, getRepTableName, getScheduleTableName, getShadowTableColumnDataTypeSequence, getShadowTableName, getSubscriptionTableName, getTableColumns, getTrackPrimayKeyUpdation_Table, getTrackReplicationTablesUpdation_Table, getvendorName, makeProvisionForLOBDataTypes, saveRepTableData, setColumnPrecisionInTypeInfo, setDefaultSchema, setIgnoredColumns, setLocalServerName, updateDataType

Methods inherited from class java.lang.Object

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

Constructor Detail

GeneralDataBaseHandler

public GeneralDataBaseHandler()

GeneralDataBaseHandler

public GeneralDataBaseHandler(ConnectionPool connectionPool0)

Method Detail

createShadowTable

public void createShadowTable(java.lang.String pubsubName,
                              java.lang.String tableName,
                              java.lang.String allColSequence,
                              java.lang.String[] primaryColumns)
                       throws RepException

Description copied from class: AbstractDataBaseHandler

Creates Shadow Table as per the database.

Specified by:

createShadowTable in class AbstractDataBaseHandler

Throws:

RepException

createShadowTableTriggers

public void createShadowTableTriggers(java.lang.String pubName,
                                      java.lang.String tableName,
                                      java.util.ArrayList colNameDataType,
                                      java.lang.String[] primCols)
                               throws RepException

Description copied from class: AbstractDataBaseHandler

Creates ShadowTable triggers on different replication tables.

Specified by:

createShadowTableTriggers in class AbstractDataBaseHandler

Throws:

RepException

isDataTypeOptionalSizeSupported

public boolean isDataTypeOptionalSizeSupported(TypeInfo typeInfo)

Specified by:

isDataTypeOptionalSizeSupported in class AbstractDataBaseHandler

setTypeInfo

public void setTypeInfo(TypeInfo typeInfo,
                        java.sql.ResultSet rs)
                 throws RepException,
                        java.sql.SQLException

Description copied from class: AbstractDataBaseHandler

This is a very important function which sets the parameter (instance of Class TypeInfo) with the corresponding typeName of the sqlType for different databases. So that we can make corresponding queries.

Specified by:

setTypeInfo in class AbstractDataBaseHandler

Throws:

RepException

java.sql.SQLException

getColumnObject

public AbstractColumnObject getColumnObject(TypeInfo typeInfo)
                                     throws RepException

Description copied from class: AbstractDataBaseHandler

According to the sqlType, different column's for different databases are handled saperately. It returns the object of AbstractColumnObject which is extended by each type of column Object classes. This fundamental is used basically for handeling Blob and Clob type of columns.

Specified by:

getColumnObject in class AbstractDataBaseHandler

Throws:

RepException

isPrimaryKeyException

public boolean isPrimaryKeyException(java.sql.SQLException ex)
                              throws java.sql.SQLException

Specified by:

isPrimaryKeyException in class AbstractDataBaseHandler

Throws:

java.sql.SQLException

getAppropriateScale

public int getAppropriateScale(int columnScale)

Specified by:

getAppropriateScale in class AbstractDataBaseHandler

makePrimaryPreperedStatement

public java.sql.PreparedStatement makePrimaryPreperedStatement(java.sql.Connection pub_sub_Connection,
                                                               java.lang.String[] primaryColumns,
                                                               java.lang.String shadowTable,
                                                               java.lang.String local_pub_sub_name)
                                                        throws java.sql.SQLException,
                                                               RepException

Specified by:

makePrimaryPreperedStatement in class AbstractDataBaseHandler

Throws:

java.sql.SQLException

RepException

isForeignKeyException

public boolean isForeignKeyException(java.sql.SQLException ex)
                              throws java.sql.SQLException

Description copied from class: AbstractDataBaseHandler

To get the foreign key error code to resolve the Synchronization problem when tables have parent - child relationship.

Specified by:

isForeignKeyException in class AbstractDataBaseHandler

Returns:

String

Throws:

java.sql.SQLException

makeCommonPreparedStatement

public java.sql.PreparedStatement makeCommonPreparedStatement(java.lang.String shadowTable,
                                                              java.lang.String local_pub_sub_name)

makeCommonPreparedStatement

Parameters:

shadowTable - String

local_pub_sub_name - String

Returns:

PreparedStatement

makePrimaryPreperedStatementBackwardTraversing

public java.sql.PreparedStatement makePrimaryPreperedStatementBackwardTraversing(java.lang.String[] primaryColumns,
                                                                                 long lastId,
                                                                                 java.lang.String local_pub_sub_name,
                                                                                 java.lang.String shadowTable)
                                                                          throws java.sql.SQLException,
                                                                                 RepException

Specified by:

makePrimaryPreperedStatementBackwardTraversing in class AbstractDataBaseHandler

Throws:

java.sql.SQLException

RepException

isSchemaSupported

public boolean isSchemaSupported()

isSchemaSupported

Specified by:

isSchemaSupported in class AbstractDataBaseHandler

Returns:

boolean