Swoole连接MySQL有两种方式：一是使用Swoole异步MySQL客户端，性能更优但需学习成本；二是使用PHP的MySQL扩展（如mysqli或PDO）结合协程，易于上手但性能稍弱。异步客户端通过\Swoole\MySQL\Client类实现，需设置连接参数并使用回调处理结果，适用于高并发场景。例如，连接成功后在回调中执行查询，所有操作非阻塞。预处理语句通过prepare和execute方法支持，防止SQL注入并提升效率。而传统扩展结合协程则在Co::run中执行同步代码，利用协程避免阻塞，适合快速迁移。选择应基于性能需求与开发成本权衡。
Swoole连接MySQL主要通过两种方式：一是使用Swoole提供的异步MySQL客户端，二是使用传统的PHP MySQL扩展结合协程。前者性能更优，后者更易上手。数据库操作包括查询、插入、更新、删除等，各有不同的实现方式。
Swoole连接MySQL，主要有两种路子。一种是官方推荐的异步客户端，性能没的说，但上手需要点时间。另一种，就是咱们熟悉的PHP那一套MySQL扩展，再套个协程的壳子，用起来顺手，但性能嘛，稍微差点意思。
异步MySQL客户端：性能至上的选择 PHP MySQL扩展 + 协程：平滑过渡的方案
如何使用Swoole异步MySQL客户端连接MySQL？
Swoole的
\Swoole\MySQL\Client类提供了异步连接MySQL的能力。使用它，需要先创建一个客户端实例，然后设置连接参数，最后调用
connect方法发起连接。
$client = new \Swoole\MySQL\Client(SWOOLE_MYSQL_ASYNC);
$client->set([
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'root',
'password' => 'your_password',
'database' => 'your_database',
]);
$client->connect(function ($cli, $result) {
if ($result === false) {
echo "连接失败: " . $cli->errMsg . PHP_EOL;
} else {
echo "连接成功" . PHP_EOL;
// 连接成功后，可以执行查询等操作
}
});这里，
SWOOLE_MYSQL_ASYNC标志告诉Swoole这是一个异步客户端。连接成功或失败后，会调用回调函数。需要注意的是，所有数据库操作都应该在连接成功的回调函数中进行，或者在后续的事件循环中进行，否则可能出现问题。 异步的好处在于，连接建立后，不会阻塞主进程，可以继续处理其他请求。
如何使用PHP MySQL扩展结合协程连接MySQL？
如果你不想一下子切换到异步客户端，可以使用PHP的
mysqli或
PDO扩展，结合Swoole的协程。这种方式相当于把同步操作放在协程中执行，避免阻塞主进程。
use Swoole\Coroutine as Co;
Co::run(function () {
$mysqli = new mysqli('127.0.0.1', 'root', 'your_password', 'your_database');
if ($mysqli->connect_error) {
die('Connect Error (' . $mysqli->connect_errno . ') ' . $mysqli->connect_error);
}
$result = $mysqli->query("SELECT * FROM your_table");
while ($row = $result->fetch_assoc()) {
var_dump($row);
}
$result->free();
$mysqli->close();
});这段代码在协程中使用了
mysqli扩展连接MySQL，并执行了查询操作。注意，必须在
Co::run中执行，才能利用协程的特性。
Swoole异步MySQL客户端如何执行查询操作？
使用Swoole异步客户端执行查询，需要调用
query方法，并传入SQL语句和回调函数。
$client->query("SELECT * FROM your_table", function ($cli, $result) {
if ($result === false) {
echo "查询失败: " . $cli->errMsg . PHP_EOL;
} elseif ($result === true) {
echo "影响行数: " . $cli->affected_rows . PHP_EOL; // INSERT/UPDATE/DELETE
} else {
// 查询结果
var_dump($result);
}
});回调函数接收两个参数：客户端实例和查询结果。如果查询失败，
$result为
false，并可以通过
$cli->errMsg获取错误信息。如果执行的是
INSERT、
UPDATE、
DELETE等操作，
$result为
true，可以通过
$cli->affected_rows获取影响的行数。如果是
SELECT操作，
$result为一个二维数组，包含查询结果。
Swoole异步MySQL客户端如何执行预处理语句？
预处理语句可以有效防止SQL注入，并提高性能。Swoole异步客户端也支持预处理语句。
$client->prepare("SELECT * FROM your_table WHERE id = ?", function ($cli, $stmt) {
if ($stmt === false) {
echo "预处理失败: " . $cli->errMsg . PHP_EOL;
} else {
$stmt->execute([1], function ($stmt, $result) { // 1是id的值
if ($result === false) {
echo "执行失败: " . $stmt->errMsg . PHP_EOL;
} else {
var_dump($result);
}
$stmt->close();
});
}
});首先调用
prepare方法预处理SQL语句，然后调用
execute方法执行预处理语句，并传入参数。执行完毕后，需要调用
close方法释放资源。
如何选择Swoole连接MySQL的方式？
选择哪种方式连接MySQL，取决于你的具体需求。如果对性能要求非常高，并且愿意投入时间学习异步编程，那么Swoole异步MySQL客户端是最佳选择。如果只是想简单地使用Swoole，并且对性能要求不高，那么PHP MySQL扩展结合协程也是一个不错的选择。
记住，没有银弹。选择最适合你的，才是最好的。
