使用 default-features = false 禁用默认使用的tokio,自行选择运行时跟数据库类型
toml
[dependencies]
sqlx-model = { version = "~0.0.1-beta.15", path = "../../",default-features = false,features = ["sqlx-mysql"] }
sqlx = {version = "~0.5",features = [ "mysql","offline","runtime-async-std-native-tls"] }
async-std={version = "1.10.0", features = [ "attributes" ]}
使用前准备，结构体增加derive宏
使用 sqlx_model::SqlxModel 宏 自动增加辅助方法 同时会创建 UserModelRef 的结构，用于辅助增删改查操作
rsmodel文件,以下工具可用:https://crates.io/crates/sqlx-model-tools 具体使用方式参考该create文档
```rust
//#[sqlx(rename_all="lowercase")] //按规则自定义字段名
pub struct UserModel {
#[sqlx(default)]
pub id: u32,
#[sqlx(default)]
pub nickname: String,
#[sqlx(default)]
pub gender: u8,
#[sqlx(default)]
pub headimg: Option
更多使用方法参考 tests 目录
rust
let nike_name="new insert".to_string();
let gender=1;
let userinsert=sqlx_model::model_option_set!(UserModelRef,{
nickname:nike_name,
gender:gender,
//不需要全部字段赋值，没赋值生成SQL会少对应字段，等于用表中默认值
});
let i1=Insert::<sqlx::MySql,UserModel,_>::new(userinsert).execute(&db).await.unwrap();
assert!(i1.last_insert_id()>0);
更多使用方法参考 tests 目录
rust
let select=Select::type_new::<UserModel>();
let user=select.fetch_one_by_where::<UserModel>(Some(format!("id=1")), &db).await.unwrap();
let detete=Delete::<sqlx::MySql>::new(UserModel::table_name())
.execute_by_pk(&user, &db)
.await.unwrap();
assert_eq!(detete.rows_affected(),1);
更多使用方法参考 tests 目录
rust
let nike_name="change to 1".to_string();
let userchange=sqlx_model::model_option_set!(UserModelRef,{
nickname:nike_name,
});
let update=Update::<sqlx::MySql,UserModel,_,_>::new(userchange);
let update=update.execute_by_scalar_pk(1,&db).await.unwrap();
assert_eq!(update.rows_affected(),1);
更多使用方法参考 tests 目录
rust
let select=Select::type_new::<UserModel>();
let user=select.fetch_one_by_scalar_pk::<UserModel,_,_>(iid, &db).await.unwrap();
assert_eq!(user.id as u64,iid);
更多使用方法参考 tests 目录
rust
let mut ta=db.begin().await.unwrap();
let nike_name="new tran".to_string();
let userinsert=sqlx_model::model_option_set!(UserModelRef,{
nickname:nike_name,
gender:11,
});
Insert::<sqlx::MySql,UserModel,_>::new(userinsert).execute(&mut ta).await.unwrap();
//其他 查删改操作...
ta.commit().await.unwrap();
rust
fn my_exec(transaction:Option<&mut Transaction<'t,sqlx::MySql>>){
let pool=get_db_pool();
let res=executor_option!({
// transaction 为 None 用 &pool 代替 db 如果 [因为execute为泛型且为&mut,多次时需要手动调用as_copy]
// 否则为 transaction 里的值代替 db
Insert::<sqlx::MySql, UserEmailModel, _>::new(idata).execute(db.as_copy()).await?
},transaction,&pool,db);
}
绑定SQL查询可以用到SQLX内部查询SQL缓存,会快少许
rust
let data=["dd","b'bb"];
let password_id=Some(1);
let sql=sql_format!(
"select * from yaf_users where id>{id} {in_grade} and password_id {password_where} ",
id=1,
in_grade=sql_array_str!("and grade in ({})",data),
password_where=sql_option_str!("= {}","is {}",password_id)
);
println!("{}",sql);//select * from yaf_users where id>1 and grade in ('dd','b\'bb') and password_id = 1
//会转义'防止sql注入
rust
let (sql,bind_res)=sqlx_model::sql_bind!(sqlx::MySql,"id>{id}");
let _= Select::type_new::<UserModel>().fetch_one_by_where_call::<UserModel,_,_>(sql,|mut query_res,_|{
sqlx_model::sql_bind_vars!(bind_res,query_res,{
"id":1
})
}, &pool).await.unwrap();