Swoole\MySQL::on()函数—用法及示例

函数名称：Swoole\MySQL::on()

适用版本：Swoole 4.3.0及更高版本

函数描述：该函数用于注册Swoole MySQL客户端的事件回调函数。

参数：

• $event：事件名称，可选值包括"close"（连接关闭事件）和"message"（收到MySQL服务器的响应事件）；
• $callback：事件回调函数，当指定事件触发时，会执行该回调函数。

返回值：无

示例：

<?php
// 创建Swoole MySQL客户端对象
$mysql = new Swoole\MySQL();

// 注册连接关闭事件回调函数
$mysql->on('close', function($mysql) {
    echo "MySQL连接已关闭\n";
});

// 注册收到响应事件回调函数
$mysql->on('message', function($mysql, $result) {
    if ($result === false) {
        echo "MySQL查询失败：{$mysql->error}\n";
    } else {
        echo "MySQL查询结果：\n";
        print_r($result);
    }
});

// 连接MySQL服务器
$serverInfo = [
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'root',
    'password' => 'password',
    'database' => 'test',
];
$mysql->connect($serverInfo, function($mysql, $result) {
    if ($result === false) {
        echo "MySQL连接失败：{$mysql->connect_error}\n";
    } else {
        echo "MySQL连接成功\n";
        
        // 发送查询语句
        $mysql->query('SELECT * FROM users', function($mysql, $result) {
            if ($result === false) {
                echo "MySQL查询失败：{$mysql->error}\n";
            } else {
                echo "MySQL查询结果：\n";
                print_r($result);
            }
            
            // 关闭MySQL连接
            $mysql->close();
        });
    }
});

上述示例中，我们首先创建了一个Swoole MySQL客户端对象，并通过on()函数注册了两个事件回调函数，一个用于处理连接关闭事件，另一个用于处理收到MySQL服务器响应的事件。

然后，我们使用connect()函数连接到MySQL服务器，并在连接成功后发送了一条查询语句。在查询语句的回调函数中，我们处理了查询结果，并通过close()函数关闭了MySQL连接。

请注意，示例中的连接参数和查询语句仅供参考，你需要根据实际情况进行相应的修改。