函数名称:Swoole\MySQL::query()
函数描述:该函数用于执行MySQL查询
适用版本:Swoole扩展1.10.0以上版本
语法:Swoole\MySQL::query(string $sql, callable $callback)
参数:
- $sql:要执行的SQL查询语句
- $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();
});
}
});
注意事项:
- 在使用Swoole\MySQL扩展之前,需要先安装Swoole扩展并启用。
- 在使用Swoole\MySQL之前,需要确保已正确安装MySQL服务器,并且已创建相应的数据库和表。
- 在实际使用中,可以根据需要自定义回调函数来处理查询结果和错误信息。
- 在查询回调函数中,可以通过
$mysql->close()
来关闭MySQL连接。 - 为了避免SQL注入攻击,建议在拼接SQL语句时使用参数绑定或转义等安全措施。