unreql 0.2.1

Well documented and easy to use RethinkDB Rust Driver
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use futures::TryStreamExt;
use serde_json::Value;
use unreql::{cmd::options::RandomOptions, r};

#[tokio::test]
async fn random_query() -> unreql::Result<()> {
    let conn = r.connect(()).await?;
    let mut query = r.random(()).run(&conn);
    let val: Option<Value> = query.try_next().await?;
    assert!(val.is_some());
    dbg!(val);
    Ok(())
}

#[tokio::test]
async fn random_one_arg_query() -> unreql::Result<()> {
    let conn = r.connect(()).await?;
    let mut query = r.random(100).run(&conn);
    let val: Option<Value> = query.try_next().await?;
    assert!(val.is_some());
    dbg!(val);
    Ok(())
}

#[tokio::test]
async fn random_one_arg_with_opts_query() -> unreql::Result<()> {
    let conn = r.connect(()).await?;
    let opts = RandomOptions { float: Some(true) };
    let mut query = r.random(r.with_opt(100, opts)).run(&conn);
    let val: Option<Value> = query.try_next().await?;
    assert!(val.is_some());
    dbg!(val);
    Ok(())
}

#[tokio::test]
async fn random_two_args_query() -> unreql::Result<()> {
    let conn = r.connect(()).await?;
    let mut query = r.random(r.args([100, 200])).run(&conn);
    let val: Option<Value> = query.try_next().await?;
    assert!(val.is_some());
    dbg!(val);
    Ok(())
}

#[tokio::test]
async fn random_two_args_with_opts_query() -> unreql::Result<()> {
    let conn = r.connect(()).await?;
    let opts = RandomOptions { float: Some(true) };
    let mut query = r.random(r.with_opt(r.args([100, 200]), opts)).run(&conn);
    let val: Option<Value> = query.try_next().await?;
    assert!(val.is_some());
    dbg!(val);
    Ok(())
}