域名 AXUM.RS 将于 2025 年 10 月到期。我们无意再对其进行续费,如果你有意接续这个域名,请与我们取得联系。
  • AXUM.RS 现仅需人民币 3000 元(大写:叁仟元整。接受适度议价
  • 按照行业规则,AXUM.RS 到期后,大概率会进入长时间的赎回期,该期间内,如果你想拥有该域名,将要付出高额的费用
  • 我们已启用 AXUM.EU.ORG 域名,并将持续运营
  • 仅接受微信或支付宝交易
如果你对 AXUM.RS 有兴趣,请和我们进行联系:

实现更新和删除方法

有了上一章的基础,我们实现更新和删除方法也不是难事。

pub(crate) fn update_ts(dm: &DbMeta) -> proc_macro2::TokenStream {
    let field_list = dm.update_fileds();
    let field_list_str = field_list
        .iter()
        .map(|f| format!("{:?} = ", f.to_string()))
        .collect::<Vec<_>>();
    let field_list_com = field_list
        .iter()
        .enumerate()
        .map(|(idx, _)| format!("{}", if idx < field_list.len() - 1 { ", " } else { "" }))
        .collect::<Vec<_>>();

    let table = dm.table.clone();
    let sql = format!("UPDATE {:?} SET ", &table,);
    let pk = dm.pk_ident().clone();
    let pk_str = pk.to_string();

    quote! {
        pub async fn update<'a>(&self, e: impl  ::sqlx::PgExecutor<'a>) -> ::sqlx::Result<u64> {
            let sql = #sql;
            let mut q = ::sqlx::QueryBuilder::new(sql);
            #(
                q.push(#field_list_str)
                .push_bind(&self.#field_list)
                .push(#field_list_com);
            )*

            q.push(format!(" WHERE {} = ", #pk_str)).push_bind(&self.#pk);

            let aff = q.build().execute(e).await?.rows_affected();
            Ok(aff)
        }
    }
}
pub(crate) fn del_ts(dm: &DbMeta) -> proc_macro2::TokenStream {
    let table = dm.table.clone();
    let pk = dm.pk_ident().clone();
    let pk_str = pk.to_string();
    let sql = format!("DELETE FROM {:?} WHERE {:?} = ", &table, &pk_str);

    quote! {
        pub async fn delete<'a>(&self, e: impl  ::sqlx::PgExecutor<'a>) -> ::sqlx::Result<u64> {
            let sql = #sql;
            let mut q = ::sqlx::QueryBuilder::new(sql);
            q.push_bind(&self.#pk);
            let aff = q.build().execute(e).await?.rows_affected();
            Ok(aff)
        }
    }
}

本章代码位于04/实现更新和删除分支。

要查看完整内容,请先登录