wbftree 0.1.2

BfTree ordered range index with multi-tree registry and chunked migration / BfTree 有序范围索引，含多树注册表与分块迁移
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

use aok::{OK, Result};
use wbftree::{
  BfTreeConfig, BfTreeDeleteResult, BfTreeInsertResult, BfTreeReadResult, BfTreeService,
  StorageBackend, StorageBackendType,
};

use super::common::TempTreeGuard;

/// 测试创建磁盘支持的 BfTree 实例及安全释放（对照 test/standalone/BfTreeInterop.test/BfTreeInteropTests.cs:CreateAndDispose）
#[test]
fn test_create_and_dispose() -> Result<()> {
  let path = TempTreeGuard::new("create_dispose");
  {
    let tree = BfTreeService::open_disk(&path, 4)?;
    assert_eq!(tree.storage_backend(), StorageBackendType::Disk);
  }
  OK
}

/// 测试使用自定义配置创建 BfTree 实例（对照 test/standalone/BfTreeInterop.test/BfTreeInteropTests.cs:CreateWithCustomConfig）
#[test]
fn test_create_with_custom_config() -> Result<()> {
  let path = TempTreeGuard::new("custom_cfg");
  {
    let mut config = BfTreeConfig::default();
    config
      .file_path(&path)
      .cb_size_byte(16 * 1024 * 1024)
      .cb_min_record_size(8)
      .cb_max_record_size(4096)
      .cb_max_key_len(128)
      .leaf_page_size(16384);
    let tree = BfTreeService::new(config)?;
    assert_eq!(tree.storage_backend(), StorageBackendType::Disk);
  }
  OK
}

/// 测试创建纯内存 BfTree 实例及基础读写（对照 test/standalone/BfTreeInterop.test/BfTreeInteropTests.cs:CreateMemoryOnly）
#[test]
fn test_create_memory_only() -> Result<()> {
  let tree = BfTreeService::open_memory(4)?;
  assert_eq!(tree.storage_backend(), StorageBackendType::Memory);
  let res = tree.insert(b"testkey", b"testval");
  assert_eq!(res, BfTreeInsertResult::Success);
  let (read_res, val) = tree.read(b"testkey");
  assert_eq!(read_res, BfTreeReadResult::Found);
  assert_eq!(val, Some(b"testval".to_vec()));
  OK
}

/// 测试磁盘后端缺失文件路径时抛出配置错误（对照 test/standalone/BfTreeInterop.test/BfTreeInteropTests.cs:CreateDiskBacked_MissingPath_Throws）
#[test]
fn test_create_disk_backed_missing_path_throws() -> Result<()> {
  let mut config = BfTreeConfig::default();
  config.storage_backend(StorageBackend::Std);
  let res = BfTreeService::new(config);
  assert!(res.is_err());
  OK
}

/// 测试对已释放的 BfTree 重复调用 dispose 具备幂等性（对照 test/standalone/BfTreeInterop.test/BfTreeInteropTests.cs:DoubleDispose_DoesNotThrow）
#[test]
fn test_double_dispose_does_not_throw() -> Result<()> {
  let path = TempTreeGuard::new("double_dispose");
  let tree = BfTreeService::open_disk(&path, 4)?;
  tree.dispose();
  tree.dispose();
  OK
}

/// 测试对已释放的 BfTree 执行读写删除操作均被安全拒绝（对照 test/standalone/BfTreeInterop.test/BfTreeInteropTests.cs:OperationsOnDisposedTree_Throw）
#[test]
fn test_operations_on_disposed_tree_throw() -> Result<()> {
  let path = TempTreeGuard::new("op_disposed");
  let tree = BfTreeService::open_disk(&path, 4)?;
  tree.dispose();

  assert_eq!(
    tree.insert(b"k", b"v"),
    BfTreeInsertResult::InvalidArguments
  );
  let (res, _) = tree.read(b"k");
  assert_eq!(res, BfTreeReadResult::InvalidArguments);
  assert_eq!(tree.delete(b"k"), BfTreeDeleteResult::InvalidArguments);

  OK
}