企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
## Mix\Database\Database::class 基于 PDO 封装的数据库组件,内置连接池,可独立使用。 ## 组件 使用 [composer]([https://www.phpcomposer.com/](https://www.phpcomposer.com/)) 安装: ~~~ composer require mix/database ~~~ ## 依赖注入配置 - [manifest/beans/database.php](https://github.com/mix-php/mix-skeleton/blob/master/manifest/beans/database.php) > \>= v2.2.9 新增了 maxLifetime、waitTimeout 参数 ## 长连接超时问题 MySQL 配置文件内的 `interactive_timeout` 与 `wait_timeout` 参数,决定了 sleep 多长时间的连接会被主动 kill,正常情况下是需要用户自己来处理连接超时的问题,但使用该组件时用户不需要处理,组件底层已经帮你处理了。 - `maxLifetime` 连接因闲置被 mysql 主动 kill 连接时,连接会被重连,业务不受影响,但调度器依然还是会调度一个异常,如果想消除这个异常,配置该参数 < `interactive_timeout` 与 `wait_timeout` 参数。 ## 获取连接 - 直接调用方法获取连接 >[danger] 注意:$conn 必须立即置空归还 ``` /** @var \Mix\Database\Database $db */ $db = context()->get('database'); // 调用方法返回连接,然后执行 $conn = $db->prepare("SELECT * FROM `post`"); $result = $conn->queryAll(); $affectedRows = $conn->getRowCount(); $conn = null; // 使用完后立即手动归还连接,避免出现协程死锁 // 不需要获取 getRowCount、getLastInsertId 时,直接调用 $result = $db->prepare("SELECT * FROM `post`")->queryAll(); ``` - 手动获取连接 >[danger] 注意:每次 borrow 取出后用完必须立即置空归还,并且在这个连接的使用过程中不可再次获取其他连接 ``` /** @var \Mix\Database\Database $db */ $db = context()->get('database'); $conn = $db->borrow(); // ... $conn = null; // 使用完后立即手动归还连接,避免出现协程死锁 ``` 当出现以下异常信息,很有可能就是协程死锁导致 ~~~ PHP Fatal error: Swoole\Coroutine\Channel::close(): you must call Channel constructor first in /Users/***/worker-pool/src/AbstractWorker.php on line 96 Fatal error: Swoole\Coroutine\Channel::close(): you must call Channel constructor first in /Users/***/worker-pool/src/AbstractWorker.php on line 96 [2020-10-26 19:48:59 @61837.0] WARNING ~Channel (ERRNO 10003): channel is destroyed, 1 consumers will be discarded [2020-10-26 19:48:59 @61837.0] WARNING ~Channel (ERRNO 10003): channel is destroyed, 20 consumers will be discarded [2020-10-26 19:48:59 @61837.0] WARNING ~Channel (ERRNO 10003): channel is destroyed, 1 consumers will be discarded [2020-10-26 19:48:59 @61837.0] WARNING ~Channel (ERRNO 10003): channel is destroyed, 1 consumers will be discarded ~~~ - 获取查询构造器 ``` /** @var \Mix\Database\Database $db */ $db = context()->get('database'); $builder = $db->table('user'); ```