|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.pentaho.di.trans.step.BaseStep
org.pentaho.di.trans.steps.sql.ExecSQL
public class ExecSQL
Execute one or more SQL statements in a script, one time or parameterised (for every row)
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary |
---|
Fields inherited from class org.pentaho.di.trans.step.BaseStep |
---|
category_order, errorRowSet, first, init, inputRowSets, linesInput, linesOutput, linesRead, linesRejected, linesSkipped, linesUpdated, linesWritten, outputRowSets, paused, remoteInputSteps, remoteOutputSteps, statusDesc, steps, stopped, terminator, terminator_rows, thr, waiting |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
ExecSQL(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
|
Method Summary | |
---|---|
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
static org.pentaho.di.core.RowMetaAndData |
getResultRow(org.pentaho.di.core.Result result,
String upd,
String ins,
String del,
String read)
|
boolean |
init(StepMetaInterface smi,
StepDataInterface sdi)
Initialise and do work where other steps need to wait for... |
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process one row. |
void |
run()
Run is where the action happens in a step... |
void |
stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.pentaho.di.trans.step.StepInterface |
---|
addRowListener, addStepListener, cleanup, getCopy, getErrors, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesUpdated, getLinesWritten, getOutputRowSets, getPartitionID, getRow, getRowListeners, getStepID, getStepMeta, getStepname, initBeforeStart, isAlive, isMapping, isPartitioned, isStopped, markStart, markStop, pauseRunning, putRow, removeRowListener, resumeRunning, setErrors, setLinesRejected, setOutputDone, setPartitionID, start, stopAll |
Constructor Detail |
---|
public ExecSQL(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)
Method Detail |
---|
public static final org.pentaho.di.core.RowMetaAndData getResultRow(org.pentaho.di.core.Result result, String upd, String ins, String del, String read)
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
StepInterface
processRow
in interface StepInterface
processRow
in class BaseStep
smi
- The metadata to work withsdi
- The temporary working data to work with (database connections, resultsets, caches, temporary variables, etc.)
org.pentaho.di.core.exception.KettleException
public void dispose(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
dispose
in interface StepInterface
dispose
in class BaseStep
smi
- The metadata to work withsdi
- The data to dispose ofpublic void stopRunning(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
stopRunning
in interface StepInterface
stopRunning
in class BaseStep
smi
- The metadata that might be needed by the step to stop running.sdi
- The interface to the step data containing the connections, resultsets, open files, etc.
org.pentaho.di.core.exception.KettleException
- in case something goes wrongpublic boolean init(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
init
in interface StepInterface
init
in class BaseStep
smi
- The metadata to work withsdi
- The data to initializepublic void run()
StepInterface
run
in interface Runnable
run
in interface StepInterface
run
in class Thread
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |