Struct PgConnection 

pub struct PgConnection { /* private fields */ }

PostgreSQL connection.

Manages a TCP connection to a PostgreSQL server, handling the wire protocol, authentication, and state tracking.

Console Support

When the console feature is enabled, the connection can report progress via an attached SqlModelConsole. This provides rich feedback during connection establishment and query execution.

Implementations

impl PgConnection

pub fn connect(config: PgConfig) -> Result<Self, Error>

Establish a new connection to the PostgreSQL server.

This performs the complete connection handshake:

1. TCP connection
2. SSL negotiation (if configured)
3. Startup message
4. Authentication
5. Receive server parameters and ReadyForQuery

pub fn state(&self) -> ConnectionState

Get the current connection state.

pub fn is_ready(&self) -> bool

Check if the connection is ready for queries.

pub fn process_id(&self) -> i32

Get the backend process ID (for query cancellation).

pub fn secret_key(&self) -> i32

Get the secret key (for query cancellation).

pub fn parameter(&self, name: &str) -> Option<&str>

Get a server parameter value.

pub fn parameters(&self) -> &HashMap<String, String>

Get all server parameters.

pub fn close(&mut self) -> Result<(), Error>

Close the connection gracefully.

Trait Implementations

impl Debug for PgConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for PgConnection

fn drop(&mut self)

Executes the destructor for this type.