use orm_mysql::{OrmMySql};
use orm_mysql::mysql::OrmMySqlTrait;
#[tokio::main]
async fn main() -> common_uu::IResult {
let ref pool: mysql_async::Pool = mysql_async::Pool::new("mysql://username:pwd@ip:port/db_name");
let mut conn: mysql_async::Conn = pool.get_conn().await?;
let mut tx = pool.start_transaction(mysql_async::TxOpts::new()).await?;
let list = UserData::query(&mut conn, "where 1 != 1", None).await?;
println!("find count: {}", list.len());
let list = UserData::query(&mut tx, "where 1=1", Some(1000)).await?;
println!("find count: {}", list.len());
let one = UserData::query_first(&mut tx, "where 1=1").await?;
println!("find count: {:?}", one.is_some());
Ok(())
}
#[derive(OrmMySql)]
#[orm_mysql(table_name=users)] struct UserData {
#[orm_mysql(id)]
user_id: i64,
username: String,
}