com.aspc.remote.task.extdbsync

Class ExtDBSyncUpdate

java.lang.Object

com.aspc.remote.task.extdbsync.ExtDBSyncUpdate

public class ExtDBSyncUpdate
extends java.lang.Object

Updates an external database with changes made to stSoftware data in real time
THREAD MODE: SINGLE-THREADED

Since:

23 September 2005

Author:

Jason McGrath

Constructor Summary

Constructors

Constructor and Description
ExtDBSyncUpdate(ExtDBSyncTableDef tableDef) constructor

Method Summary

Modifier and Type	Method and Description
boolean	checkDestExists(ExtDBSyncTableDef tableDef, java.util.HashMap valMap) Determines if a record already exists in the destination database
protected void	doInsert(ExtDBSyncTableDef tableDef, java.util.HashMap valMap) Inserts a record into the destination database
void	doUpdate() Updates the destination database based on the action
protected void	doUpdate(ExtDBSyncTableDef tableDef, java.util.HashMap valMap) Updates a record in the destination database
java.lang.String	getAction() the action to be performed
Executor	getExecutor() The st executor (connection)
java.lang.String	getSrcKeyValue() the value of the src key
ExtDBSyncTableDef	getTableDef() the definition of the table
java.lang.String	getTransId() the transaction id that the update was triggered from
java.util.HashMap	getValMap() the table of values
protected void	processDelete(ExtDBSyncTableDef tableDef, java.util.HashMap valMap) Deletes a record from the destination database
protected void	processUpdate(ExtDBSyncTableDef tableDef, java.util.HashMap valMap) Performs an insert or updated based on whether the data already exists in the destination database or not;
void	setData(java.lang.String transId, java.lang.String action, java.util.HashMap valMap) Sets the data to be used by updates
void	setExecutor(Executor executor) Set the st executor (connection)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExtDBSyncUpdate

public ExtDBSyncUpdate(ExtDBSyncTableDef tableDef)

constructor

Parameters:

tableDef - - Table and field definitions

Method Detail

setData

public void setData(java.lang.String transId,
                    java.lang.String action,
                    java.util.HashMap valMap)

Sets the data to be used by updates

Parameters:

transId - - Id of transaction

action - - Action to be performed i.e D for delete

valMap - - Field/value mapping

getAction

public java.lang.String getAction()

the action to be performed

Returns:

the name

getTableDef

public ExtDBSyncTableDef getTableDef()

the definition of the table

Returns:

the name

getTransId

public java.lang.String getTransId()

the transaction id that the update was triggered from

Returns:

the name

getSrcKeyValue

public java.lang.String getSrcKeyValue()

the value of the src key

Returns:

the name

getValMap

public java.util.HashMap getValMap()

the table of values

Returns:

the name

doUpdate

public void doUpdate()
              throws java.lang.Exception

Updates the destination database based on the action

Throws:

java.lang.Exception - A serious error

processUpdate

protected void processUpdate(ExtDBSyncTableDef tableDef,
                             java.util.HashMap valMap)
                      throws java.lang.Exception

Performs an insert or updated based on whether the data already exists in the destination database or not;

Parameters:

tableDef - - Table and field definitions

valMap - - Field/value mapping

Throws:

java.lang.Exception - A serious error

processDelete

protected void processDelete(ExtDBSyncTableDef tableDef,
                             java.util.HashMap valMap)
                      throws java.lang.Exception

Deletes a record from the destination database

Parameters:

tableDef - - Table and field definitions

valMap - - Field/value mapping

Throws:

java.lang.Exception - A serious error

doInsert

protected void doInsert(ExtDBSyncTableDef tableDef,
                        java.util.HashMap valMap)
                 throws java.lang.Exception

Inserts a record into the destination database

Parameters:

tableDef - - Table and field definitions

valMap - - Field/value mapping

Throws:

java.lang.Exception - A serious error

doUpdate

protected void doUpdate(ExtDBSyncTableDef tableDef,
                        java.util.HashMap valMap)
                 throws java.lang.Exception

Updates a record in the destination database

Parameters:

tableDef - - Table and field definitions

valMap - - Field/value mapping

Throws:

java.lang.Exception - A serious error

checkDestExists

public boolean checkDestExists(ExtDBSyncTableDef tableDef,
                               java.util.HashMap valMap)
                        throws java.lang.Exception

Determines if a record already exists in the destination database

Parameters:

tableDef - - database to be updated

valMap - - name of destination table to be updated

Returns:

- true if there is an entry in the destination database that matches supplied field value

Throws:

java.lang.Exception - A serious error

getExecutor

public Executor getExecutor()

The st executor (connection)

Returns:

Executor a connection

setExecutor

public void setExecutor(Executor executor)

Set the st executor (connection)

Parameters:

executor - - a connection