FuelPHPでインポートのバッチ処理をする（考え方だけ）

頭の整理のためのメモなので、考え方だけです。
実際のコードに関しては、記載しません。

要求

1. 途中で何らかエラーがあったらすべてをロールバック
2. エラー内容はすべて表示

どういう流れにするか

最初にバリデーションをしてから、最後にsaveをする。

プログラムイメージ

<?php
// この前にはファイルオープンやらなにやら前処理があるはず

foreach ($datas as $i => $data)
{
	try
	{
		$model = Model_Hoge()::forge($data);
		$model->validate();
		$models[] = $model;
	}
	catch (Exception_ValidateError $e)
	{
		$errors[] = $e->show_errors();
	}
}

// エラー時に格納したものがなければ保存
if (count($errors) === 0)
{
	foreach ($models as $model)
	{
		$model->save();
	}
}

おそらくこれで要求は満たせる

1:Nの関連性があるモデルはどうするか

1:Nの関連性があるモデルがある場合は、どうしたらいいのか。

プログラムイメージ

<?php
// この前にはファイルオープンやらなにやら前処理があるはず

// Model_Hoge (1) -> Model_Fuga (N) という継承とする

foreach ($datas as $data)
{
	try
	{
		// hogeのバリデーション
		$hoge = Model_Hoge::forge($data);
		$hoge->validate();
		
		// fugaのバリデーション
		$fuga = Model_Fuga::forge($data);
		$fuga->validate();
		
		// 問題なければ親のモデルにセット
		$hoge->fuga[] = $fuga;

		// 最後にsaveするので、一旦格納
		$models[] = $hoge;
	}
	catch (Exception_ValidateError $e)
	{
		$errors[] = $e->show_errors();
	}
}

if (count($errors) === 0)
{
	foreach ($models as $model)
	{
		// まとめてsaveする
		$model->save();
	}
}

こんな感じでできるんじゃないかなー。

8/28追記
以下でも良い。というか以下の方がやりやすかった。

別案

<?php
// この前にはファイルオープンやらなにやら前処理があるはず

// Model_Hoge (1) -> Model_Fuga (N) という継承とする

DB::start_transaction();

foreach ($datas as $data)
{
	try
	{
		// hogeのバリデーション
		$hoge = Model_Hoge::forge($data);
		$hoge->validate();
		
		// fugaのバリデーション
		$fuga = Model_Fuga::forge($data);
		$fuga->validate();
		
		// 問題なければ親のモデルにセット
		$hoge->fuga[] = $fuga;

		$hoge->save();

		// ここでsaveしているので
		// 同じ内容を入れたくない場合は、2週目以降検索すればよい
	}
	catch (Exception_ValidateError $e)
	{
		$errors[] = $e->show_errors();
	}
}

if (count($errors) === 0)
{
	DB::commit_transaction();
}
else
{
	DB::rollback_transaction();
}