# SQLx + PostgreSQL v17 开发指南 ## 编译时检查查询 // 查询_as！（类型安全）让用户 = sqlx::query_as!( 用户， r#"从用户中选择 ID、姓名、电子邮件、角色为“角色：UserRole”，其中 id = $1"#, 编号 ).fetch_one(&pool).await?; // 单列 let count = sqlx::query_scalar!("SELECT COUNT(*) FROM users WHERE active = true") .fetch_one(&pool).await?; // 插入/更新/删除 sqlx::query!("插入用户（姓名，电子邮件）值（$1，$2）"，姓名，电子邮件） .execute(&pool).await?; ## 获取方法 .fetch_one(&pool) // 1 行（如果 0 或 2+ 则出错） .fetch_Optional(&pool) // 0-1 行 (Option) .fetch_all(&pool) // 所有行 (Vec) .fetch(&pool) // 流 (Stream) .execute(&pool) // 仅执行 (PgQueryResult) ## PostgreSQL 枚举 -- 迁移 CREATE TYPE user_role AS ENUM ('Admin', 'AreaManager', 'ServiceStation'); #[导出（调试、克隆、sqlx::类型、序列化、反序列化）] #[sqlx(type_name = "user_role", rename_all = "PascalCase")] pub enum UserRole { Admin, AreaManager, ServiceStation } // 查询（需要强制转换） sqlx::query_as!(User, r#"从用户中选择角色为"角色：UserRole"#) ## JSONB #[导出（调试、序列化、反序列化）] pub 结构元数据 { pub 标签：Vec } // 插入 sqlx::query!("INSERT INTO 项（元数据）值 ($1)", sqlx::types::Json(元数据) as _) .execute(&pool).await?; // 选择 sqlx::query_as!(Item, r#"从项目中选择元数据作为"元数据：Json<元数据>"#) ## 交易让 mut tx = pool.begin().await?; sqlx::query!("INSERT INTO users (name) VALUES ($1)", name) .execute(&mut *tx).await?; sqlx::query!("插入配置文件 (user_id) 值 ($1)", user_id) .execute(&mut *tx).await?; tx.commit().await?; // 错误 → tx 丢弃 → 自动回滚 ## 分页 #[导出（反序列化）] pub struct 分页 { page: Option, per_page: Option } 实现分页{ pub fn offset(&self) -> i64 { (self.page.unwrap_or(1) - 1) * self.per_page() } pub fn per_page(&self) -> i64 { self.per_page.unwrap_or(20).min(100) } } sqlx::query_as!(User, "SELECT * FROM users LIMIT $1 OFFSET $2", pagination.per_page(), pagination.offset()) ## 批量插入（UNNEST）让名称： Vec = items.iter().map(|i| i.name.clone()).collect(); 让值： Vec = items.iter().map(|i| i.value).collect(); sqlx::查询！( "INSERT INTO 项（名称、值）SELECT * FROM UNNEST($1::text[], $2::int[])", 名称和值(&A) ).execute(&pool).await?; ## 更新插入 sqlx::查询！( r#“插入价格（station_id、fuel_type、价格）值（$1、$2、$3）冲突时（station_id，fuel_type） DO UPDATE SET 价格 = EXCLUDED.price, Recorded_at = NOW()"#, station_id，fuel_type as _，价格 ).execute(&pool).await?; ## 动态查询（QueryBuilder） let mut builder = QueryBuilder::new("SELECT * FROM users WHERE 1=1"); if let Some(name) = &filter.name { builder.push(" AND name ILIKE ").push_bind(format!("%{}%", name)); } builder.push(" ORDER BY id LIMIT ").push_bind(limit); builder.build_query_as::().fetch_all(&pool).await？ ## 迁移 sqlx 迁移添加 create_users_table sqlx 迁移运行 sqlx 迁移恢复 ## 注释 1. **ENUM 转换** : `role as "role: UserRole"` 格式需要 2. **NULL** ：对可为空的列使用 `Option` 3. **编译时检查**：需要`DATABASE_URL`环境 4. **离线模式** : `cargo sqlxprepare` 生成.sqlx目录 5. **连接** : `&pool` 用于正常，`&mut *tx` 用于交易

SQLx Postgres

包含技能