Percona XtraDB Cluster. Установка и тестирование

<?php
require dirname(__FILE__).'/config.php';

while(true)
{
$ts=date('r');
// echo «старт\n»;
foreach ($config['db'] as $key=>$val)
{
if(!$db[$key]=mysql_connect($val['host'], $val['user'], $val['password']))
die(«Ошибка подключения к БД: ». var_dump($val)."\n");
}
// echo «подключено\n»;

$tables=array();
$tables_summary=array();

// считываем названия всех таблиц во всех базах
foreach($config['db'] as $key=>$val)
{
$db_=$db[$key];
if(!mysql_query(«USE {$config['scheme']}», $db_))
echo $ts.' Ошибка выбора таблицы: '.mysql_error($db_)."\n";
mysql_query(«SET names 'utf8'», $db_);
if($res=mysql_query(«SHOW TABLES», $db_))
{
while($row=mysql_fetch_row($res))
{
$tables[$key][$row[0]]=true;
$tables_summary[$row[0]]=true;
}
}
else
echo $ts.' '.mysql_error($db_);
}

// echo «проверка таблиц\n»;
// проверяем наличие таблиц во всех базах
foreach($tables_summary as $key=>$val)
{
foreach($config['db'] as $key0=>$val0)
{
if(!@$tables[$key0][$key])
{
echo "$ts В базе $key0 нет таблицы $key. Таблица исключена из проверки.\n";
$tables_summary[$key]=false;
}
}
}

//system(«clear»);

// echo «проверка данных\n»;
foreach($tables_summary as $key=>$val)
{
if($val)
{
// лочим таблицы
foreach($config['db'] as $key0=>$val0)
{
$db_=$db[$key0];
if(mysql_query(«START TRANSACTION», $db_))
mysql_query(«SELECT 1 FROM $key LIMIT 1», $db_); // чтоб запустилась блокировка внутри транзакции надо что-нибудь прочитать из таблицы
if(mysql_error($db_))
echo $ts.' Ошибка блокировки: '.mysql_error($db_)."\n";
}
//echo "$key\t";
unset($id_summary);
unset($id_name);
foreach($config['db'] as $key0=>$val0)
{
if(!isset($id_name))
{
$db_=$db[$key0];
// получаем имя первой колонки
$res=mysql_query(«DESCRIBE $key», $db_);
$row=mysql_fetch_row($res);
$id_name=$row[0];
//echo "$id_name\t";
}

// получаем максимальный id
$res=mysql_query(«SELECT MAX($id_name) FROM $key», $db_);
$row=mysql_fetch_row($res);
if(is_numeric($row[0]))
{
//echo " $row[0] ";
if(!isset($id_summary))
{
$id_summary=$row[0];
}
else
{
if($id_summary<$row[0])
{
echo "$ts В базе $key0 в таблице $key ключ $id_name опережает другие на ".$row[0]-$id_summary."\n";
}
if($id_summary>$row[0])
{
echo "$ts В базе $key0 в таблице $key ключ $id_name отстаёт от других на ".$row[0]-$id_summary."\n";
$id_summary=$row[0]; // В $id_summary попадает значение id, которое есть во всех базах
}
}
}
else
unset($id_summary);
}
if(@$id_summary)
{
// echo «сравнение данных\n»;
$data=array();
foreach($config['db'] as $key0=>$val0)
{
$db_=$db[$key0];
// считываем по одной строке из каждой базы
$res=mysql_query(«SELECT * FROM $key WHERE $id_name='$id_summary' LIMIT 1», $db_);
$row=mysql_fetch_row($res);
if($data)
{
if(is_array($data) && is_array($row))
$result = array_diff($data, $row);
elseif($data!=$row)
$result=true;
if($result || !$row)
{
echo "$ts Есть расхождения в таблице $key, $id_name='$id_summary':\n";
print_r($data);
print_r($row);
}
}
else
{
if($row)
$data=$row;
}
}
}
// разлочиваем таблицы
foreach($config['db'] as $key0=>$val0)
{
$db_=$db[$key0];
mysql_query(«COMMIT», $db_);
if(mysql_error($db_))
echo $ts.' Ошибка разблокировки: '.mysql_error($db_)."\n";
}
}
}
//echo «закрытие соединений\n»;
foreach($config['db'] as $key0=>$val0)
{
mysql_close($db[$key0]);
}
usleep(10);
}