org.pentaho.di.trans.steps.synchronizeaftermerge
Class SynchronizeAfterMergeData
java.lang.Object
org.pentaho.di.trans.step.BaseStepData
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
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
SynchronizeAfterMergeData
public SynchronizeAfterMergeData()
- Default constructor.