tonbo 0.3.2

An embedded persistent KV database in Rust.
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

use std::{fs, sync::Arc};

use fusio::path::Path;
use tonbo::{
    dyn_record, dyn_schema,
    executor::tokio::TokioExecutor,
    record::{DataType, Value},
    DbOption, DB,
};

#[tokio::main]
async fn main() {
    fs::create_dir_all("./db_path/users").unwrap();

    let schema = dyn_schema!(("foo", String, false), ("bar", Int32, true), 0);

    let options = DbOption::new(
        Path::from_filesystem_path("./db_path/users").unwrap(),
        &schema,
    );
    let db = DB::new(options, TokioExecutor::current(), schema)
        .await
        .unwrap();

    {
        let mut txn = db.transaction().await;
        txn.insert(dyn_record!(
            ("foo", String, false, "hello".to_owned()),
            ("bar", Int32, true, 1),
            0
        ));

        txn.commit().await.unwrap();
    }

    db.get(
        &Value::new(
            DataType::String,
            "foo".into(),
            Arc::new("hello".to_owned()),
            false,
        ),
        |v| {
            let v = v.get();
            println!("{:?}", v.columns[0].value.downcast_ref::<String>());
            Some(())
        },
    )
    .await
    .unwrap();
}