psdi.app.recontask.engine

Class ReconComparisonProcessor

java.lang.Object

psdi.app.recontask.engine.ReconComparisonProcessor

public class ReconComparisonProcessor
extends java.lang.Object

Performs reconciliation comparison processing

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map[][]	linkedPairs the pairs linked during the link phase
protected boolean	writeFailures write the failed reconciliation results?
protected boolean	writeSuccesses write the successful reconciliation results?

Constructor Summary

Constructors

Constructor and Description
ReconComparisonProcessor(ReconInfo reconInfo, java.util.Map[][] linkedPairs)

Method Summary

Modifier and Type	Method and Description
void	calculateResultOption() Retrieves the result type in which the reconciliation comparison results are to be reported.
void	compare() Performs complete, end-to-end reconciliation comparison processing
protected void	removeDuplicated(java.util.List results)
protected java.util.List	retrieveComparisonRules() Retrieves the comparison rules for the given reconciliation task
protected void	writeResults(java.util.List results)

Methods inherited from class java.lang.Object

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

Field Detail

linkedPairs

protected java.util.Map[][] linkedPairs

the pairs linked during the link phase

linkedPairs[i][0] is a map uid and key values for the root of data set1

linkedPairs[i][1] is a map uid and key values for the root of data set2

writeSuccesses

protected boolean writeSuccesses

write the successful reconciliation results?

writeFailures

protected boolean writeFailures

write the failed reconciliation results?

Constructor Detail

ReconComparisonProcessor

public ReconComparisonProcessor(ReconInfo reconInfo,
                                java.util.Map[][] linkedPairs)
                         throws MXException,
                                java.rmi.RemoteException

Parameters:

reconTask - the reconciliation task configuration

linkedPairs - the linked pairs, linkedPairs[i][0] is the uid and key values for data set1 and linkedPairs[i][1] is the uid and key values for data set2

Throws:

MXException

java.rmi.RemoteException

Method Detail

calculateResultOption

public void calculateResultOption()
                           throws MXException,
                                  java.rmi.RemoteException

Retrieves the result type in which the reconciliation comparison results are to be reported. Valid types are All, Successful, and Failed.

Throws:

MXException

java.rmi.RemoteException

compare

public void compare()
             throws java.rmi.RemoteException,
                    MXException,
                    java.sql.SQLException

Performs complete, end-to-end reconciliation comparison processing

Throws:

java.rmi.RemoteException

MXException

java.sql.SQLException

removeDuplicated

protected void removeDuplicated(java.util.List results)

retrieveComparisonRules

protected java.util.List retrieveComparisonRules()
                                          throws MXException,
                                                 java.rmi.RemoteException,
                                                 java.sql.SQLException

Retrieves the comparison rules for the given reconciliation task

Parameters:

taskMbo - The reconciliation task for which to retrieve comparison rules

Throws:

MXException - If fails to obtain reconciliation business object

java.rmi.RemoteException - If fails to obtain reconciliation business object

java.sql.SQLException

writeResults

protected void writeResults(java.util.List results)
                     throws java.rmi.RemoteException,
                            MXException,
                            java.sql.SQLException

Throws:

java.rmi.RemoteException

MXException

java.sql.SQLException