org.pentaho.di.job.entries.mssqlbulkload
Class JobEntryMssqlBulkLoad
java.lang.Object
org.pentaho.di.job.entry.JobEntryBase
org.pentaho.di.job.entries.mssqlbulkload.JobEntryMssqlBulkLoad
- All Implemented Interfaces:
- Cloneable, org.pentaho.di.core.CheckResultSourceInterface, org.pentaho.di.core.variables.VariableSpace, JobEntryInterface, ResourceHolderInterface
public class JobEntryMssqlBulkLoad
- extends JobEntryBase
- implements Cloneable, JobEntryInterface
This defines a MSSQL Bulk job entry.
- Since:
- Jan-2007
- Author:
- Samatar Hassan
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)
|
int |
getBatchSize()
|
String |
getCodePage()
|
org.pentaho.di.core.database.DatabaseMeta |
getDatabase()
|
String |
getDataFileType()
|
int |
getEndFile()
|
String |
getErrorFilename()
|
String |
getFieldTerminator()
|
String |
getFilename()
|
String |
getFormatFilename()
|
String |
getLineterminated()
|
int |
getMaxErrors()
|
String |
getOrderBy()
|
String |
getOrderDirection()
|
String |
getRealFieldTerminator()
|
String |
getRealLineterminated()
|
String |
getRealOrderBy()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Get a list of all the resource dependencies that the step is depending
on. |
int |
getRowsPerBatch()
|
String |
getSchemaname()
|
String |
getSpecificCodePage()
|
int |
getStartFile()
|
String |
getTablename()
|
org.pentaho.di.core.database.DatabaseMeta[] |
getUsedDatabaseConnections()
This method returns all the database connections that are used by the job entry. |
String |
getXML()
|
boolean |
isAddDatetime()
|
boolean |
isAddFileToResult()
|
boolean |
isCheckConstraints()
|
boolean |
isFireTriggers()
|
boolean |
isKeepIdentity()
|
boolean |
isKeepNulls()
|
boolean |
isTablock()
|
boolean |
isTruncate()
|
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 |
setAddDatetime(boolean adddatetime)
|
void |
setAddFileToResult(boolean addfiletoresultin)
|
void |
setBatchSize(int batchsize)
|
void |
setCheckConstraints(boolean checkconstraints)
|
void |
setCodePage(String codepage)
|
void |
setDatabase(org.pentaho.di.core.database.DatabaseMeta database)
|
void |
setDataFileType(String datafiletype)
|
void |
setEndFile(int endfile)
|
void |
setErrorFilename(String errorfilename)
|
void |
setFieldTerminator(String fieldterminator)
|
void |
setFilename(String filename)
|
void |
setFireTriggers(boolean firetriggers)
|
void |
setFormatFilename(String formatfilename)
|
void |
setKeepIdentity(boolean keepidentity)
|
void |
setKeepNulls(boolean keepnulls)
|
void |
setLineterminated(String lineterminated)
|
void |
setMaxErrors(int maxerrors)
|
void |
setOrderBy(String orderby)
|
void |
setOrderDirection(String orderdirection)
|
void |
setRowsPerBatch(int rowsperbatch)
|
void |
setSchemaname(String schemaname)
|
void |
setSpecificCodePage(String specificcodepage)
|
void |
setStartFile(int startfile)
|
void |
setTablename(String tablename)
|
void |
setTablock(boolean tablock)
|
void |
setTruncate(boolean truncate)
|
Methods inherited from class org.pentaho.di.job.entry.JobEntryBase |
clear, copyVariablesFrom, environmentSubstitute, environmentSubstitute, exportResources, getBooleanValueOfVariable, getConfigId, getDescription, getDialogClassName, 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, 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 |
JobEntryMssqlBulkLoad
public JobEntryMssqlBulkLoad(String n)
JobEntryMssqlBulkLoad
public JobEntryMssqlBulkLoad()
JobEntryMssqlBulkLoad
public JobEntryMssqlBulkLoad(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
setTablename
public void setTablename(String tablename)
setSchemaname
public void setSchemaname(String schemaname)
getSchemaname
public String getSchemaname()
getTablename
public String getTablename()
setMaxErrors
public void setMaxErrors(int maxerrors)
getMaxErrors
public int getMaxErrors()
getBatchSize
public int getBatchSize()
setBatchSize
public void setBatchSize(int batchsize)
getRowsPerBatch
public int getRowsPerBatch()
setRowsPerBatch
public void setRowsPerBatch(int rowsperbatch)
setDatabase
public void setDatabase(org.pentaho.di.core.database.DatabaseMeta database)
getDatabase
public org.pentaho.di.core.database.DatabaseMeta getDatabase()
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
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
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.
setFilename
public void setFilename(String filename)
getFilename
public String getFilename()
- Specified by:
getFilename
in interface JobEntryInterface
- Overrides:
getFilename
in class JobEntryBase
setFieldTerminator
public void setFieldTerminator(String fieldterminator)
setLineterminated
public void setLineterminated(String lineterminated)
setCodePage
public void setCodePage(String codepage)
getCodePage
public String getCodePage()
setSpecificCodePage
public void setSpecificCodePage(String specificcodepage)
getSpecificCodePage
public String getSpecificCodePage()
setFormatFilename
public void setFormatFilename(String formatfilename)
getFormatFilename
public String getFormatFilename()
getFieldTerminator
public String getFieldTerminator()
getLineterminated
public String getLineterminated()
getDataFileType
public String getDataFileType()
setDataFileType
public void setDataFileType(String datafiletype)
getRealLineterminated
public String getRealLineterminated()
getRealFieldTerminator
public String getRealFieldTerminator()
setStartFile
public void setStartFile(int startfile)
getStartFile
public int getStartFile()
setEndFile
public void setEndFile(int endfile)
getEndFile
public int getEndFile()
setOrderBy
public void setOrderBy(String orderby)
getOrderBy
public String getOrderBy()
getOrderDirection
public String getOrderDirection()
setOrderDirection
public void setOrderDirection(String orderdirection)
setErrorFilename
public void setErrorFilename(String errorfilename)
getErrorFilename
public String getErrorFilename()
getRealOrderBy
public String getRealOrderBy()
setAddFileToResult
public void setAddFileToResult(boolean addfiletoresultin)
isAddFileToResult
public boolean isAddFileToResult()
setTruncate
public void setTruncate(boolean truncate)
isTruncate
public boolean isTruncate()
setAddDatetime
public void setAddDatetime(boolean adddatetime)
isAddDatetime
public boolean isAddDatetime()
setFireTriggers
public void setFireTriggers(boolean firetriggers)
isFireTriggers
public boolean isFireTriggers()
setCheckConstraints
public void setCheckConstraints(boolean checkconstraints)
isCheckConstraints
public boolean isCheckConstraints()
setKeepNulls
public void setKeepNulls(boolean keepnulls)
isKeepNulls
public boolean isKeepNulls()
setKeepIdentity
public void setKeepIdentity(boolean keepidentity)
isKeepIdentity
public boolean isKeepIdentity()
setTablock
public void setTablock(boolean tablock)
isTablock
public boolean isTablock()
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