DB_Tableで利用されているMDB2についてのメモ。

DB_TableではバックエンドのコネクションにMDB2を利用することができる。
この辺いろいろ複雑だけどメモメモ。

実際にDB_Tableを利用してselectとか発行すると
DB/Table/Base.phpの

// get the result
if ($this->backend == 'mdb2') {
$result = $db->extended->$method($sql, null, $params);   // この辺
} else {
switch ($method) {

この辺が呼ばれる。
これの$db->extendedって MDB2/Extended.phpで、

function getAll($query, $types = null, $params = array(),
$param_types = null, $fetchmode = MDB2_FETCHMODE_DEFAULT,
$rekey = false, $force_array = false, $group = false)
{
$db =& $this->getDBInstance();
if (PEAR::isError($db)) {
return $db;
}
settype($params, 'array');
if (empty($params)) {
return $db->queryAll($query, $types, $fetchmode, true, $force_array\
, $group);
}

この辺が呼ばれる。getDBInstance()はMDB2.phpにあって、

function &getDBInstance()
{
if (isset($GLOBALS['_MDB2_databases'][$this->db_index])) {
$result =& $GLOBALS['_MDB2_databases'][$this->db_index];
} else {
$result =& MDB2::raiseError(MDB2_ERROR_NOT_FOUND, null, null,
'could not find MDB2 instance');
}
return $result;
}

こんな感じ。
で、グローバル変数の$GLOBALS[‘_MDB2_databases’]とかってある。
ほんでこの$dbを使ってqueryAll()を呼び出してる。
ｑｕｅｒｙＡｌｌはExtended.phpにあって、

function queryAll($query, $types = null, $fetchmode = MDB2_FETCHMODE_DEFAUL
T,
$rekey = false, $force_array = false, $group = false)
{
$result = $this->query($query, $types);
if (!MDB2::isResultCommon($result)) {
return $result;
}

$all = $result->fetchAll($fetchmode, $rekey, $force_array, $group);
$result->free();
return $all;
}

// }}}
}

こんな感じ。
そんで$this->queryはMDB2.phpにあって

function &query($query, $types = null, $result_class = true, $result_wrap_class = false)
{
$offset = $this->offset;
$limit = $this->limit;
$this->offset = $this->limit = 0;
$query = $this->_modifyQuery($query, false, $limit, $offset);

$connection = $this->getConnection();  // このへん！
if (PEAR::isError($connection)) {
return $connection;
}

$result =& $this->_doQuery($query, false, $connection, $this->database_name);
if (PEAR::isError($result)) {
return $result;
}

$result =& $this->_wrapResult($result, $types, $result_class, $result_wrap_class, $limit, $offset);
return $result;
}

で、これの”このへん！”のところでgetConnection()してるけどコイツがMDB2.phpの

function getConnection()
{
$result = $this->connect();
if (PEAR::isError($result)) {
return $result;
}
return $this->connection;
}

これで、$this->connect()がMDB2/Driver/mysql.phpとかにあって

function connect()
{
if (is_resource($this->connection)) {
//if (count(array_diff($this->connected_dsn, $this->dsn)) == 0
if (MDB2::areEquals($this->connected_dsn, $this->dsn)
&& $this->opened_persistent == $this->options['persistent']
) {
return MDB2_OK;
}
$this->disconnect(false);
}

$connection = $this->_doConnect(
$this->dsn['username'],

このへんにありますよ！ってお話！

疲れたー。

DB_Tableを利用しながらコネクションを切ったらどうなるか調べてみた。

立ち上げっぱなしになるデーモンでは、インスタンスの生成にコストがかかるので、mysqlのコネクションを張りっぱなしでやっていた。

でもそうなるとさすがに待ち受け側でコネクション数がかなりいっぱいになってしまうので切ってやらないといけない状況に。

某所で、”LL(Lightweight Languagage) なんて再接続のコスト安いんだから、javaみたいにコネクションプーリングとか考えずに毎度毎度つないじゃえばいいんだよ”、というアドバイスを小耳に挟んだ物で。

で、利用していると、DB_Tableでは最初に突っ込んであげたMDB2のインスタンスがdisconnect()されてても、なんか適当につなぎ直してくれるらしい。

そこでまずは再接続にどれぐらいのコストがかかるか検証してみた。

$dsn = 'mysql://dbuser:[email protected]/db';
$conn =& MDB2::connect($dsn);
$tbl = new hoge_DBTable($conn, 'db.hoge', 'safe');

define('MAX_COUNT', 10000);
$starttime = microtime(true);
for($i=0; $i < MAX_COUNT; $i++){
$sql = array('select'=>'data');
if(PEAR::isError($rows = $tbl->select($sql))){
die;
}
//var_dump($rows);
}
echo ($res1 = microtime(true) - $starttime)."\n";
$starttime = microtime(true);
for($i=0; $i < MAX_COUNT; $i++){
$conn->disconnect();
$sql = array('select'=>'data');
if(PEAR::isError($rows = $tbl->select($sql))){
die;
}
}
echo ($res2 = microtime(true) - $starttime)."\n";
echo $res2/$res1 . "\n";

で、これの結果

5.72950482368  // つなぎっぱなしで10000回
111.679533958 // 切りまくって10000回
19.4920045266 // 時間的な比率

かなり時間がかかってしまった。

とくにクライアント側ではなくてサーバ側の負担が大きくて、CPU使用率が50%を超えてる状況。場合によってはこれがサーバの負担になることも十分考えられる。