Package org.pentaho.di.trans.steps.synchronizeaftermerge

Class SynchronizeAfterMergeData

java.lang.Object

org.pentaho.di.trans.step.BaseStepData

org.pentaho.di.trans.step.BaseDatabaseStepData

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

All Implemented Interfaces:

StepDataInterface

public class SynchronizeAfterMergeData
extends BaseDatabaseStepData
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

Fields

Modifier and Type	Field	Description
List<Object[]>	batchBuffer
boolean	batchMode	Use batch mode or not?
Map<String,Integer>	commitCounterMap
int	commitSize
org.pentaho.di.core.database.DatabaseMeta	databaseMeta
org.pentaho.di.core.row.RowMetaInterface	deleteParameterRowMeta
String	deleteValue
int	indexOfOperationOrderField
int	indexOfTableNameField
org.pentaho.di.core.row.RowMetaInterface	inputRowMeta
org.pentaho.di.core.row.RowMetaInterface	insertRowMeta
String	insertValue
int[]	keynrs
int[]	keynrs2
boolean	lookupFailure
org.pentaho.di.core.row.RowMetaInterface	lookupParameterRowMeta
org.pentaho.di.core.row.RowMetaInterface	lookupReturnRowMeta
org.pentaho.di.core.row.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
boolean	supportsSavepoints
org.pentaho.di.core.row.RowMetaInterface	updateParameterRowMeta
String	updateValue
int[]	valuenrs

Fields inherited from class org.pentaho.di.trans.step.BaseDatabaseStepData

db

Constructor Summary

Constructors

Constructor	Description
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

clone, equals, finalize, 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 Details

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 org.pentaho.di.core.row.RowMetaInterface outputRowMeta

inputRowMeta

public org.pentaho.di.core.row.RowMetaInterface inputRowMeta

deleteParameterRowMeta

public org.pentaho.di.core.row.RowMetaInterface deleteParameterRowMeta

updateParameterRowMeta

public org.pentaho.di.core.row.RowMetaInterface updateParameterRowMeta

lookupParameterRowMeta

public org.pentaho.di.core.row.RowMetaInterface lookupParameterRowMeta

lookupReturnRowMeta

public org.pentaho.di.core.row.RowMetaInterface lookupReturnRowMeta

insertRowMeta

public org.pentaho.di.core.row.RowMetaInterface insertRowMeta

commitCounterMap

public Map<String,Integer> commitCounterMap

commitSize

public int commitSize

databaseMeta

public org.pentaho.di.core.database.DatabaseMeta databaseMeta

specialErrorHandling

public boolean specialErrorHandling

savepoint

public Savepoint savepoint

releaseSavepoint

public boolean releaseSavepoint

supportsSavepoints

public boolean supportsSavepoints

batchBuffer

public List<Object[]> batchBuffer

Constructor Details

SynchronizeAfterMergeData

public SynchronizeAfterMergeData()

Default constructor.