README

在 SwooleMySQL 上实现的 Doctrine\DBAL\Driver。

入门

安装

composer require matrix2305/swoole-mysql-doctrine-driver

使用

Doctrine参数，对于DBAL和ORM项目，都接受driverClass选项；这就是我们可以注入此项目驱动的地方

use Doctrine\DBAL\{Driver, DriverManager};

$params = [
    'dbname' => 'mysql',
    'user' => 'mysql',
    'password' => 'mysql',
    'host' => 'db',
    'driverClass' => Driver\SwooleMySQL\Driver::class,
    'poolSize' => 8,
];

$conn = DriverManager::getConnection($params);

是的，我故意使用了Doctrine\DBAL\Driver命名空间+SwooleMySQL命名空间，所以不会混淆。

您已经准备好在协程（Fibers）中尽情发挥

Co\run(static function() use ($conn): void {
    $results = [];
    $wg = new Co\WaitGroup();
    $start_time = time();

    Co::create(static function() use (&$results, $wg, $conn): void {
        $wg->add();
        $results[] = $conn->executeQuery('select 1, sleep(1)')->fetchOne();
        $wg->done();
    });

    Co::create(static function() use (&$results, $wg, $conn): void {
        $wg->add();
        $results[] = $conn->executeQuery('select 1, sleep(1)')->fetchOne();
        $wg->done();
    });

    $wg->wait();
    $elapsed = time() - $start_time;
    $sum = array_sum($results);

    echo "Two sleep(1) queries in $elapsed second, returning: $sum\n";
});

您应该看到 在1秒内有两次sleep(1)查询，返回：2，总时间应该不是2（sleep(1)的总和），因为它们是并发运行的。

real    0m1.228s
user    0m0.036s
sys     0m0.027s