查詢

Swoole\Coroutine\MySQL::query()函式—用法及示例

「 在Swoole協程環境中執行MySQL查詢語句 」


函式名稱:Swoole\Coroutine\MySQL::query()

適用版本:Swoole v4.4.0+

函式用途:該函式用於在Swoole協程環境中執行MySQL查詢語句。

函式語法:public Swoole\Coroutine\MySQL::query(string $sql, float $timeout = -1)

引數說明:

  • $sql:要執行的SQL查詢語句。
  • $timeout(可選):超時時間,單位為秒,預設為-1,表示不設定超時。

返回值:

  • 成功時,返回查詢結果,型別為Swoole\Coroutine\MySQL\Statement物件。
  • 失敗時,返回false。

示例程式碼:

<?php
use Swoole\Coroutine\MySQL;

// 建立MySQL協程客戶端
$mysql = new MySQL();

// 連線MySQL伺服器
$serverConfig = [
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'root',
    'password' => 'password',
    'database' => 'mydb',
];
$mysql->connect($serverConfig);

// 執行查詢語句
$sql = 'SELECT * FROM users';
$result = $mysql->query($sql);

// 處理查詢結果
if ($result === false) {
    echo "Error: " . $mysql->error . PHP_EOL;
} else {
    while ($row = $result->fetch()) {
        print_r($row);
    }
}

// 關閉MySQL連線
$mysql->close();

在上面的示例中,我們首先建立了一個Swoole\Coroutine\MySQL物件,並使用connect()方法連線到MySQL伺服器。然後,我們執行了一個查詢語句,並透過query()方法傳入要執行的SQL語句。最後,我們使用fetch()方法逐行獲取查詢結果,並進行處理。

請注意,在使用Swoole協程環境中,我們可以在一個協程中使用多個MySQL連線,而不會阻塞其他協程的執行。

補充糾錯
熱門PHP函式
分享連結