Struct Connection 

pub struct Connection { /* private fields */ }

Postgres connection

Implementations

impl Connection

pub fn new(transport: Transport) -> Self

Create connection from transport

pub fn state(&self) -> ConnectionState

Get current connection state

pub async fn startup(&mut self, config: &ConnectionConfig) -> Result<()>

Perform startup and authentication

pub async fn simple_query(&mut self, query: &str) -> Result<Vec<BackendMessage>>

Execute a simple query (returns all backend messages)

pub async fn close(self) -> Result<()>

Close the connection

pub async fn streaming_query( self, query: &str, chunk_size: usize, max_memory: Option<usize>, soft_limit_warn_threshold: Option<f32>, soft_limit_fail_threshold: Option<f32>, enable_adaptive_chunking: bool, adaptive_min_chunk_size: Option<usize>, adaptive_max_chunk_size: Option<usize>, ) -> Result<JsonStream>

Execute a streaming query

Note: This method consumes the connection. The stream maintains the connection internally. Once the stream is exhausted or dropped, the connection is closed.