2 releases
0.1.1 | Mar 9, 2024 |
---|---|
0.1.0 | Jan 21, 2024 |
#6 in #rethink-db
56 downloads per month
Used in 2 crates
(via unreql)
17KB
485 lines
Unofficial RethinkDB Driver for Rust
Well documented and easy to use
Motivation
The official driver is difficult to support, awkward to use, and has little to no documentation or examples. Therefore, an attempt was made by me to remedy these shortcomings
Install
$ cargo add unreql
or
[dependencies]
unreql = "0.1.8"
Import
use unreql::r;
Connect
let conn = r.connect(()).await?;
Get data
Get by ID
let user: User = r.table("users").get(1).exec(&conn).await?;
Get all data
let users: Vec<User> = r.table("users").exec_to_vec(&conn).await?;
or
let mut cur = r.table("users").run(&conn);
let mut users: Vec<User> = vec![];
while let Ok(Some(user)) = cur.try_next().await? {
users.push(user);
}
Update data
Use a nested reql query
r.table("users")
.get(1)
.update(rjson!({
"name": "John",
"upd_count": r.row().g("upd_count").add(1),
}))
.run(&conn);
Use connection pool
Implemented session manager for async deadpool
use unreql::{r, cmd::connect};
use unreql_deadpool::{IntoPoolWrapper, SessionManager};
use deadpool::managed::Pool;
// config to connect to rethinkdb
let config = connect::Options::default();
// new session manager
let manager = SessionManager::new(config);
// create a pool that is wrapped for ease of use (to be able to be passed to `.run(&pool)`)
let pool = Pool::builder(manager).max_size(20).build().unwrap().wrapper();
// now you can to pass `pool` to `.run()` and `.exec()`
let user: User = r.table("users").get(1).exec(&pool).await?;
Dependencies
~2MB
~44K SLoC