Update test case

Author: chungquantin

.DS_Store

@@ -45,6 +45,5 @@ path-absolutize = "3.0.14"
 [dev-dependencies]
 tokio = { version = "1.21.2", features = ["macros", "rt"] }
 
-
 [lib]
 name = "db"

Cargo.lock

@@ -5,19 +5,10 @@ use lazy_static::lazy_static;
 #[derive(Hash, PartialEq, Eq)]
 pub enum ColumnFamily {
 	TestSuite,
-	Edge,
-	VertexProperty,
-	Property,
-	Vertex,
 }
 
 lazy_static! {
-	pub static ref COLUMN_FAMILIES: HashMap<ColumnFamily, String> = HashMap::from([
-		(ColumnFamily::TestSuite, "test_suite:v1".to_string()),
-		(ColumnFamily::Edge, "edges:v1".to_string()),
-		(ColumnFamily::VertexProperty, "vertex-properties:v1".to_string()),
-		(ColumnFamily::Property, "properties:v1".to_string()),
-		(ColumnFamily::Vertex, "vertices:v1".to_string())
-	]);
+	pub static ref COLUMN_FAMILIES: HashMap<ColumnFamily, String> =
+		HashMap::from([(ColumnFamily::TestSuite, "test_suite:v1".to_string()),]);
 	pub static ref CF_NAMES: Vec<&'static String> = COLUMN_FAMILIES.values().collect();
 }

db/Cargo.toml

@@ -119,7 +119,7 @@ mod test {
 
 	#[tokio::test]
 	async fn should_create() {
-		let db = Datastore::new("redb:../temp/v1.redb");
+		let db = Datastore::new("redb:../temp/redb");
 		assert!(db.transaction(false).await.is_ok());
 
 		let key1 = i32::to_be_bytes(2001);
@@ -134,6 +134,8 @@ mod test {
 		tx.set(key1, val1, tag!()).await.unwrap();
 		tx.set(key2, val2, tag!()).await.unwrap();
 		tx.set(key3, val3, tag!()).await.unwrap();
+		let iter = tx.iterate(tag!()).await.unwrap();
+		assert!(iter.len() == 3);
 		tx.commit().await.unwrap();
 	}
 
@@ -157,6 +159,8 @@ mod test {
 		tx.set(key1, val1, tags.clone()).await.unwrap();
 		tx.set(key2, val2, tags.clone()).await.unwrap();
 		tx.set(key3, val3, tags.clone()).await.unwrap();
+		let iter = tx.iterate(tags.clone()).await.unwrap();
+		assert!(iter.len() == 3);
 		tx.commit().await.unwrap();
 	}
 }

db/src/constant/cf.rs

@@ -7,8 +7,8 @@ pub use tx::*;
 pub use ty::*;
 
 use crate::{
-	util::generate_path, DBTransaction, DatastoreAdapter, Error, StorageAdapter,
-	StorageAdapterName, StorageVariant,
+	util::{generate_path, get_absolute_path},
+	DBTransaction, DatastoreAdapter, Error, StorageAdapter, StorageAdapterName, StorageVariant,
 };
 pub struct ReDBAdapter(StorageAdapter<DBType>);
 
@@ -20,7 +20,8 @@ impl ReDBAdapter {
 
 	pub fn new(path: &str) -> Result<ReDBAdapter, Error> {
 		let path = &path["redb:".len()..];
-		let db_instance = unsafe { Database::create(path).unwrap() };
+		let abs_path = get_absolute_path(path);
+		let db_instance = unsafe { Database::create(abs_path.as_str()).unwrap() };
 
 		Ok(ReDBAdapter(StorageAdapter::<DBType>::new(
 			StorageAdapterName::ReDB,

db/src/storage/ds.rs

@@ -2,7 +2,7 @@
   "databases": [
     {
       "name": "rocksdb",
-      "path": "../temp"
+      "path": "../temp/cf"
     },
     {
       "name": "redb",