Swoole 协程 MySQL 客户端与异步回调 MySQL 客户端的对比

Swoole 协程 MySql 客户端与 异步回调 MySql 客户端的对比

为何要对比这两种不一样模式的客户端？

异步 MySQL 回调客户端是虽然在 Swoole 1.8.6 版本就已经发布了，
可是异步回调的层层嵌套，让编码变得很别扭。
现在 Swoole 4.3 版本都已经发布了，而且已经支持协程化的 MySQL 客户端，
这意味着能够彻底采用同步编码的模式，来进行程序开发了，
对于开发者来讲这是一个大好的消息。
并且在 Swoole 4.3 版本以后，就已经移出了异步回调客户端，
官方也一直推荐使用协程客户端进行编码。

Swoole 协程 Mysql 客户端

从 Swoole 4.0 版本开始提供了完整的协程，应用层可使用彻底的同步模式的编程方式，底层自动实现异步IO。
Swoole 的 MySQL 协程客户端须要在协程的上下文环境下执行。
具体的使用方法直接看下面的示例便可。

• 链接 Mysql 协程客户端

co::create(function() {
    $swoole_mysql = new Swoole\Coroutine\MySQL();
    $swoole_mysql->connect([
        'host' => 'mysql',
        'port' => 3306,
        'user' => 'root',
        'password' => 'root',
        'database' => 'fastadmin',
    ]);
    $res = $swoole_mysql->query('select sleep(1)');
    
    // 新增
    // 更新
    // 查询
    // 删除
    // 事务操做
    // ......
});

• 新增操做

co::create(function() {
    $stmt = $db->prepare('INSERT INTO runoob_tbl (runoob_title, runoob_author, submission_date) VALUES (?, ?, ?');
    if ($stmt == false){
        var_dump($db->errno, $db->error);
    } else {
        $ret2 = $stmt->execute(['学习 PHP', '学习 PHP', date("Y-m-d")]);
        var_dump($ret2);
    }
});

• 查询操做

co::create(function() {
   $res = $swoole_mysql->query('SELECT * FROM runoob_tbl WHERE runoob_id=1');
    if($res === false) {
        return;
    }
    foreach ($res as $value) {
        echo $value['runoob_title'];
    } 
});

• 更新操做

co::create(function() {
    $stmt = $db->prepare('UPDATE runoob_tbl SET runoob_title=? WHERE runoob_id=?');
    if ($stmt == false){
        var_dump($db->errno, $db->error);
    } else {
        $ret2 = $stmt->execute(['学习 C++', 1]);
        var_dump($ret2);
    }
});

• 删除操做

co::create(function() {
    $stmt = $db->prepare('DELETE FROM runoob_tbl WHERE runoob_id=1');
    if ($stmt == false){
        var_dump($db->errno, $db->error);
    } else {
        $ret2 = $stmt->execute(['学习 C++', 1]);
        var_dump($ret2);
    }
});

• 事务操做

co::create(function() {
    $db->begin();

    $stmt = $db->prepare('INSERT INTO runoob_tbl (runoob_title, runoob_author, submission_date) VALUES (?, ?, ?');
    if ($stmt == false){
        var_dump($db->errno, $db->error);
    } else {
        $ret2 = $stmt->execute(['学习 PHP', '学习 PHP', date("Y-m-d")]);
        var_dump($ret2);
    }
    
    $stmt = $db->prepare('UPDATE runoob_tbl SET runoob_title=? WHERE runoob_id=?');
    if ($stmt == false){
        var_dump($db->errno, $db->error);
        $db->rollback();
    } else {
        $ret2 = $stmt->execute(['学习 C++', 1]);
        var_dump($ret2);
    }
    
    $db->commit();  
});

Swoole 异步回调 Mysql 客户端

Swoole 在 1.8.6 版本提供了全新的异步 MySQL 客户端，底层实现了 MySQL 通讯协议。
无需依赖其余第三方库，如 libmysqlclient, mysqlnd, mysqli 等。
无需经过 --enable-async-mysql 编译参数开启。
Swoole 的 Mysql 异步回调客户端的使用示例直接看下文便可。

