package jp.terasoluna.batch.functionsample.b002;

import jp.terasoluna.fw.batch.blogic.AbstractTransactionBLogic;
import jp.terasoluna.fw.batch.blogic.vo.BLogicParam;
import jp.terasoluna.fw.batch.dao.support.BatchUpdateSupport;
import jp.terasoluna.fw.batch.dao.support.BatchUpdateSupportImpl;
import jp.terasoluna.fw.dao.UpdateDAO;
import jp.terasoluna.fw.file.dao.FileLineIterator;
import jp.terasoluna.fw.file.dao.FileQueryDAO;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;

/**
 * ファイル-DB関連ジョブ（バッチ更新）のサンプル<br>
 * <br>
 * 事前準備：C:\tmp配下にinput.csvファイルを配置すること<br>
 * <br>
 * サンプル内容：ファイルを読み込み、DBにバッチ更新するサンプル。
 */
public class B002003BLogic extends AbstractTransactionBLogic {

    private Log log = LogFactory.getLog(B002003BLogic.class);

    private static final int BATCH_NORMAL_END = 0;

    @Autowired
    @Qualifier("csvFileQueryDAO")
    private FileQueryDAO csvFileQueryDAO = null;

    @Autowired
    @Qualifier("updateDAO")
    private UpdateDAO updateDAO = null;

    @Override
    public int doMain(BLogicParam arg0) {

        // EMPLOYEEテーブルの初期化
        updateDAO.execute("B002003.deleteEmployees", null);

        // バッチ更新サポート
        BatchUpdateSupport batchUpdate = new BatchUpdateSupportImpl();

        FileLineIterator<CsvRecord> recordIterator = csvFileQueryDAO.execute(
                "C:\\tmp\\input.csv", CsvRecord.class);

        try {

            while (recordIterator.hasNext()) {
                CsvRecord record = recordIterator.next();
                log.info("ID:" + record.getId() + " FIMILYNAME:"
                        + record.getFamilyName() + " FIRSTNAME:"
                        + record.getFirstName() + " AGE:" + record.getAge());

                // バッチ更新リストに登録
                batchUpdate.addBatch("B002003.insertEmployees", record);

                // 1000件ごとにバッチ更新を実行
                if (batchUpdate.size() >= 1000) {
                    // バッチ更新実行
                    batchUpdate.executeBatch(updateDAO);
                }
            }
        } finally {
            // ファイルのクローズ
            recordIterator.closeFile();
        }

        // バッチ更新実行
        batchUpdate.executeBatch(updateDAO);

        // 正常終了
        return BATCH_NORMAL_END;
    }

}
