Swoole\MySQL::on()

注册Swoole MySQL客户端的事件回调函数

首字母:S

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

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

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

参数:

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

返回值:无

示例:

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连接。

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

同首字母函数