reactphp 异步mysql

use React\EventLoop\Factory;
use React\MySQL\Connection;
use React\MySQL\QueryResult;

$loop = Factory::create();

$connection = new Connection($loop, [
    'host' => 'localhost',
    'port' => 3306,
    'user' => 'username',
    'password' => 'password',
    'database' => 'database_name',
]);

$connection->connect(function ($e) use ($connection) {
    if ($e) {
        echo "Connection error: " . $e->getMessage() . "\n";
        return;
    }

    $query = "SELECT * FROM table_name";
    $connection->query($query, function (QueryResult $result) {
        if ($result->hasError()) {
            echo "Query error: " . $result->getError() . "\n";
            return;
        }

        $rows = $result->fetchAll();
        foreach ($rows as $row) {
            echo "Row: " . json_encode($row) . "\n";
        }
    });
});

$loop->run();