clover-swoole / database
The Swoole Pool Database package.
dev-master
2020-10-19 09:09 UTC
Requires
- illuminate/database: v8.8.0
- symfony/console: ^5.1
Requires (Dev)
- swoole/ide-helper: @dev
This package is auto-updated.
Last update: 2024-10-10 18:25:19 UTC
README
基于Swoole 封装的连接池
以及适配了illuminate/database
目前基于PDO规范 支持MySQL,SQL Server,Postgres和SQLite。
1. 引用本包
composer require itxiao6/database:dev-master
2. 创建配置
实例
/** * 创建配置 */ (new \itxiao6\SwooleDatabase\PDOConfig())-> withDriver('mysql')-> // 驱动类型 withHost('127.0.0.1')-> // 主机地址 withDbname('test')-> // 数据库名 withUsername('root')-> // 用户名 withPassword('123456')-> // 密码 withCharset('utf8mb4')-> // 字符集编码 setConfig('default'); // 设置全局访问(默认为default)
3. 设置
\itxiao6\SwooleDatabase\PoolManager::addPool(64,'default'); // 设置指定连接池尺寸(连接名称默认为 default)
4. 使用协程环境模拟Swoole 的任务执行
/** * 开启协程(如果框架内已经开启可忽略) */ \Swoole\Runtime::enableCoroutine(); /** * 记录开始时间 */ $s = microtime(true); \Swoole\Coroutine\run(function () { /** * 循环创建协程(模拟HTTP 请求 执行任务) */ for ($i = 0; $i < 20; $i++) { \Swoole\Coroutine::create(function () { /** * 创建表 */ // \itxiao6\SwooleDatabase\Manager::schema()->create('test',function(\Illuminate\Database\Schema\Blueprint $table){ // $table->increments('id'); // $table->string('name')->nullable()->default(1); // $table->timestamps(); // }); /** * 模型查询 */ // $lists = \itxiao6\SwooleDatabase\Model::query()->first(); /** * Connection 直接查询 */ $lists = \itxiao6\SwooleDatabase\Adapter\Manager::table('bd_live_plan')->first(); var_dump(boolval($lists)); /** * 协程销毁会自动归还连接(不需要手动处理) */ }); } }); echo '所有任务用了:' . (microtime(true) - $s) . '秒';