注：异步回调客户端在 Swoole 4.3 版本已经被移出了（标志着已通过时了），建议使用协程客户端。

• 链接 Mysql 数据库

$db = new swoole_mySQL();

$server = [
    'host' => 'mysql',
    'port' => 3306,
    'user' => 'root',
    'password' => 'root',
    'database' => 'fastadmin',
    'charset'  => 'utf8',
    'timeout'  => 2
];

$db->connect($server, function ($db, $r) {
    if ($r === false) {
        var_dump($db->connect_errno, $db->connect_errno);
        die();
    }
    
    // 新增
    // 更新
    // 查询
    // 删除
    // 事务操做
    // ......
)

• 新增操做

// 新增
$sql = "INSERT INTO runoob_tbl (runoob_title, runoob_author, submission_date) VALUES (\"学习 PHP\", \"菜鸟教程\", NOW())";
$db->query($sql, function(swoole_mySQL $db, $r) {
    if ($r === false) {
        echo "新增数据失败, 错误信息: " . $db->error . ", 错误码: " . $db->errno . "\n";
    } elseif ($r === true) {
        echo "新增数据成功, ID为：" . $db->insert_id, ", 影响行数: " . $db->affected_rows . "\n";
    }
    $db->close();
});

• 更新操做

// 修改
$sql = "UPDATE runoob_tbl SET runoob_title='学习 C++' WHERE runoob_id=1";
$db->query($sql, function(swoole_mySQL $db, $r) {
    if ($r === false) {
        echo "新增数据失败, 错误信息: " . $db->error . ", 错误码: " . $db->errno . "\n";
    } elseif ($r === true) {
        echo "新增数据成功, ID为：" . $db->insert_id, ", 影响行数: " . $db->affected_rows . "\n";
    }
    var_dump($r);
    $db->close();
});

• 查询操做

// 查询
$sql = "SELECT * FROM runoob_tbl WHERE runoob_id=1";
$db->query($sql, function(swoole_mySQL $db, $r) {
    if ($r === false) {
        echo "新增数据失败, 错误信息: " . $db->error . ", 错误码: " . $db->errno . "\n";
    }
    var_dump($r);
    $db->close();
});

• 删除操做

// 删除
$sql = "DELETE FROM runoob_tbl WHERE runoob_id=1";
$db->query($sql, function(swoole_mySQL $db, $r) {
    if ($r === false) {
        echo "新增数据失败, 错误信息: " . $db->error . ", 错误码: " . $db->errno . "\n";
    }
    var_dump($r);
    $db->close();
});

• 事务操做

// 事务
$db->begin(function(swoole_mySQL $db, $r) {
    $sql = "INSERT INTO runoob_tbl (runoob_title, runoob_author, submission_date) VALUES (\"学习 PHP\", \"菜鸟教程\", NOW())";
    $db->query($sql, function(swoole_mySQL $db, $r) {
        if ($r === true) {
            $sql = "UPDATE runoob_tbl SET runoob_title1='学习 C++' WHERE runoob_id=5";
            $db->query($sql, function(swoole_mySQL $db, $r){
                if ($r === true) {
                    $db->commit(function(swoole_mySQL $db, $r) {
                        if ($r === true) {
                            echo "commit ok \n";
                        }
                    });
                }

                if ($r === false) {
                    $db->rollback(function(swoole_mySQL $db, $r) {
                        if ($r === true) {
                            echo "commit failed, rollback success \n";
                        }
                    });
                }
                $db->close();
            });
        }
    });
});

总结

• 在 Swoole 4.3 版本之后已经移出了异步回调模块了。
• 之后的开发能够直接协程的客户端进行编码了。
• 协程客户端须要在协程的上下文环境中进行编码。
• 不建议在使用异步回调模块。

参考文档

• https://wiki.swoole.com/wiki/page/517.html
• https://wiki.swoole.com/wiki/page/p-coroutine_mysql.html