Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

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

Field Summary

Fields inherited from class org.pentaho.di.job.entry.JobEntryBase
`category_order`

Constructor Summary
`JobEntryMssqlBulkLoad()`
`JobEntryMssqlBulkLoad(JobEntryBase jeb)`
`JobEntryMssqlBulkLoad(String n)`

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 class java.lang.Object
`equals, getClass, hashCode, notify, notifyAll, wait, wait, wait`

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`

Constructor Detail

### JobEntryMssqlBulkLoad

    public JobEntryMssqlBulkLoad(String n)

### JobEntryMssqlBulkLoad

    public JobEntryMssqlBulkLoad()

### JobEntryMssqlBulkLoad

    public JobEntryMssqlBulkLoad(JobEntryBase jeb)

Method Detail

### 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 entry
    `jobMeta` - JobMeta information letting threading back to the JobMeta possible

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD