![Latest Version]
rust
// Cargo.toml
serde = { version = "1.0", features = ["derive"] }
arel = { version = "0.3", features = ["runtime-tokio-native-tls", "sqlite"] } // sqlte | mysql | postgres
```rust use arel::prelude::*;
struct User {
#[arel(primarykey)]
id: i64,
name: String,
#[arel(rename = "type")]
r#type: String,
expiredat: Option
// init db from Environment std::env::setvar("DATABASEURL", "sqlite::memory:"); arel::db::visitor::init().await?; // or init db from code arel::db::visitor::getorinit(|| Box::pin(async { arel::db::DatabasePoolOptions::new().max_connections(5).connect("sqlite::memory:").await })).await?;
// total count let count = User::query().selectsql("COUNT(*)").fetchcount().await?; println!("total: {}", count);
// create let mut user = User { name: Set("n1"), ..Default::default() }; user.save().await?;
// select
let user = User::query().r#where("id", 1).fetchone().await?;
let uesrs: Vec
// update let mut user: User = User::query().fetchone().await?; // activeuser.name.set("n-1"); user.assign(&User { name: Set("n-1"), ..Default::default() }); user.save().await?;
// destroy user.destroy().await?; ```
select
rust
User::query().select(vec!(["id", "name"])).to_sql();
where
rust
let sql = User::query().r#where("name", "n1").r#where("id", 1).to_sql();
// where_not
let sql = User::query().where_not(id: vec![1, 2, 3]).to_sql();
// where_range
let sql = User::query().where_range("age", 18..25).to_sql();
joins
rust
let sql = User::query().join::<Wallet>(arel::JoinConst::InnerJoin).to_sql();
let sql = User::query().join_sql("INNER JOIN wallet on user.id = wallet.user_id").to_sql();
lock
rust
// should use in transaction
let user: User = User::query().r#where("name", "n1").lock().fetch_one_with_exec(tx);
group & having
rust
let sql = User::query().group(vec!["name"]).having("age", 18..).to_sql();
order
rust
let sql = User::query().order("created_at", arel::SortConst::Desc).to_sql();
let sql = User::query().order_asc().to_sql();
let sql = User::query().order_desc().to_sql();
limit & offset
rust
let sql = User::query().limit(10).to_sql();
let sql = User::query().offset(10)();
let sql = User::query().paginate(1, 10).to_sql();
transaction
rust
User::with_transaction(|tx| {
Box::pin(async move {
// for entry in 1i32..=100 {
// sqlx::query("INSERT INTO user (name) VALUES ($1)")
// .bind(format!("name-{}", entry))
// .bind("Admin")
// .execute(tx.as_mut())
// .await?;
// }
let mut user = User {
name: Set("n1"),
r#type: Set("ADMIN"),
..Default::default()
};
user.save_with_tx(tx).await?;
Ok(None)
})
})
.await?;
increment
rust
let user = User::query().r#where("id", 1).fetch_one().await?;
user.increment("lock_version", 5).await?;