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 Detail
-
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
-
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
-
-