Rust语言从入门到精通系列 - SeaORM框架实战(数据库DML篇)

SeaORM是一个Rust语言的ORM框架,提供了简单易用的API,可以帮助我们轻松地操作数据库。SeaORM支持多种数据库,包括MySQL、PostgreSQL、SQLite等等。
在本教程中,我们将以Animal实体为例,介绍SeaORM的基本用法,包括创建表、增删改查等操作。
准备工作
在MySQL中创建一个名为animals的数据库,并在其中创建一个名为animal的表,用于存储动物的信息。表结构如下:
CREATE TABLE `animal` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(255) NOT NULL, `age` int(11) NOT NULL, `species` varchar(255) NOT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;定义 Entity
在SeaORM中,我们可以通过定义实体来操作数据库。实体通常对应着数据库中的一张表。在本例中,我们需要创建一个Animal实体,对应着animal表。
首先,我们需要在Cargo.toml中添加SeaORM和MySQL驱动程序的依赖:
[dependencies]sea-orm = "0.11.3"然后,在src目录下创建一个名为animal.rs的文件,定义Animal实体:
use sea_orm::entity::prelude::*;
#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]#[sea_orm(table_name = "animal")]pub struct Animal { #[sea_orm(primary_key)] pub id: i32, pub name: String, pub age: i32, pub species: String,}这里我们使用了derive宏来自动生成Animal实体的代码。其中,#[sea_orm(table_name = "animal")]表示Animal实体对应的表名为animal;#[sea_orm(primary_key)]表示id字段为主键。
有了Animal实体之后,我们就可以使用SeaORM提供的API来操作数据库了。下面分别介绍如何进行增删改查操作。
增加记录
要增加一条记录,我们可以使用Animal::insert()方法。例如,要添加一只名为“Tom”的2岁猫,可以这样写:
use sea_orm::{Database, EntityTrait, FromQueryResult};
let database_url = "mysql://root:password@localhost:3306/animals";let db = Database::connect(database_url).await.unwrap();
let animal = Animal { id: 0, name: "Tom".to_owned(), age: 2, species: "cat".to_owned(),};
let inserted_animal = Animal::insert(&animal).exec(&db).await.unwrap();这里我们首先连接到了名为animals的MySQL数据库,然后创建了一只名为“Tom”的2岁猫,使用Animal::insert()方法将其插入到数据库中,最后返回插入的记录。
删除记录
要删除一条记录,我们可以使用Animal::delete()方法。例如,要删除id为1的记录,可以这样写:
use sea_orm::{Database, EntityTrait, FromQueryResult};
let database_url = "mysql://root:password@localhost:3306/animals";let db = Database::connect(database_url).await.unwrap();
let deleted_animal = Animal::delete() .filter(animal::Column::Id.eq(1)) .exec(&db) .await .unwrap();这里我们使用Animal::delete()方法删除了id为1的记录,使用filter()方法指定了要删除的记录,最后返回删除的记录。
更新记录
要更新一条记录,我们可以使用Animal::update()方法。例如,要将id为1的记录的年龄改为3岁,可以这样写:
use sea_orm::{Database, EntityTrait, FromQueryResult};
let database_url = "mysql://root:password@localhost:3306/animals";let db = Database::connect(database_url).await.unwrap();
let updated_animal = Animal::update() .set(animal::Column::Age, 3) .filter(animal::Column::Id.eq(1)) .exec(&db) .await .unwrap();这里我们使用Animal::update()方法更新了id为1的记录,使用set()方法指定了要更新的字段,最后返回更新后的记录。
查询记录
要查询记录,我们可以使用Animal::find()方法。例如,要查询所有名字为“Tom”的动物,可以这样写:
use sea_orm::{Database, EntityTrait, FromQueryResult};
let database_url = "mysql://root:password@localhost:3306/animals";let db = Database::connect(database_url).await.unwrap();
let animals = Animal::find() .filter(animal::Column::Name.eq("Tom")) .all(&db) .await .unwrap();这里我们使用Animal::find()方法查询了所有名字为“Tom”的动物,使用filter()方法指定了查询条件,最后返回查询结果。
联表查询
除了基本的增删改查操作之外,SeaORM还支持联表查询。例如,我们可以查询每个物种的平均年龄:
use sea_orm::{Database, EntityTrait, FromQueryResult};
let database_url = "mysql://root:password@localhost:3306/animals";let db = Database::connect(database_url).await.unwrap();
let avg_age_by_species = Animal::find() .group_by(animal::Column::Species) .select((animal::Column::Species, Avg(animal::Column::Age))) .all(&db) .await .unwrap();这里我们使用Animal::find()方法查询了所有动物的信息,使用group_by()方法指定了分组条件,使用select()方法指定了要查询的字段和聚合函数,最后返回查询结果。
总结
本教程介绍了SeaORM的基本用法,包括创建实体、增删改查等操作。SeaORM提供了简单易用的API,可以帮助我们轻松地操作数据库。同时,SeaORM还支持多种数据库,包括MySQL、PostgreSQL、SQLite等等。
在实际开发中,我们可以根据需要选择不同的数据库和ORM框架。SeaORM是一个不错的选择,它提供了很多有用的功能,可以帮助我们更加高效地开发应用程序。
支持与分享
如果这篇文章对你有帮助,欢迎分享给更多人或赞助支持!