use AsyncMysql;

// Установка времени ожидания
AsyncMysql::setTimeout(2);

$res = (yield AsyncMysql::query("INSERT INTO `user` (`id`, `mobile`, `password`) VALUES (NULL, '18768122222', '11111')"));

if ($res) {
    $result = $res->getResult();
    $affectedRows = $res->getAffectedRows();
    $id = $res->getInsertId();
}

use AsyncMysql;

public function test() {
    try {
        yield AsyncMysql::begin();

        $res = (yield $this->doTrans());
        if ($res === false) {
            throw new \Exception("need roll back");
        }

        yield AsyncMysql::commit();
    } catch (\Exception $e) {
        yield AsyncMysql::rollback();
    }
}

public function doTrans() {
    $res = (yield AsyncMysql::query("INSERT INTO `user` (`id`, `mobile`, `password`) 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));
    }

    yield true;
}