nablarch.etl

Class SqlLoaderBatchlet

java.lang.Object

javax.batch.api.AbstractBatchlet

nablarch.etl.SqlLoaderBatchlet

All Implemented Interfaces:

javax.batch.api.Batchlet

@Named
 @Dependent
public class SqlLoaderBatchlet
extends javax.batch.api.AbstractBatchlet

SQL*Loaderを用いてCSVファイルのデータをワークテーブルに登録するBatchletの実装クラス。

Constructor Summary

Constructors

Constructor and Description
SqlLoaderBatchlet(javax.batch.runtime.context.JobContext jobContext, javax.batch.runtime.context.StepContext stepContext, StepConfig stepConfig, java.io.File inputFileBasePath, java.io.File sqlLoaderControlFileBasePath, java.io.File sqlLoaderOutputFileBasePath) コンストラクタ。

Method Summary

Modifier and Type	Method and Description
java.lang.String	process() SQL*Loaderを実行してCSVファイルのデータをワークテーブルに一括登録する。

Methods inherited from class javax.batch.api.AbstractBatchlet

stop

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlLoaderBatchlet

@Inject
public SqlLoaderBatchlet(javax.batch.runtime.context.JobContext jobContext,
                                 javax.batch.runtime.context.StepContext stepContext,
                                 StepConfig stepConfig,
                                 java.io.File inputFileBasePath,
                                 java.io.File sqlLoaderControlFileBasePath,
                                 java.io.File sqlLoaderOutputFileBasePath)

コンストラクタ。

Parameters:

jobContext - JobContext

stepContext - StepContext

stepConfig - ステップの設定

inputFileBasePath - 入力ファイルのあるディレクトリ

sqlLoaderControlFileBasePath - SQL*Loaderのコントロールファイルが置かれたディレクトリ

sqlLoaderOutputFileBasePath - SQL*Loaderが出力するファイルを置くディレクトリ

Method Detail

process

public java.lang.String process()
                         throws java.lang.Exception

SQL*Loaderを実行してCSVファイルのデータをワークテーブルに一括登録する。

Specified by:

process in interface javax.batch.api.Batchlet

Specified by:

process in class javax.batch.api.AbstractBatchlet

Returns:

実行結果

Throws:

java.lang.Exception - 例外