pdo_mysql.php

#!/usr/bin/env php
<?php

declare(strict_types=1);

/**
 * In this example, we make five concurrent MySQL connection/queries using the PDO MYSQL extension.
 * Each query takes three seconds to finish. In non-blocking mode, it takes 15 seconds to make the five queries.
 * However, since the queries are executed asynchronously in Swoole, it takes barely over three seconds to finish all
 * the queries.
 *
 * How to run this script:
 *     docker compose exec -t client bash -c "./hooks/pdo_mysql.php"
 *
 * You can run following command to see how much time it takes to run the script:
 *     docker compose exec -t client bash -c "time ./hooks/pdo_mysql.php"
 */

use Swoole\Constant;
use Swoole\Coroutine;

use function Swoole\Coroutine\go;
use function Swoole\Coroutine\run;

// This statement is optional because hook flags are set to SWOOLE_HOOK_ALL by default, and flag SWOOLE_HOOK_ALL has
// flag SWOOLE_HOOK_TCP included already.
Coroutine::set([Constant::OPTION_HOOK_FLAGS => SWOOLE_HOOK_TCP]);

run(function () {
    for ($i = 0; $i < 5; $i++) {
        go(function () {
            $pdo  = new PDO('mysql:host=mysql;dbname=test', 'username', 'password');
            $stmt = $pdo->prepare('SELECT SLEEP(3)');
            $stmt->execute();
            $stmt = null;
            $pdo  = null;
        });
    }
});