From 46a9a05cb5cab83abbcddfb496b5cda2a87bbc9a Mon Sep 17 00:00:00 2001
From: wangge <ys.wangge@h3c.com>
Date: Wed, 31 Jul 2024 14:56:21 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0lmdb=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E7=94=A8=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 docs/databases/lmdb/tc_lmdb_lmdb_fun_001.yaml |  46 ++++++++++++
 tests/databases/lmdb/students.zip             | Bin 0 -> 885 bytes
 tests/databases/lmdb/tc_lmdb_lmdb_fun_001.py  |  71 ++++++++++++++++++
 3 files changed, 117 insertions(+)
 create mode 100644 docs/databases/lmdb/tc_lmdb_lmdb_fun_001.yaml
 create mode 100644 tests/databases/lmdb/students.zip
 create mode 100644 tests/databases/lmdb/tc_lmdb_lmdb_fun_001.py

diff --git a/docs/databases/lmdb/tc_lmdb_lmdb_fun_001.yaml b/docs/databases/lmdb/tc_lmdb_lmdb_fun_001.yaml
new file mode 100644
index 000000000..b843ce347
--- /dev/null
+++ b/docs/databases/lmdb/tc_lmdb_lmdb_fun_001.yaml
@@ -0,0 +1,46 @@
+作者:     wangge
+优先级:   P0
+支持架构: noarch
+执行方式: 自动
+测试类型: 功能测试
+通用标签: local,lmdb
+用例描述: 测试lmdb基本功能
+修改人:   wangge
+
+前置条件: 
+- 安装lmdb
+- 创建lmdb目录
+- 准备测试所需文件students.zip
+
+测试步骤:
+- ls -l students | grep -E 'data.mdb|lock.mdb'  # 列出 students 目录中的文件并检查是否包含 data.mdb 和 lock.mdb 文件，这有助于用户对目录中的文件进行确认和检查。
+- mdb_stat students/  # 查看 students 目录中的 LMDB 数据库统计信息
+- os.makedirs("students_copy",exist_ok=True)  # 创建名为 students_copy 的目录
+- mdb_copy -c students students_copy  # 复制 students 目录中的 LMDB 数据库到 students_copy 目录
+- mdb_stat students_copy  # 查看 students_copy 目录中的 LMDB 数据库统计信息
+- ent_copy=int([line.split(":")[1].strip() for line in result.stdout.splitlines() if "Entries" in line][0])  # 获取 students_copy 目录中的 Entries 数量
+- rm -fr test  # 删除现有的 test 的文件
+- mdb_dump students -f test  # 将 students 目录中的 LMDB 数据库导出到 test 文件中
+- with open("test", 'r') as f ： lines = f.readlines()  # 统计 test 文件中的行数，将结果存储在变量 len(lines) 中
+- mdb_load -f test -N -T students  # 将 test 文件中的数据加载到名为 students 的 LMDB 数据库中
+- ent = int([line.split(":")[1].strip() for line in result.stdout.splitlines() if "Entries" in line][0])  # 获取 students 目录中的 Entries 数量
+- entries = ent - ent_copy  # 计算加载后的 Entries 数量与复制前的 Entries 数量之差
+- self.assertGreater(entries, 0, "Failed to add new entries to LMDB")  # 检查 Entries 数量的变化是否大于 0"
+
+期望结果:
+- 包含 data.mdb 和 lock.mdb 文件
+- 可以成功查看数据统计信息
+- 创建students_copy目录成功
+- 复制成功
+- 可以成功查看数据统计信息
+- 成功获取 students_copy 目录中的 Entries 数量
+- 删除成功
+- 数据可以导出到test文件内
+- 统计成功，test内容不为0说明数据成功导入到test文件内
+- 加载成功
+- 成功获取 students 目录中的 Entries 数量
+- 计算命令执行成功
+- Entries 数量的变化大于 0
+
+
+
diff --git a/tests/databases/lmdb/students.zip b/tests/databases/lmdb/students.zip
new file mode 100644
index 0000000000000000000000000000000000000000..9fd9ae2036d2e392d072a7e9449f2089a3fcd364
GIT binary patch
literal 885
zcmWIWW@Zs#W&i@u*oaUN4FjA&MsZ1LN@`w7v3>wl83$O|6|<nF`HVpM00ss@WMwId
zC5d{uDM@c{@AW$rAadZNwt)h(xa1tkIlN0F5?(kkby_7f9Sil|q0q_En00{tgQZL@
z*W)wB5{HE~@)zW;^kwdJIjnH<|MV|)bBgo67tii;xFdZ(&Tigzmm803ympE@KC9lk
zrN6b={)+k^%UuO}N?_L>*p>Tt)&Kanm$$F_->>)O_rwK!VDUB4DqC)e3jfrLf9k>o
z7Wtrm^zZxUzg8rFT~}rPR$)@Ha;~<>#XBC`AG<7C_^;mo%%n_9?{~kqGaUcq8Fz|3
z4;(TK((3Pet(Af`q*R@aquef5P6=Ew<@~9%tzm)}mv%K7TZu}>#-B5td-L?uXFFRg
z)=bmBy6g9<o^_p5#C^NgnM!G_UdiShd|LACG1vQ9s}rBc&HR~j(&K0P+rs#nywwXr
zuD_~|)Say_C(`p~Pg3-p@Yl=T)lGx*zp}-iHj_?{z8iUc`>X!H^*UGnFFzXM_wpMk
z<QZ;QXy*6m|BIJ@v!4Mqc9thrAN2yNa8N*tot*sSY;f$H+sN7AAi#2<`t}Ba*(N`_
zj(Fu9<Z_7@aA9_|`!n-_UR2ri%DF*HG*0b(`r}%x{obN#LD8Z=#ouhL+UxGD5(8Ne
z1P;}F0p5&E_RP4_j|xN`gFwSuM-UU9nz$Ggz*3A15)2HT!E>XY-(Y0;cxM@yhVl_c
zV@q=|qZJyKG^!&T4NHMot$<mD!wS@ZL$=~5Fv#JqhXo^XR<N>xyvhuOia<l`m_R%L
DdwMYL

literal 0
HcmV?d00001

diff --git a/tests/databases/lmdb/tc_lmdb_lmdb_fun_001.py b/tests/databases/lmdb/tc_lmdb_lmdb_fun_001.py
new file mode 100644
index 000000000..8e9dd83c6
--- /dev/null
+++ b/tests/databases/lmdb/tc_lmdb_lmdb_fun_001.py
@@ -0,0 +1,71 @@
+#!/usr/bin/env python3
+# -*- encoding: utf-8 -*-
+
+"""
+@File:      tc_lmdb_lmdb_fun_001.py
+@Time:      2024/07/31 17:07:20
+@Author:    wangge
+@Version:   1.0
+@Contact:   YS.wangge@h3c.com
+@License:   Mulan PSL v2
+@Modify:    wangge
+"""
+import os
+import re
+import shutil
+import subprocess
+from pathlib import Path
+from common.basetest import LocalTest
+
+class Test(LocalTest):
+    """
+    See tc_lmdb_lmdb_fun_001.yaml for details
+
+    :avocado: tags=P0,noarch,local
+    """
+    PARAM_DIC = {"pkg_name": "lmdb"}
+    def setUp(self):
+        super().setUp(self.PARAM_DIC)
+        self.current_directory = Path(__file__).parent.resolve()
+        os.chdir(self.current_directory)
+        os.makedirs("lmdb",exist_ok=True) 
+        os.chdir("lmdb")
+        shutil.copy("../students.zip","./")
+        subprocess.run(["unzip","students.zip"])
+
+    def test(self):
+
+        result = subprocess.run(['ls', '-l', "students"], stdout=subprocess.PIPE, text=True)
+        self.assertTrue(re.search(r'data\.mdb', result.stdout) or re.search(r'lock\.mdb', result.stdout), "Neither data.mdb nor lock.mdb found")
+
+        result = subprocess.run(['mdb_stat', "students"], stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        self.assertEqual(result.returncode, 0, "Failed to view LMDB data")
+
+        os.makedirs("students_copy",exist_ok=True)
+        result_copy = subprocess.run(['mdb_copy', '-c', 'students', 'students_copy'], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+        self.assertEqual(result_copy.returncode, 0, f"mdb_copy failed: {result_copy.stderr.decode()}")
+        result_stat = subprocess.run(['mdb_stat', 'students_copy'], stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        self.assertEqual(result_stat.returncode, 0, "Failed to view copied LMDB data")
+        ent_copy = int([line.split(":")[1].strip() for line in result.stdout.splitlines() if "Entries" in line][0])
+
+        self.cmd("rm -fr test")
+        result = subprocess.run(['mdb_dump', "students", '-f', "test"], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+        self.assertEqual(result.returncode, 0, "Failed to export LMDB data")
+
+        with open("test", 'r') as f:
+             lines = f.readlines()
+        self.assertNotEqual(len(lines), 0, "Failed to export LMDB data")
+
+        result = subprocess.run(['mdb_load', '-f', "test", '-N', '-T', "students"], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+        result = subprocess.run(['mdb_stat', "students"], stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        self.assertEqual(result.returncode, 0, "Failed to view LMDB data after import")
+        ent = int([line.split(":")[1].strip() for line in result.stdout.splitlines() if "Entries" in line][0])
+
+        entries = ent - ent_copy
+        self.assertGreater(entries, 0, "Failed to add new entries to LMDB")
+
+    def tearDown(self):
+        super().tearDown(self.PARAM_DIC)
+        os.chdir(self.current_directory)
+        subprocess.run(["rm", "-rf", "lmdb"], check=True)
+        
\ No newline at end of file
-- 
Gitee