函数名称:Swoole\MySQL::query()
函数描述:该函数用于执行MySQL查询
适用版本:Swoole扩展1.10.0以上版本
语法:Swoole\MySQL::query(string $sql, callable $callback)
参数:
返回值:无
示例代码:
<?php
// 引入Swoole\MySQL命名空间
use Swoole\MySQL;
// 创建Swoole\MySQL对象
$mysql = new MySQL();
// 连接MySQL服务器
$server = array(
'host' => '127.0.0.1',
'user' => 'root',
'password' => 'password',
'database' => 'test',
);
$mysql->connect($server, function (MySQL $mysql, bool $result) {
if ($result === false) {
// 连接失败处理逻辑
echo "MySQL连接失败:" . $mysql->connect_error . PHP_EOL;
} else {
// 连接成功,在回调函数中执行查询
$sql = 'SELECT * FROM users';
$mysql->query($sql, function (MySQL $mysql, $result) {
if ($result === false) {
// 查询失败处理逻辑
echo "MySQL查询失败:" . $mysql->error . PHP_EOL;
} else {
// 查询成功,处理查询结果
var_dump($result);
}
// 关闭MySQL连接
$mysql->close();
});
}
});
注意事项:
$mysql->close()
来关闭MySQL连接。