com.toolsverse.etl.core.task.sqlserver

Class BcpTask

Object

com.toolsverse.etl.core.task.common.CmdTask

com.toolsverse.etl.core.task.sqlserver.BcpTask

All Implemented Interfaces:

OnTask, SupportsCodeUpdate, SupportsRecording

Direct Known Subclasses:

MsSqlBcpTask, SybaseBcpTask

public abstract class BcpTask
extends CmdTask

This is abstract wrapper for the task which executes BCP command. BCP is specific for Microsoft Sql Server and Sybase Sql Server.

Since:

1.0

Version:

2.0

See Also:

Task

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTION_ATTR
static String	SQL_ATTR

Fields inherited from class com.toolsverse.etl.core.task.common.CmdTask

CMD_ATTR, ERROR_MASK_ATTR, KEEP_LOG_VAR, SUCCESS_MASK_ATTR

Constructor Summary

Constructors

Constructor and Description
BcpTask()

Method Summary

Modifier and Type	Method and Description
TaskResult	executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario) Executes task after extract or load finished.
abstract String	getServer(EtlConfig config, Task task) Gets the server name.
abstract String	getSql(EtlConfig config, Task task, String datFileName, String params) Gets the sql to execute.

Methods inherited from class com.toolsverse.etl.core.task.common.CmdTask

executeBeforeEtlTask, executeInlineTask, executePreTask, getCodeLanguage, getDefaultValues, getResourceName, getTitle, init, isInlineTask, isPostTask, isPreEtlTask, isPreTask

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SQL_ATTR

public static final String SQL_ATTR

See Also:

Constant Field Values

CONNECTION_ATTR

public static final String CONNECTION_ATTR

See Also:

Constant Field Values

Constructor Detail

BcpTask

public BcpTask()

Method Detail

executePostTask

public TaskResult executePostTask(EtlConfig config,
                                  Task task,
                                  DataSet dataSet,
                                  Scenario scenario)
                           throws Exception

Description copied from interface: OnTask

Executes task after extract or load finished.

Specified by:

executePostTask in interface OnTask

Overrides:

executePostTask in class CmdTask

Parameters:

config - the etl config

task - the task to execute

dataSet - the data set

scenario - the scenario

Returns:

the task result

Throws:

Exception - in case of any error

getServer

public abstract String getServer(EtlConfig config,
                                 Task task)

Gets the server name.

Parameters:

config - the etl config

task - the task

Returns:

the server name

getSql

public abstract String getSql(EtlConfig config,
                              Task task,
                              String datFileName,
                              String params)

Gets the sql to execute.

Parameters:

config - the el config

task - the task

datFileName - the data file name

params - the params

Returns:

the sql