org.pentaho.di.trans.steps.synchronizeaftermerge
Class SynchronizeAfterMergeData

java.lang.Object
  extended by org.pentaho.di.trans.step.BaseStepData
      extended by org.pentaho.di.trans.steps.synchronizeaftermerge.SynchronizeAfterMergeData
All Implemented Interfaces:
StepDataInterface

public class SynchronizeAfterMergeData
extends BaseStepData
implements StepDataInterface

Performs an insert/update/delete depending on the value of a field.

Since:
13-10-2008
Author:
Samatar

Nested Class Summary
 
Nested classes/interfaces inherited from class org.pentaho.di.trans.step.BaseStepData
BaseStepData.StepExecutionStatus
 
Field Summary
 List<Object[]> batchBuffer
           
 boolean batchMode
          Use batch mode or not?
 Map<String,Integer> commitCounterMap
           
 int commitSize
           
 DatabaseMeta databaseMeta
           
 Database db
           
 RowMetaInterface deleteParameterRowMeta
           
 String deleteValue
           
 int indexOfOperationOrderField
           
 int indexOfTableNameField
           
 RowMetaInterface inputRowMeta
           
 RowMetaInterface insertRowMeta
           
 String insertValue
           
 int[] keynrs
           
 int[] keynrs2
           
 boolean lookupFailure
           
 RowMetaInterface lookupParameterRowMeta
           
 RowMetaInterface lookupReturnRowMeta
           
 RowMetaInterface outputRowMeta
           
 Map<String,PreparedStatement> preparedStatements
          Mapping between the SQL and the actual prepared statement.
 String realSchemaName
           
 String realSchemaTable
           
 String realTableName
           
 boolean releaseSavepoint
           
 Savepoint savepoint
           
 boolean specialErrorHandling
           
 String stringErrorKeyNotFound
           
 String stringFieldnames
           
 RowMetaInterface updateParameterRowMeta
           
 String updateValue
           
 int[] valuenrs
           
 
Constructor Summary
SynchronizeAfterMergeData()
          Default constructor.
 
Method Summary
 
Methods inherited from class org.pentaho.di.trans.step.BaseStepData
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, isStopped, setStatus
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.pentaho.di.trans.step.StepDataInterface
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, setStatus
 

Field Detail

db

public Database db

keynrs

public int[] keynrs

keynrs2

public int[] keynrs2

valuenrs

public int[] valuenrs

indexOfTableNameField

public int indexOfTableNameField

indexOfOperationOrderField

public int indexOfOperationOrderField

preparedStatements

public Map<String,PreparedStatement> preparedStatements
Mapping between the SQL and the actual prepared statement. Normally this is only one, but in case we have more then one, it's convenient to have this.


realTableName

public String realTableName

realSchemaName

public String realSchemaName

realSchemaTable

public String realSchemaTable

batchMode

public boolean batchMode
Use batch mode or not?


insertValue

public String insertValue

updateValue

public String updateValue

deleteValue

public String deleteValue

stringErrorKeyNotFound

public String stringErrorKeyNotFound

stringFieldnames

public String stringFieldnames

lookupFailure

public boolean lookupFailure

outputRowMeta

public RowMetaInterface outputRowMeta

inputRowMeta

public RowMetaInterface inputRowMeta

deleteParameterRowMeta

public RowMetaInterface deleteParameterRowMeta

updateParameterRowMeta

public RowMetaInterface updateParameterRowMeta

lookupParameterRowMeta

public RowMetaInterface lookupParameterRowMeta

lookupReturnRowMeta

public RowMetaInterface lookupReturnRowMeta

insertRowMeta

public RowMetaInterface insertRowMeta

commitCounterMap

public Map<String,Integer> commitCounterMap

commitSize

public int commitSize

databaseMeta

public DatabaseMeta databaseMeta

specialErrorHandling

public boolean specialErrorHandling

savepoint

public Savepoint savepoint

releaseSavepoint

public boolean releaseSavepoint

batchBuffer

public List<Object[]> batchBuffer
Constructor Detail

SynchronizeAfterMergeData

public SynchronizeAfterMergeData()
Default constructor.