下面通过一个完整的示例演示如何使用 SeaORM 对 PostgreSQL 数据库进行增删改查CRUD操作。1. 项目设置与依赖首先创建一个新项目并添加必要的依赖。bashcargo new seaorm-example cd seaorm-example在Cargo.toml中添加以下依赖toml[dependencies] # SeaORM 核心库启用 sqlx-postgres 特性以支持 PostgreSQL 和异步运行时 sea-orm { version 1.0, features [sqlx-postgres, runtime-tokio-rustls] } # 异步运行时 tokio { version 1, features [full] } # 用于处理异步错误 anyhow 1 # 可选用于记录日志 env_logger 0.102. 定义实体 (Entity)SeaORM 鼓励“实体优先”的工作流。我们手动定义一个bakery实体它对应数据库中的bakery表。创建文件src/entities/bakery.rsrust// src/entities/bakery.rs use sea_orm::entity::prelude::*; #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)] #[sea_orm(table_name bakery)] pub struct Model { #[sea_orm(primary_key)] pub id: i32, pub name: String, #[sea_orm(column_type Double)] pub profit_margin: f64, } #[derive(Copy, Clone, Debug, EnumIter, DeriveColumn)] pub enum Column { Id, Name, ProfitMargin, } #[derive(Copy, Clone, Debug, EnumIter, DerivePrimaryKey)] pub enum PrimaryKey { Id, } impl PrimaryKeyTrait for PrimaryKey { type ValueType i32; fn auto_increment() - bool { true } } #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)] pub enum Relation {} impl Relatedsuper::chef::Entity for Entity { fn to() - RelationDef { // 我们稍后会定义 chef 实体 todo!() } } impl ActiveModelBehavior for ActiveModel {}为了让bakery模块可用在src/entities/mod.rs中声明它rust// src/entities/mod.rs pub mod bakery;3. 数据库连接与初始化在src/main.rs中我们建立数据库连接并创建一个bakery表如果它不存在的话。SeaORM 可以通过Schema工具从实体定义创建表。rust// src/main.rs mod entities; use entities::bakery; use sea_orm::{ ColumnTrait, ConnectionTrait, Database, DbBackend, DbErr, EntityTrait, QueryFilter, Schema, Set, ActiveValue::NotSet }; use anyhow::Result; #[tokio::main] async fn main() - Result() { // 初始化日志可选 env_logger::init(); // 1. 建立数据库连接 let database_url postgres://postgres:passwordlocalhost:5432/postgres; let db Database::connect(database_url).await?; // 2. 创建表如果表不存在 let schema Schema::new(DbBackend::Postgres); let create_table_stmt schema.create_table_from_entity(bakery::Entity); // 执行创建表的SQL语句 match db.execute(db.get_database_backend().build(create_table_stmt)).await { Ok(_) println!(Table bakery created or already exists.), Err(e) eprintln!(Error creating table: {}, e), }; // 3. 执行CRUD操作 run_crud_operations(db).await?; Ok(()) }4. 执行 CRUD 操作定义run_crud_operations函数在其中演示增、查、改、删操作。rustasync fn run_crud_operations(db: sea_orm::DatabaseConnection) - Result(), DbErr { // --- 插入 (Insert) --- // 使用 ActiveModel 构建要插入的数据[reference:4] let happy_bakery bakery::ActiveModel { name: Set(Happy Bakery.to_owned()), profit_margin: Set(0.0), ..Default::default() // 其他字段如 id使用默认值 }; let insert_result Bakery::insert(happy_bakery).exec(db).await?; let new_bakery_id insert_result.last_insert_id; println!(插入成功ID: {}, new_bakery_id); // --- 查询 (Select) --- // 1. 查询所有[reference:5] let all_bakeries: Vecbakery::Model Bakery::find().all(db).await?; println!(所有面包店: {:?}, all_bakeries); // 2. 根据主键查询[reference:6] let bakery_by_id: Optionbakery::Model Bakery::find_by_id(new_bakery_id).one(db).await?; if let Some(bakery) bakery_by_id { println!(根据ID查询结果: {:?}, bakery); } // 3. 带条件查询[reference:7] let sad_bakery: Optionbakery::Model Bakery::find() .filter(bakery::Column::Name.eq(Sad Bakery)) .one(db) .await?; if let Some(bakery) sad_bakery { println!(根据名字 Sad Bakery 查询结果: {:?}, bakery); } // --- 更新 (Update) --- // 1. 先查询出要更新的模型然后转换为 ActiveModel[reference:8] let mut sad_bakery_active: bakery::ActiveModel Bakery::find_by_id(new_bakery_id) .one(db) .await? .unwrap() // 为了演示假设一定存在 .into(); // 将 Model 转换为 ActiveModel // 修改字段值 sad_bakery_active.name Set(Sad Bakery.to_owned()); // 执行更新 let updated_bakery: bakery::Model sad_bakery_active.update(db).await?; println!(更新后的数据: {:?}, updated_bakery); // 2. 批量更新[reference:9] use sea_orm::{QueryFilter, Condition}; let update_result Bakery::update_many() .col_expr(bakery::Column::ProfitMargin, sea_orm::Expr::value(10.0)) .filter(bakery::Column::Name.contains(Sad)) .exec(db) .await?; println!(批量更新影响行数: {}, update_result.rows_affected); // --- 删除 (Delete) --- // 根据条件删除[reference:10] let delete_result Bakery::delete_many() .filter(bakery::Column::Name.eq(Sad Bakery)) .exec(db) .await?; println!(删除影响行数: {}, delete_result.rows_affected); Ok(()) }5. 高级特性示例关联查询 (Relations)SeaORM 支持定义实体间的关系并能进行懒加载Lazy Loading和预加载Eager Loading。rust// 假设已定义 cake 和 fruit 实体且 cake 与 fruit 是一对多关系 // 懒加载先查 Cake再查其关联的 Fruit[reference:12] let cheese_cake: Optioncake::Model Cake::find_by_id(1).one(db).await?; if let Some(cake) cheese_cake { let fruits: Vecfruit::Model cake.find_related(fruit::Entity).all(db).await?; println!(Cakes fruits: {:?}, fruits); } // 预加载一次性查询 Cake 及其关联的 Fruit[reference:13] let cakes_with_fruits: Vec(cake::Model, Vecfruit::Model) Cake::find().find_with_related(fruit::Entity).all(db).await?;事务 (Transactions)SeaORM 通过DatabaseTransaction支持事务。rustuse sea_orm::{TransactionTrait}; let txn db.begin().await?; // 在事务内执行多个操作... let bakery bakery::ActiveModel { /* ... */ }.insert(txn).await?; // ... 其他操作 txn.commit().await?; // 提交事务 // 或 txn.rollback().await?; // 回滚事务嵌套 ActiveModel (Nested ActiveModel)SeaORM 2.0 引入的Nested ActiveModel允许你一次性保存一个包含关联数据的复杂对象树。例如一次性插入一个用户及其个人资料、帖子和标签。rustlet user user::ActiveModel::builder() .set_name(Bob) .set_email(bobsea-ql.org) .set_profile(profile::ActiveModel::builder().set_picture(image.jpg)) .add_post( post::ActiveModel::builder() .set_title(Nice weather) .add_tag(tag::ActiveModel::builder().set_tag(sunny)), ) .save(db) .await?;总结这个示例涵盖了 SeaORM 的核心用法实体定义使用#[derive(DeriveEntityModel)]等宏将 Rust 结构体映射到数据库表。数据库连接通过Database::connect创建连接池。增删改查 (CRUD)通过Entity和ActiveModel提供的insert、find、update、delete等方法进行操作。高级功能支持关联查询、事务和嵌套 ActiveModel。SeaORM 的官方文档非常详尽包含了从安装到高级特性的完整指南。你可以将其作为后续深入学习的参考。