AsyncMysql::query($sql, $usePool = true)

具体使用

异步Mysql事务处理

与传统事务一样使用，只是需要加上yield关键词，以异步方式调用

    public function test()
    {
        try {
            yield AsyncMysql::begin();
            $res = (yield $this->doTrans());
                throw new \Exception("need roll back");
            }
            yield AsyncMysql::commit();
        } catch (\Exception $e) {
            yield AsyncMysql::rollback();
        }
    }
    public function doTrans()
    {
        VALUES (NULL, '187681343332', '11111')"));
        if ($res) {
            $result = $res->getResult();
            $affectedRows = $res->getAffectedRows();
            $id = $res->getInsertId();
            $res = (yield AsyncMysql::query("SELECT * FROM `user` WHERE id = {$id}"));
            $res = (yield AsyncMysql::query("SELECT * FROM `user`"));
            $res = (yield AsyncMysql::query("DELETE FROM `user` WHERE id = {$id}", false));
        }