域名 AXUM.RS 将于2025年10月到期。我们无意再对其进行续费,我们希望你能够接续这个域名,让更多 AXUM 开发者继续受益。
  • 方案1️⃣AXUM.RS 域名 = 3000
  • 方案2️⃣方案1️⃣ + 本站所有专题原始 Markdown 文档 = 5000
  • 方案3️⃣方案2️⃣ + 本站原始数据库 = 5500
如果你有意接续这份 AXUM 情怀,请与我们取得联系。
说明:
  1. 如果有人购买 AXUM.RS 域名(方案1️⃣),或者该域名到期,本站将启用新的免费域名继续提供服务。
  2. 如果有人购买了 AXUM.RS 域名,且同时购买了内容和/或数据库(方案2️⃣/方案3️⃣),本站将关闭。届时我们或许会以另一种方式与你再相遇。

内容介绍

目标

  • 实现 CRUD,基于 sqlx
  • 实现自定义表名、主键及是否为视图
  • 实现某些字段跳过插入
  • 实现某些字段跳过更新
  • 实现查找单条记录的过滤条件,并可指定过滤条件是使用 ILIKE 进行模糊查询,还是使用 = 进行精确匹配。
  • 实现记录列表的过滤条件,并可指定过滤条件是使用 ILIKE 进行模糊查询,还是使用 = 进行精确匹配。
  • 实现分页

本专题使用的是 PostgreSQL 数据库,并未对其它数据库做兼容处理。

本专题使用的是 PostgreSQL 数据库,并未对其它数据库做兼容处理。

预览

最终,我们希望达到的效果是:

#[derive(Db)]
#[db(table = "users", pk = "id")]
pub struct User {
    #[db(find)]
    pub id: String,
    
    #[db(find)]
    #[db(list_opt)]
    #[db(opt_like)]
    pub email: String,
    
    pub password: String,
    
    #[db(list_opt)]
    #[db(opt_like)]
    pub nickname: String,
    
    #[db(skip_update)]
    pub dateline: chrono::DateTime<chrono::Local>,
}

#[derive(Db)]
#[db(table = "messages", pk = "id")]
pub struct Message {
    #[db(find)]
    #[db(skip_insert)]
    pub id: i32,
    
    #[db(list_opt)]
    #[db(skip_update)]
    pub user_id: String,
    
    #[db(list_opt)]
    #[db(opt_like)]
    pub content: String,
    
    #[db(skip_update)]
    pub dateline: chrono::DateTime<chrono::Local>,
    
}

#[derive(Db)]
#[db(table = "v_user_messages", pk = "user_id, message_id", is_view)]
pub struct UserMessage {
    #[db(list_opt)]
    #[db(opt_like)]
    pub email: String,
    
    #[db(list_opt)]
    #[db(opt_like)]
    pub nickname: String,
    
    #[db(find_opt)]
    #[db(list_opt)]
    pub message_id: i32,
    
    #[db(find_opt)]
    #[db(list_opt)]
    pub user_id: String,
    
    #[db(list_opt)]
    #[db(opt_like)]
    pub content: String,
    
    pub dateline: chrono::DateTime<chrono::Local>,
}
/// 插入
User::insert<'a>(&self, e: impl sqlx::PgExecutor<'a>) -> sqlx::Result<String>;

/// 更新
User::update<'a>(&self, e: impl sqlx::PgExecutor<'a>) -> sqlx::Result<u64>;

/// 查找单条
User::find<'a>(e: impl sqlx::PgExecutor<'a>, f:&UserFindFilter) -> sqlx::Result<Option<Self>>;

/// 列表
User::list_data<'a>(e: impl sqlx::PgExecutor<'a>, f:&UserListFilter) -> sqlx::Result<Vec<Self>>;

/// 统计
User::list_count<'a>(e: impl sqlx::PgExecutor<'a>, f:&UserListFilter) -> sqlx::Result<i64>;

/// 分页
User::list(p: &sqlx::PgPool, f:&UserListFilter) -> sqlx::Result<UserPaginate<Self>>;

/// 删除
User::list_count<'a>(e: impl sqlx::PgExecutor<'a>, id:&String) -> sqlx::Result<u64>;
要查看完整内容,请先登录