Coroutine\PostgreSQL->query

postgresql发送异步非阻塞协程命令

function Coroutine\PostgreSQL->query(resource $connection);

example:

go(function () {
    $pg = new Swoole\Coroutine\PostgreSQL();
    $conn  = $pg -> connect ("host=127.0.0.1 port=5432 dbname=test user=root password=");
    $result = $pg -> query('SELECT * FROM test;');
    $arr = $pg -> fetchAll($result);
    var_dump($arr);
});

返回insert id:

go(function () {
    $pg = new Swoole\Coroutine\PostgreSQL();
    $conn  = $pg -> connect ("host=127.0.0.1 port=5432 dbname=test user=wuzhenyu password=");
    $result = $pg -> query("insert into test (id,text) VALUES (24,'text') RETURNING id ;");
    $arr = $pg -> fetchRow($result);
    var_dump($arr);
});
?>

也可以多次提交query 命令，如begin commit

go(function () {
    $pg = new Swoole\Coroutine\PostgreSQL();
    $conn  = $pg -> connect ("host=127.0.0.1 port=5432 dbname=test user=root password=");
	$pg -> query('BEGIN;');
    $result = $pg -> query('SELECT * FROM test;');
	$arr = $pg -> fetchAll($result);
    $pg -> query('COMMIT;');

    var_dump($arr);
});