Module sql 

Structs

BackendKeyData

Column

CommandStarting

Description

ExtendedRequest

An request to execute a SQL query using the extended protocol.

Notice

ParameterStatus

SqlError

SqlResponse

The response to a SqlRequest.

Enums

Error

ExistingUser

SqlRequest

A request to execute SQL over HTTP.

SqlResult

The result of a single query in a SqlResponse.

StatementResult 🔒

WebSocketAuth

WebSocketResponse

Statics

PER_REPLICA_LABELS 🔒

Traits

ResultSender 🔒

Trait describing how to transmit a response to a client. HTTP clients accumulate into a Vec and send all at once. WebSocket clients send each message as they occur.

Functions

await_rows 🔒

execute_promsql_query 🔒

execute_request 🔒

Executes an entire SqlRequest.

execute_stmt 🔒

Executes a single statement in a SqlRequest.

execute_stmt_group 🔒

Returns Ok(Err) if any statement error’d during execution.

forward_notices 🔒

Forwards a collection of Notices to the provided WebSocket.

handle_promsql

handle_promsql_query 🔒

handle_sql

handle_sql_ws 🔒

is_txn_exit_stmt 🔒

make_notices 🔒

run_ws 🔒

run_ws_request 🔒

send_and_retire 🔒

send_ws_response 🔒

Sends a single WebSocketResponse over the provided WebSocket.

stream_ws_peek_rows 🔒

Streams a peek (SELECT) result to a WebSocket client one stash batch at a time, flushing between batches so a slow client applies real backpressure and only one batch is resident. This gives a large SELECT over WebSocket the same bounded memory profile as pgwire SELECT, and mirrors the Subscribe arm of WebSocket::add_result.

ws_peek_result 🔒

Packages a terminal result of stream_ws_peek_rows, appending any notices still buffered on the session after msgs.