diff --git a/lib/tools/dbs-tools/src/kv_db_old.rs b/lib/tools/dbs-tools/src/kv_db_old.rs index a061e68766c683d52c11dc5befa7d8bfab2b6b2d..e7fd6271fae88403c2eacd230cc25fbbcfa2f3a0 100644 --- a/lib/tools/dbs-tools/src/kv_db_old.rs +++ b/lib/tools/dbs-tools/src/kv_db_old.rs @@ -13,3 +13,36 @@ pub use rkv::{ store::multi::Iter, IntegerStore, MultiIntegerStore, MultiStore, OwnedValue as KvFileDbOwnedValue, Readable, SingleStore, Value as KvFileDbValue, }; + +#[cfg(test)] +mod tests { + + use super::*; + use sled::Config; + use std::thread; + use tempfile::tempdir; + + #[test] + fn test_tmp_sled() { + //let tmp_dir = tempdir().expect("fail to create tmpdir."); + let db = sled::Config::default() + .path("test_sled_db".to_owned()) + .open() + .expect("fail to open sled DB."); + + db.insert(b"k1", b"v1").expect("db error"); + assert_eq!(&db.get(b"k1").expect("db error").expect("no value"), b"v1"); + + let _ = thread::spawn(move || { + let db2 = sled::Config::default() + .path("test_sled_db".to_owned()) + .open() + .expect("fail to open sled DB."); + + assert_eq!(&db2.get(b"k1").expect("db error").expect("no value"), b"v1"); + }); + + db.insert(b"k2", b"v2").expect("db error"); + assert_eq!(&db.get(b"k2").expect("db error").expect("no value"), b"v2"); + } +}