CakePHPのModel->query()でSQLを何回も発行するようなバッチを作る際の注意点

ほとんどこんな事例ないと思うけど、メモ。

CakePHPでバッチを作る際に、Model->query()でSQLを何回も発行するような組み方をしてしまうと、メモリが足りなくて処理落ちする事がある。まぁ、そもそもこんなバッチ組んでるのどうなの？って思うけど。

<?php
class HogeShell extends AppShell {
	public $uses  = array('Hoge');
	public function main() {
		for ($i=0; $i<100; $i++) {
			// メモリ足りなくて死ぬ
			$result = $this->Hoge->query('...');
		}
	}
}

前提

• CakePHP 2.4.x

Model->find() などはクエリキャッシュできる

Modelにはセッション単位でのクエリキャッシュする機能がある。Model-> cacheQueries に true を設定すると、クエリキャッシュが有効になる。デフォルトでは無効。あくまでセッション単位なので、活用するシーンはあまりなさそうだけど。

Hoge.php

<?php
class Hoge extends AppModel {
	public $cacheQueries = true;
}

Model->query()はデフォルトでクエリキャッシュする

まさにこれがハマリポイント。

query() は本質的に分離された機能のため、$Model->cacheQueries は無視されます。クエリ実行のキャッシュしないようにするには、2つ目の引数にfalseを指定してください。query($query, $cachequeries = false)

マニュアルにしっかり書かれているが、特別扱いのため、別個で指定してあげないとNG。それにしてもなぜModel->query()はデフォルトでクエリキャッシュが有効なのか。謎。

lib/Cake/Model/Datasource/DboSource.php

public function fetchAll($sql, $params = array(), $options = array()) {
		if (is_string($options)) {
			$options = array('modelName' => $options);
		}
		if (is_bool($params)) {
			$options['cache'] = $params;
			$params = array();
		}

		// ここで無指定ならデフォルトで有効にしている…
		$options += array('cache' => true);
		$cache = $options['cache'];

		// snip
}

なので、クエリキャッシュする必要がなく、何回もquery()を実行する場合は、引数に false を渡してあげよう。

<?php
class HogeShell extends AppShell {
	public $uses  = array('Hoge');
	public function main() {
		for ($i=0; $i<100; $i++) {
			// メモリ足りて無事終わる
			$result = $this->Hoge->query('...', false);
		}
	}
}

そして、こういったバッチを書いている状況の場合、もっと改善できないか検討しよう。