org.pentaho.di.job.entries.sql
Class JobEntrySQL
java.lang.Object
org.pentaho.di.job.entry.JobEntryBase
org.pentaho.di.job.entries.sql.JobEntrySQL
- All Implemented Interfaces:
- Cloneable, org.pentaho.di.core.CheckResultSourceInterface, org.pentaho.di.core.variables.VariableSpace, JobEntryInterface, ResourceHolderInterface
public class JobEntrySQL
- extends JobEntryBase
- implements Cloneable, JobEntryInterface
This defines an SQL job entry.
- Since:
- 05-11-2003
- Author:
- Matt
Method Summary |
void |
check(List<org.pentaho.di.core.CheckResultInterface> remarks,
JobMeta jobMeta)
Support for overrides not having to put in a check method |
Object |
clone()
|
boolean |
evaluates()
check whether or not this job entry evaluates. |
org.pentaho.di.core.Result |
execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
org.pentaho.di.core.database.DatabaseMeta |
getDatabase()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Get a list of all the resource dependencies that the step is depending
on. |
String |
getSQL()
|
String |
getSQLFilename()
|
boolean |
getSQLFromFile()
|
org.pentaho.di.core.database.DatabaseMeta[] |
getUsedDatabaseConnections()
This method returns all the database connections that are used by the job entry. |
boolean |
getUseVariableSubstitution()
|
String |
getXML()
|
boolean |
isUnconditional()
|
void |
loadRep(Repository rep,
long id_jobentry,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
loadXML(Node entrynode,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
|
void |
saveRep(Repository rep,
long id_job)
|
void |
setDatabase(org.pentaho.di.core.database.DatabaseMeta database)
|
void |
setSQL(String sql)
|
void |
setSQLFilename(String sqlfilename)
|
void |
setSQLFromFile(boolean sqlfromfilein)
|
void |
setUseVariableSubstitution(boolean subs)
|
Methods inherited from class org.pentaho.di.job.entry.JobEntryBase |
clear, copyVariablesFrom, environmentSubstitute, environmentSubstitute, exportResources, getBooleanValueOfVariable, getConfigId, getDescription, getDialogClassName, getFilename, getHolderType, getID, getJobEntryType, getName, getParentVariableSpace, getPluginID, getRealFilename, getSQLStatements, getSQLStatements, getTypeCode, getTypeCode, getTypeDesc, getTypeDesc, getTypeId, getVariable, getVariable, hasChanged, initializeVariablesFrom, injectVariables, isDummy, isEvaluation, isFTP, isHTTP, isJob, isMail, isSFTP, isShell, isSpecial, isStart, isTransformation, listVariables, loadXML, parseRepositoryObjects, resetErrorsBeforeExecution, setChanged, setChanged, setConfigId, setDescription, setID, setJobEntryType, setName, setParentVariableSpace, setPluginID, setVariable, shareVariablesWith, toString |
Methods inherited from interface org.pentaho.di.job.entry.JobEntryInterface |
clear, exportResources, getConfigId, getDescription, getDialogClassName, getFilename, getID, getJobEntryType, getName, getPluginID, getRealFilename, getSQLStatements, getSQLStatements, getTypeCode, hasChanged, isDummy, isEvaluation, isJob, isMail, isShell, isSpecial, isStart, isTransformation, resetErrorsBeforeExecution, setChanged, setChanged, setConfigId, setDescription, setID, setJobEntryType, setName, setPluginID |
JobEntrySQL
public JobEntrySQL(String n)
JobEntrySQL
public JobEntrySQL()
JobEntrySQL
public JobEntrySQL(JobEntryBase jeb)
clone
public Object clone()
- Specified by:
clone
in interface JobEntryInterface
- Overrides:
clone
in class JobEntryBase
getXML
public String getXML()
- Specified by:
getXML
in interface JobEntryInterface
- Overrides:
getXML
in class JobEntryBase
loadXML
public void loadXML(Node entrynode,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
throws org.pentaho.di.core.exception.KettleXMLException
- Specified by:
loadXML
in interface JobEntryInterface
- Throws:
org.pentaho.di.core.exception.KettleXMLException
loadRep
public void loadRep(Repository rep,
long id_jobentry,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
loadRep
in interface JobEntryInterface
- Overrides:
loadRep
in class JobEntryBase
- Throws:
org.pentaho.di.core.exception.KettleException
saveRep
public void saveRep(Repository rep,
long id_job)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
saveRep
in interface JobEntryInterface
- Overrides:
saveRep
in class JobEntryBase
- Throws:
org.pentaho.di.core.exception.KettleException
setSQL
public void setSQL(String sql)
getSQL
public String getSQL()
getSQLFilename
public String getSQLFilename()
setSQLFilename
public void setSQLFilename(String sqlfilename)
getUseVariableSubstitution
public boolean getUseVariableSubstitution()
setUseVariableSubstitution
public void setUseVariableSubstitution(boolean subs)
setSQLFromFile
public void setSQLFromFile(boolean sqlfromfilein)
getSQLFromFile
public boolean getSQLFromFile()
setDatabase
public void setDatabase(org.pentaho.di.core.database.DatabaseMeta database)
getDatabase
public org.pentaho.di.core.database.DatabaseMeta getDatabase()
execute
public org.pentaho.di.core.Result execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
- Specified by:
execute
in interface JobEntryInterface
evaluates
public boolean evaluates()
- Description copied from class:
JobEntryBase
- check whether or not this job entry evaluates.
- Specified by:
evaluates
in interface JobEntryInterface
- Overrides:
evaluates
in class JobEntryBase
- Returns:
- true if the job entry evaluates
isUnconditional
public boolean isUnconditional()
- Specified by:
isUnconditional
in interface JobEntryInterface
- Overrides:
isUnconditional
in class JobEntryBase
getUsedDatabaseConnections
public org.pentaho.di.core.database.DatabaseMeta[] getUsedDatabaseConnections()
- Description copied from class:
JobEntryBase
- This method returns all the database connections that are used by the job entry.
- Specified by:
getUsedDatabaseConnections
in interface JobEntryInterface
- Overrides:
getUsedDatabaseConnections
in class JobEntryBase
- Returns:
- an array of database connections meta-data.
Return an empty array if no connections are used.
getResourceDependencies
public List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
- Description copied from class:
JobEntryBase
- Get a list of all the resource dependencies that the step is depending
on.
- Specified by:
getResourceDependencies
in interface JobEntryInterface
- Overrides:
getResourceDependencies
in class JobEntryBase
- Returns:
- a list of all the resource dependencies that the step is
depending on
check
public void check(List<org.pentaho.di.core.CheckResultInterface> remarks,
JobMeta jobMeta)
- Description copied from class:
JobEntryBase
- Support for overrides not having to put in a check method
- Specified by:
check
in interface JobEntryInterface
- Overrides:
check
in class JobEntryBase
- Parameters:
remarks
- CheckResults from checking the job entryjobMeta
- JobMeta information letting threading back to the JobMeta possible