<?php
define('DEBUG', 'on');
define('WEBPATH', realpath(__DIR__ . '/..'));
//包含框架入口文件
require WEBPATH . '/libs/lib_config.php';

$config = array(
    'host' => '10.10.2.38',
    'user' => 'root',
    'password' => 'root',
    'database' => 'chelun',
);

$pool = new Swoole\Async\MySQL($config, 20);
//$sql1 = "INSERT INTO `test`.`userinfo`
// (`id`, `name`, `passwd`, `regtime`, `lastlogin_ip`)
// VALUES ('0', 'womensss', 'world', '2015-06-15 13:50:34', '4')";
//$sql2 = "update userinfo set name='rango' where id = 16";
$sql3 = "show tables";

for ($i = 0; $i < 200; $i++)
{
    $pool->query($sql3, function (swoole_mysql $mysqli, $result) use ($i)
    {
        if ($result === true)
        {
            echo "insert_id={$mysqli->insert_id}, _affected_rows={$mysqli->affected_rows}\n";
        }
        elseif ($result === false)
        {
            echo "errno={$mysqli->errno}, error={$mysqli->error}\n";
        }
        else
        {
            //var_dump($result);
        }
        echo "$i\t" . str_repeat('-', 120) . "\n";
        //usleep(10000);
    });
}