如何用Rust+diesel.rs实现PostgreSQL Upsert的DRY代码结构？

错误原因分析 #

你遇到的编译错误核心在于AsChangeset trait是为单个实体结构体设计的，而你传入的是&Vec<Post>集合类型，Diesel不会为集合自动实现这个trait。要复用更新逻辑，得回到AsChangeset的正确用法上。

优化方案（符合DRY原则） #

1. 确保结构体正确派生AsChangeset

先给Post结构体同时派生Insertable和AsChangeset，并绑定对应的表名：

use diesel::{Insertable, AsChangeset};
use crate::schema::posts; // 导入你的表schema定义

#[derive(Insertable, AsChangeset, Debug)]
#[diesel(table_name = posts)]
struct Post {
    id: i32,
    title: String,
    content: String,
    // 其他上百列直接在这里定义，无需额外重复编写更新逻辑
}

如果有不需要参与更新的列，用#[diesel(skip)]标记跳过即可：

#[diesel(skip)]
created_at: NaiveDateTime,

2. 批量UPSERT的简洁实现

利用PostgreSQL的ON CONFLICT语法结合Diesel的excluded函数，直接复用AsChangeset的逻辑完成全列更新，彻底摆脱手动编写所有列set语句的冗余：

use diesel::pg::upsert::excluded;
use diesel::PgConnection;
use diesel::result::QueryResult;

fn bulk_upsert_posts(conn: &mut PgConnection, posts: Vec<Post>) -> QueryResult<usize> {
    diesel::insert_into(posts::table)
        .values(&posts)
        .on_conflict(posts::id) // 指定冲突判断的唯一键（比如主键id）
        .do_update()
        .set(Post::as_changeset(&excluded(posts::table))) // 直接复用AsChangeset的映射逻辑
        .execute(conn)
}

这里excluded(posts::table)会获取冲突时原本要插入的行数据，再通过Post::as_changeset自动转换成符合更新要求的结构，所有列的更新逻辑会自动映射完成。

3. 自定义更新逻辑（可选）

如果不需要全列更新，只想更新特定列，可以在派生AsChangeset时用#[diesel(only)]指定目标列：

#[derive(AsChangeset)]
#[diesel(table_name = posts, only(title, content))]
struct PostUpdate {
    title: String,
    content: String,
}

后续在UPSERT逻辑中使用这个结构体的as_changeset即可。

注意事项 #

• 若批量处理的行数过多（比如上万行），要注意PostgreSQL的参数数量限制，建议分批执行（比如每1000行一批）
• excluded是PostgreSQL特有的函数，必须导入diesel::pg::upsert::excluded才能使用

内容的提问来源于stack exchange，提问作者Mike