Pg send query: примеры (PHP)

<?php
$connection = pg_connect("host=localhost dbname=test user=postgres");
if ($connection) {
    $result = pg_send_query($connection, "SELECT * FROM users WHERE id = 1");
    if ($result) {
        echo "Запрос отправлен";
    } else {
        echo "Ошибка отправки";
    }
}
?>

Запрос отправлен

<?php
$connection = pg_connect("host=localhost dbname=test");
$queries = "INSERT INTO logs (message) VALUES ('test1'); INSERT INTO logs (message) VALUES ('test2');";
$sendResult = pg_send_query($connection, $queries);
var_dump($sendResult);
?>

bool(true)

pg_query — синхронное выполнение запроса. Ожидает завершения и сразу возвращает результат. Подходит для большинства стандартных операций.

pg_send_query_params — асинхронная отправка параметризованного запроса. Рекомендуется для запросов с пользовательскими данными из-за безопасности.

pg_send_prepare и pg_send_execute — асинхронная работа с подготовленными запросами. Полезны при многократном выполнении схожих запросов.

Выбор зависит от необходимости асинхронности и типа запроса. Для простых запросов без параметров используют pg_send_query, для данных извне — pg_send_query_params.

import asyncio
import asyncpg

async def async_query():
    conn = await asyncpg.connect('postgresql://user:pass@localhost/db')
    await conn.execute('INSERT INTO logs(message) VALUES($1)', 'test')
    await conn.close()

asyncio.run(async_query())

const { Client } = require('pg');
const client = new Client();
await client.connect();
const res = await client.query('SELECT $1::text as message', ['Hello']);
console.log(res.rows[0].message);
await client.end();

В MySQL асинхронные запросы обычно реализуются через неблокирующие соединения в драйверах, таких как mysql2 для Node.js или asyncio для Python.

Основное отличие от PHP: в Python и JavaScript асинхронность встроена в язык, что упрощает написание неблокирующего кода.

<?php
$connection = false;
$result = pg_send_query($connection, "SELECT 1");
var_dump($result);
?>

bool(false)

Функция возвращает false при неверном соединении.

<?php
$conn = pg_connect("host=localhost dbname=test");
pg_send_query($conn, "SELECT 1");
// Попытка сразу использовать pg_fetch_result приведет к ошибке
$row = pg_fetch_result(pg_get_result($conn), 0, 0);
echo $row;
?>

1

Для получения результата асинхронного запроса требуется сначала вызвать pg_get_result.

В PHP 8.1.0 изменений в поведении функции не было. В PHP 8.0.0 функция стала строже к типам аргументов, ожидается ресурс соединения.

Начиная с PHP 7.4.0, функция корректно обрабатывает ошибки при передаче неверного типа аргументов.

Рекомендуется использовать последние версии PHP для улучшенной обработки ошибок и стабильности.

<?php
$conn = pg_connect("host=localhost dbname=test");
$query1 = "SELECT pg_sleep(2), 'slow query' as result";
$query2 = "SELECT 'fast query' as result";

pg_send_query($conn, $query1);
pg_send_query($conn, $query2); // Отправляется до завершения первого

// Получение результатов
$res1 = pg_get_result($conn);
$res2 = pg_get_result($conn);

echo pg_fetch_result($res2, 0, 0); // fast query
// Далее можно получить результат первого запроса
?>

fast query

<?php
$conn = pg_connect("host=localhost dbname=test");
pg_send_query($conn, "SELECT * FROM non_existing_table");
$result = pg_get_result($conn);
if (pg_result_error($result)) {
    echo "Ошибка запроса: ". pg_result_error($result);
}
?>

Ошибка запроса: ERROR: relation "non_existing_table" does not exist

<?php
$conn = pg_connect("host=localhost dbname=test");
pg_send_query($conn, "SELECT pg_sleep(1)");
while (pg_connection_busy($conn)) {
    echo "Соединение занято, ожидание...\n";
    usleep(100000);
}
$result = pg_get_result($conn);
echo "Запрос завершен\n";
?>

Соединение занято, ожидание...
Запрос завершен