自己实现基于key-value的NoSQL数据库(二)—— 改进存储方式和查询修改函数

释放双眼,带上耳机,听听看~!

上一篇文章实现的数据库很不方便

一方面基于不同的数据,需要不同的函数用于存取

另一方面数据存储基于数组,大小一开始的固定的,显然不行

这一章来尝试改一改

我们希望这个数据库是动态大小的,能存多少都行

那么一提到这个,第一个想到的应该就是链表了

先来整体看看改动后的smallsql.h

自己实现基于key-value的NoSQL数据库(二)—— 改进存储方式和查询修改函数

可以看到数据采用链表来存储,接口也改为固定的一对get/set了,其余不变
依然来先看看open函数吧


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
1bool smallsql::open(const std::string& sqlPath)
2{
3   FILE* fp = nullptr;
4   m_sqlPath = sqlPath;
5
6   fopen_s(&fp, sqlPath.c_str(), "r");
7   if (fp == nullptr)
8   {
9       return true;
10  }
11
12  SqlDataList* pHead = m_pDatas;
13  SqlDataList* pPre = nullptr;
14
15  while (!feof(fp))
16  {
17      int type = 0;
18      fread_s(&type, 1, 1, 1, fp);
19
20      int key_len = 0;
21      fread_s(&key_len, 1, 1, 1, fp);
22
23      if (key_len == 0)
24      {
25          continue;
26      }
27
28      m_pDatas = new SqlDataList;
29      m_pDatas->pNext = nullptr;
30      m_pDatas->type = type;
31
32      if (pPre != nullptr)
33      {
34          pPre->pNext = m_pDatas;
35      }
36
37      char* key = new char[key_len + 1];
38      fread_s(key, key_len, key_len, 1, fp);
39      key[key_len] = 0;
40      m_pDatas->key = std::string(key);
41
42      if (type == 0)
43      {
44          SqlData<int>* pItem = new SqlData<int>();
45          fread_s(&pItem->value, 4, 4, 1, fp);
46          m_pDatas->pValue = pItem;
47      }
48      else
49      {
50          SqlData<std::string>* pItem = new SqlData<std::string>();
51          int value_len = 0;
52          fread_s(&value_len, 1, 1, 1, fp);
53          char* value_str = new char[value_len + 1];
54          fread_s(value_str, value_len, value_len, 1, fp);
55          value_str[value_len] = 0;
56          pItem->value = std::string(value_str);
57          delete[] value_str;
58          m_pDatas->pValue = pItem;
59      }
60
61      delete[] key;
62
63      if (pHead == nullptr)
64      {
65          pHead = m_pDatas;
66      }
67
68      pPre = m_pDatas;
69  }
70
71  m_pDatas = pHead;
72
73  fclose(fp);
74
75  return true;
76}
77

1
2
1  和上一章想比,就是改变了数据的读取而已
2

这是改写后的get函数


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
1template<typename T>
2T smallsql::get(const std::string& key)
3{
4   SqlDataList* pData = m_pDatas;
5
6   while (pData != nullptr)
7   {
8       if (pData->key == key)
9       {
10          int type = typeid(T) == typeid(int) ? 0 : 1;
11
12          if (type == pData->type)
13          {
14              SqlData<T>* pItem = static_cast<SqlData<T>*>(pData->pValue);
15              return pItem->value;
16          }
17          else
18          {
19              return T();
20          }
21      }
22
23      pData = pData->pNext;
24  }
25
26  return T();
27}
28

改写后的set函数


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
1template<typename T>
2void smallsql::set(const std::string& key, const T& value)
3{
4   SqlDataList* pHead = m_pDatas;
5   SqlDataList* pPre = nullptr;
6
7   while (m_pDatas != nullptr)
8   {
9       if (m_pDatas->key == key)
10      {
11          delete m_pDatas->pValue;
12          SqlData<T>* pItem = new SqlData<T>();
13          pItem->value = value;
14          m_pDatas->pValue = pItem;
15
16          if (pHead != nullptr)
17          {
18              m_pDatas = pHead;
19          }
20
21          return;
22      }
23      else
24      {
25          pPre = m_pDatas;
26          m_pDatas = m_pDatas->pNext;
27      }
28  }
29
30  SqlData<T>* pItem = new SqlData<T>();
31  pItem->value = value;
32
33  m_pDatas = new SqlDataList;
34  m_pDatas->key = key;
35  m_pDatas->pValue = pItem;
36
37  if (typeid(T) == typeid(int))
38  {
39      m_pDatas->type = 0;
40  }
41  else
42  {
43      m_pDatas->type = 1;
44  }
45
46  m_pDatas->pNext = nullptr;
47
48  if (pPre != nullptr)
49  {
50      pPre->pNext = m_pDatas;
51  }
52
53  if (pHead != nullptr)
54  {
55      m_pDatas = pHead;
56  }
57}
58

1
2
1  新的get和set用模板来当做数据项保存内容,实现一个接口存储,比上一章要好了不少了
2

另外这里的typeid其余可以考虑用模板特化来消除掉

总体来说,这一版改动了数据的存储格式和查询修改的接口

这是1W个数据的时间,相比上一章没什么大的变化因为并没有优化过,10W个数据的时间任然惨不忍睹 哈哈

自己实现基于key-value的NoSQL数据库(二)—— 改进存储方式和查询修改函数

看来当务之急的解决效率问题了,10W个数据的操作80多秒是不能忍受的

下一章就尝试解决这个问题

附上本章代码工程,VS2013

http://pan.baidu.com/s/1sjmMp6P

给TA打赏
共{{data.count}}人
人已打赏
安全运维

OpenSSH-8.7p1离线升级修复安全漏洞

2021-10-23 10:13:25

安全运维

设计模式的设计原则

2021-12-12 17:36:11

个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索