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

MIT

• itxiao6

• orm
• sql
• laravel
• swoole
• Databses

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) . '秒';