cache

examples/dynamic.rs

@@ -0,0 +1,62 @@
+use std::fs;
+use std::sync::Arc;
+
+use fusio::path::Path;
+use tonbo::executor::tokio::TokioExecutor;
+use tonbo::record::{Datatype, DynRecord, DynSchema, Value, ValueDesc};
+use tonbo::{DbOption, DB};
+
+#[tokio::main]
+async fn main() {
+    fs::create_dir_all("./db_path/users").unwrap();
+
+    let schema = DynSchema::new(
+        vec![
+            ValueDesc::new("foo".into(), Datatype::String, false),
+            ValueDesc::new("bar".into(), Datatype::Int32, true),
+        ],
+        0,
+    );
+
+    let options = DbOption::from((
+        Path::from_filesystem_path("./db_path/users").unwrap(),
+        &schema,
+    ));
+    let db = DB::with_schema(options, TokioExecutor::new(), schema)
+        .await
+        .unwrap();
+
+    {
+        let mut txn = db.transaction().await;
+        txn.insert(DynRecord::new(
+            vec![
+                Value::new(
+                    Datatype::String,
+                    "foo".into(),
+                    Arc::new("hello".to_owned()),
+                    false,
+                ),
+                Value::new(Datatype::Int32, "bar".into(), Arc::new(1), true),
+            ],
+            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();
+}