После перехода в режим конвейеризации приложение отправляет запросы с помощью функции PQsendQueryParams или её аналога для подготовленных запросов PQsendQueryPrepared. Данные запросы помещаются в очередь на стороне клиента до их отправки на сервер; это происходит в тех случаях, когда PQpipelineSync используется для создания точки синхронизации в конвейере, или когда PQflush вызывается. Функции PQsendPrepare, PQsendDescribePrepared, PQsendDescribePortal, PQsendClosePreparedи PQsendClosePortal также поддерживают работу в конвейерном режиме. Порядок обработки результатов описан ниже.

Сервер выполняет операторы и возвращает результаты в том же порядке, в котором их отправляет клиент. Сервер начинает выполнение команд в конвейере немедленно, не ожидая его завершения. Следует учитывать, что на стороне сервера результаты буферизуются; сервер очищает данный буфер при установке точки синхронизации с помощью функции PQpipelineSync или PQsendPipelineSync, а также при вызове функции PQsendFlushRequest вызывается. Если при выполнении какого-либо оператора возникает ошибка, сервер прерывает текущую транзакцию и не выполняет последующие команды в очереди до достижения следующей точки синхронизации; PGRES_PIPELINE_ABORTED для каждой такой команды формируется результат. (Это правило остается в силе, даже если команды в конвейере вызовут откат транзакции.) Обработка запросов возобновляется после точки синхронизации.

Допускается зависимость одной операции от результатов предыдущей; например, один запрос может определять таблицу, используемую следующим запросом в том же конвейере. Аналогичным образом приложение может создать именованный подготовленный оператор и выполнить его в последующих операторах того же конвейера.

Чтобы обработать результат одного запроса в конвейере, приложение многократно вызывает функцию PQgetResult и обрабатывает каждый результат до тех пор, пока PQgetResult не вернет значение NULL. Затем результат следующего запроса в конвейере может быть получен путем повторного вызова функции PQgetResult после чего цикл повторяется. Результаты отдельных операторов приложение обрабатывает в обычном режиме. Когда результаты всех запросов в конвейере будут возвращены, PQgetResult возвращает результат, содержащий значение статуса PGRES_PIPELINE_SYNC

Клиент может выбрать вариант с отложенной обработкой результатов до завершения отправки всего конвейера или совмещать её с отправкой последующих запросов; см. Раздел 4.1.5.1.4.

PQgetResult работает так же, как и при обычной асинхронной обработке, за исключением возможности появления новых PGresult типов PGRES_PIPELINE_SYNC и PGRES_PIPELINE_ABORTED. PGRES_PIPELINE_SYNC сообщается ровно один раз для каждого PQpipelineSync или PQsendPipelineSync в соответствующей точке конвейера. PGRES_PIPELINE_ABORTED выдается вместо обычного результата запроса при возникновении первой ошибки и для всех последующих результатов до следующего PGRES_PIPELINE_SYNC; см. Раздел 4.1.5.1.3.

PQisBusy, PQconsumeInput, и т. д. работают в штатном режиме при обработке результатов конвейера. В частности, вызов функции PQisBusy в середине конвейера возвращает 0, если результаты всех отправленных на данный момент запросов уже были получены.

libpq не предоставляет приложению никакой информации о текущем обрабатываемом запросе (за исключением того, что PQgetResult возвращает значение NULL, указывая на начало возврата результатов следующего запроса). Приложение должно самостоятельно отслеживать порядок отправки запросов для их сопоставления с соответствующими результатами. Как правило, для этой цели в приложениях используется конечный автомат или очередь FIFO.

С точки зрения клиента, после того как PQresultStatus возвращает значение PGRES_FATAL_ERROR, конвейер помечается как прерванный. PQresultStatus будет возвращать PGRES_PIPELINE_ABORTED результат для каждой оставшейся в очереди операции в прерванном конвейере. Результат для PQpipelineSync или PQsendPipelineSync возвращается как PGRES_PIPELINE_SYNC для сигнализации о завершении прерванного конвейера и возобновлении обычной обработки результатов.

Клиент должен обрабатывает результаты с помощью функции PQgetResult в процессе восстановления после ошибки.

Если в конвейере использовалась неявная транзакция, то уже выполненные операции откатываются, а операции, находившиеся в очереди после сбойной операции, полностью пропускаются. Аналогичное поведение сохраняется, если в конвейере запускается и фиксируется одна явная транзакция (т. е. первым оператором является BEGIN а последним — COMMIT), за исключением того, что по завершении работы конвейера сеанс остается в состоянии прерванной транзакции. Если конвейер содержит несколько явных транзакций, то все транзакции, зафиксированные до возникновения ошибки, остаются зафиксированными, текущая выполняемая транзакция прерывается, а все последующие операции, включая последующие транзакции, полностью пропускаются. Если точка синхронизации конвейера возникает в момент, когда явный блок транзакции находится в состоянии прерывания, выполнение следующего конвейера будет немедленно прекращено, если только следующая команда не переведет транзакцию в нормальный режим с помощью ROLLBACK.

Во избежание взаимоблокировок в больших конвейерах архитектуру клиента следует основывать на неблокирующем цикле событий с использованием таких средств операционной системы, как select, poll, WaitForMultipleObjectEx, и т. д.

Как правило, клиентскому приложению следует поддерживать очередь задач, ожидающих отправки, и очередь задач, которые уже были отправлены, но результаты выполнения которых еще не обработаны. Когда сокет становится доступен для записи, следует передать на выполнение дополнительный объем задач. Когда сокет становится доступен для чтения, следует прочитать результаты и обработать их, сопоставляя их со следующей записью в соответствующей очереди результатов. Исходя из объема доступной памяти, результаты из сокета следует считывать часто: для чтения результатов нет необходимости ждать завершения работы конвейера. Область действия конвейеров должна ограничиваться логическими единицами работы, как правило (но не обязательно), одной транзакцией на конвейер. Нет необходимости выходить из режима конвейера и повторно входить в него между конвейерами или ожидать завершения одного конвейера перед отправкой следующего.

Пример использования select() и простого конечного автомата для отслеживания отправленных и полученных задач приведен в файле src/test/modules/libpq_pipeline/libpq_pipeline.c в составе дистрибутива исходных кодов PostgreSQL.