Swoole如何连接MySQL？数据库操作有哪些方法？-Swoole-PHP中文网

Swoole如何连接MySQL？数据库操作有哪些方法？

幻夢星雲

发布： 2025-08-15 13:57:01

原创

781人浏览过

Swoole连接MySQL有两种方式：一是使用Swoole异步MySQL客户端，性能更优但需学习成本；二是使用PHP的MySQL扩展（如mysqli或PDO）结合协程，易于上手但性能稍弱。异步客户端通过\Swoole\MySQL\Client类实现，需设置连接参数并使用回调处理结果，适用于高并发场景。例如，连接成功后在回调中执行查询，所有操作非阻塞。预处理语句通过prepare和execute方法支持，防止SQL注入并提升效率。而传统扩展结合协程则在Co::run中执行同步代码，利用协程避免阻塞，适合快速迁移。选择应基于性能需求与开发成本权衡。

swoole如何连接mysql？数据库操作有哪些方法？

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语句和回调函数。

法语写作助手

法语助手旗下的AI智能写作平台，支持语法、拼写自动纠错，一键改写、润色你的法语作文。

查看详情

$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();
        });
    }
});

登录后复制

首先调用