Struct SqlxPgConnection 

pub struct SqlxPgConnection { /* private fields */ }

Trait Implementations

impl Connection for SqlxPgConnection

fn execute_with_params<'a>( &'a mut self, sql: &'a str, params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

PostgreSQL 参数绑定执行（INSERT/UPDATE/DELETE）

使用 sqlx prepared statement 绑定参数。PostgreSQL 协议使用 $1, $2, ... 占位符。

类型映射说明

PostgreSQL 不支持无符号整数类型（u8/u16/u32/u64），因此无符号 Value 绑定 时按“最小可容纳的有符号类型“转换：

• U8 → i16（PostgreSQL SMALLINT）
• U16 → i32（PostgreSQL INTEGER）
• U32 → i64（PostgreSQL BIGINT）
• U64 → i64（可能截断，仅适用于 < i64::MAX 的值）

其他类型直接 bind；未知类型回退为 to_string() 后以 TEXT 绑定。

fn query_with_params<'a>( &'a mut self, sql: &'a str, params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<QueryRows, DbError>> + Send + 'a>>

PostgreSQL 参数绑定查询（SELECT，HashMap 映射）

类型映射规则与 Self::execute_with_params 相同。

fn query_values<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Future<Output = Result<QueryValues, DbError>> + Send + 'a>>

PostgreSQL 位置式查询（SELECT，无参数）

绕过 HashMap 行映射，返回 (列名, 按列序号的值矩阵)。适用于 SELECT ALL 大结果集。

fn query_values_with_params<'a>( &'a mut self, sql: &'a str, params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<QueryValues, DbError>> + Send + 'a>>

PostgreSQL 参数绑定位置式查询（SELECT）

类型映射规则与 Self::execute_with_params 相同。

fn query_stream<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, Value>, DbError>> + Send + 'a>>

PostgreSQL 流式查询：逐行返回结果，避免大结果集 fetch_all 内存峰值

使用 sqlx::query::fetch 获取行流，逐行映射为 HashMap<String, Value>。 流正常消费完毕后连接归还 self.conn；若提前 drop 流，连接通过 PoolConnection::drop 归还到 sqlx 池，但 self.conn 变为 None。

注意：PostgreSQL 的 fetch 返回 Pin<Box<dyn Stream<...>>>（boxed trait object）， 其析构函数可能持有 pool_conn 的借用，导致无法直接 self.conn = Some(pool_conn)。 通过显式 drop(row_stream) 提前结束借用，再归还连接。

fn execute<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

执行 SQL（INSERT/UPDATE/DELETE），返回影响行数

fn query<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Vec<HashMap<String, Value>>, DbError>> + Send + 'a>>

执行查询（SELECT），返回结果行集

fn begin_transaction<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

开启事务

fn commit<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

提交事务

fn rollback<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

回滚事务

fn is_connected(&self) -> bool

判断连接是否仍然有效

fn ping<'a>(&'a mut self) -> Pin<Box<dyn Future<Output = bool> + Send + 'a>>

发送 PING 检测连接存活

fn close<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

关闭连接

fn query_stream_cursor<'a>( &'a mut self, sql: &'a str, _batch_size: usize, ) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, Value>, DbError>> + Send + 'a>>

游标式流式查询（P1-2）：按 batch_size 分批拉取，避免大结果集内存峰值。

fn execute_batch<'a>( &'a mut self, sqls: &'a [String], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

批量执行多条 SQL（按顺序执行，返回累计影响行数）

fn execute_batch_params<'a>( &'a mut self, sql: &'a str, params_batch: &'a [Vec<Value>], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

批量插入（单条 SQL 多次参数绑定执行）

impl Drop for SqlxPgConnection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl PgExtensions for SqlxPgConnection

fn listen<'life0, 'life1, 'async_trait>( &'life0 mut self, channel: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

LISTEN 通道：订阅指定通道的通知

fn notify<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, channel: &'life1 str, payload: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

NOTIFY 通道：向指定通道发送通知

fn copy_from_stdin<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, sql: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

COPY FROM STDIN：批量导入数据