内容介绍

目标

本专题使用的是 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 为例，将自动为其生成以下方法：

/// 插入
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>;

pub enum UserFindBy {
    Id(String),
    Email(String),
}

pub struct UserFindFilter {
    pub by: UserFindBy,
}

pub struct UserListFilter {
    pub page: u32,
    pub page_size: u32,
    pub email: Option<String>,
    pub nickname: Option<String>,
}

pub struct UserPaginate {
    pub page: u32,
    pub page_size: u32,
    pub total: u32,
    pub total_page: u32,
    pub data: Vec<User>,
}