matrix2305/swoole-pgslq-doctrine-driver

A Doctrine DBAL Driver implementation on top of Swoole Coroutine PostgreSql extension

dev-main 2023-05-23 22:22 UTC

Requires

• php: ^8.0
• ext-pdo: *
• doctrine/dbal: ^2.13.3

Requires (Dev)

• pestphp/pest: ^1.0
• swoole/ide-helper: ^4.6

Suggests

• ext-openswoole: You need either ext-swoole or ext-openswoole
• ext-swoole: You need either ext-swoole or ext-openswoole

MIT

• Diego Rin Martín
• leocavalcante

README

A Doctrine\DBAL\Driver implementation on top of Swoole\Coroutine\PostgreSQL.

Getting started

Install

composer require matrix2305/swoole-pgsql-doctrine-driver

Usage

Doctrine parameters, for both DBAL and ORM projects, accepts the driverClass option; it is where we can inject this project's driver:

use Doctrine\DBAL\{Driver, DriverManager};

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

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

Yes, I deliberately used the Doctrine\DBAL\Driver namespace + Swoole\Coroutine\MySQL namespace, so it is not confusing.

You are ready to rock inside Coroutines (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";
});

You should be seeing Two sleep(1) queries in 1 second, returning: 2 and the total time should not be 2 (the sum of sleep(1)'s) because they ran concurrently.

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