异步与网络

第26课：数据库操作

🎯 本课目标

掌握Rust数据库操作：SQLx异步查询、连接池、事务和ORM。

1. SQLx基础

// Cargo.toml: sqlx = { version = "0.7", features = ["postgres", "runtime-tokio"] }
use sqlx::postgres::PgPoolOptions;

#[tokio::main]
async fn main() -> Result<(), sqlx::Error> {
    // 连接池
    let pool = PgPoolOptions::new()
        .max_connections(5)
        .connect("postgres://user:pass@localhost/db").await?;

    // 查询
    let rows = sqlx::query("SELECT id, name FROM users")
        .fetch_all(&pool).await?;

    // 参数化查询（防止SQL注入！）
    let user = sqlx::query_as::<_, (i32, String)>(
        "SELECT id, name FROM users WHERE id = $1"
    )
    .bind(1)
    .fetch_one(&pool).await;

    // 插入
    sqlx::query("INSERT INTO users (name) VALUES ($1)")
        .bind("Alice")
        .execute(&pool).await?;

    Ok(())
}

✅ 编译验证通过

2. 编译期SQL检查

// sqlx的编译期检查（需数据库运行或离线模式）
use sqlx::query;

// 运行时查询
let r = query("SELECT * FROM users").fetch_all(&pool).await;

// macro查询（编译期检查SQL）
// let r = sqlx::query_as!(User, "SELECT * FROM users")
//     .fetch_all(&pool).await?;

3. 事务

async fn transfer(pool: &sqlx::PgPool, from: i32, to: i32, amount: f64) -> Result<(), sqlx::Error> {
    let mut tx = pool.begin().await?;

    sqlx::query("UPDATE accounts SET balance = balance - $1 WHERE id = $2")
        .bind(amount).bind(from)
        .execute(&mut *tx).await?;

    sqlx::query("UPDATE accounts SET balance = balance + $1 WHERE id = $2")
        .bind(amount).bind(to)
        .execute(&mut *tx).await?;

    tx.commit().await
}

4. 连接池配置

连接池架构：应用程序 │ ↓ 获取连接 ┌──────────────┐ │ 连接池 │ │ ┌──┐┌──┐┌──┐│ │ │C1││C2││C3││ ← 空闲连接 │ └──┘└──┘└──┘│ │ ┌──┐┌──┐ │ │ │C4││C5│ │ ← 活跃连接 │ └──┘└──┘ │ └──────────────┘ │ ↓ 执行SQL ┌──────────────┐ │ PostgreSQL │ └──────────────┘ max_connections: 最大连接数 min_connections: 最小保持连接数 acquire_timeout: 获取超时 idle_timeout: 空闲超时 max_lifetime: 连接最大寿命

📝 练习题

练习1：用户CRUD

实现完整的用户增删改查。

练习2：分页查询

实现数据库分页查询。

练习3：迁移脚本

用sqlx-cli管理数据库迁移。

🏆

成就解锁：数据守护者

掌握Rust数据库操作——持久化存储

⬅ 上一课 🏠 目录下一课 ➡

🔬 深度理解：异步编程模型

Rust的异步模型与其他语言有本质区别：

1. 编译器生成状态机

async函数不是语法糖生成闭包或Future对象，而是编译器生成一个状态机enum，每个.await点是一个状态。这比Green Thread更高效——无堆分配、无运行时开销。

2. 零成本异步

不使用的异步特性不产生代码。不调用async函数？没有状态机代码。这与其他语言的全局运行时（Go的goroutine调度器、Java的Fiber）不同。

3. 显式运行时

Rust没有内置异步运行时。你选择Tokio、async-std或其他——运行时是库，不是语言特性。这意味着灵活但需要选择。

📊 异步模型对比

模型	语言	开销	并发数
OS线程	C/Java	1-8MB/线程	~1000
Green Thread	Go	~2KB/goroutine	~100K
async/await	Rust	~几百字节	~1M+
回调	Node.js	小	高

🌐 网络编程最佳实践

背压控制：使用tokio::sync::Semaphore限制并发
超时设置：所有IO操作加超时，避免挂起
优雅关闭：监听信号，等待进行中的请求完成
连接池：复用TCP连接，减少握手开销
零拷贝：使用bytes::Bytes避免不必要的数据复制
结构化日志：使用tracing替代println

🧪 实战练习补充

以下练习帮助你将本课知识应用到实际场景：

练习A：代码审查

阅读以下代码片段，找出潜在问题并改进：

// 仔细阅读，思考有什么问题
fn process(data: Vec) -> Vec {
    let mut result = Vec::new();
    for i in 0..data.len() {
        result.push(data[i] * 2);
    }
    result
}

改进建议：使用迭代器、预分配容量、考虑溢出。

练习B：性能对比

用criterion基准测试对比以下实现的性能差异：

for循环 vs 迭代器
String拼接 vs write!宏
Vec::push vs Vec::with_capacity

练习C：API设计

为以下场景设计Rust API：一个支持过期时间的缓存系统。考虑所有权、错误处理和泛型。

📌 本课要点总结

通过本课的学习，你应该掌握以下核心要点：

理解Rust核心概念背后的设计哲学
能够将所学知识应用到实际编码中
知道何时选择哪种工具和模式
具备阅读和审查Rust代码的能力
能够独立解决编译器报告的问题

如果某个要点还不够清晰，回顾本课的代码示例和内存图，动手编写代码验证你的理解。

🔗 相关资源

The Rust Book — 官方教程
Rust by Example — 示例驱动学习
Rust Playground — 在线编写运行Rust
crates.io — Rust包仓库
docs.rs — 自动生成的文档
This Week in Rust — 社区周报
Rust用户论坛 — 问答社区

📚 扩展阅读

以下资源帮助你深入学习本课主题：

The Rust Programming Language — 官方教程，Rust圣经
Rust by Example — 通过示例学习Rust
Rust Reference — 语言参考手册
Rustnomicon — Unsafe Rust黑魔法指南
Too Many Lists — 用Rust实现各种链表

🔑 关键术语回顾

本课涉及的核心概念，确保你理解每一个：

术语	说明
所有权	Rust内存管理的核心机制，每个值有唯一所有者
借用	通过引用访问数据，不获取所有权
生命周期	引用有效的范围，编译期分析工具
trait	Rust的接口/抽象机制，类似其他语言的接口
泛型	参数化类型，零成本抽象
模式匹配	强大的数据解构和分支机制
零成本抽象	高层抽象不引入运行时开销
fearless concurrency	编译器保证线程安全

💬 学习建议

动手编码 — 每个代码示例都在本地运行一遍
修改实验 — 故意改错代码，看编译器报什么错
完成练习 — 每课的练习题是巩固知识的关键
阅读源码 — 看标准库和优秀开源项目的实现
写项目 — 真正掌握需要构建真实项目

🤔 常见问题

Q: Rust学习曲线真的很陡吗？

A: 前期确实需要适应所有权和借用检查器，但一旦理解了，这些概念会让你的代码更可靠。大多数人2-4周就能上手。

Q: Rust适合什么项目？

A: 系统编程、Web服务、CLI工具、嵌入式、WASM、网络服务、数据库等。基本上需要性能和安全的地方都适合。

Q: 遇到编译错误怎么办？

A: Rust编译器的错误信息非常友好！仔细阅读，通常会指出问题所在和修复建议。也可以用cargo clippy获取更多提示。