【手写数据库内核miniToadb】第1天 模拟数据库流程，分析数据库内核的组成 ...

​专栏内容：
  

• 手写数据库toadb
  本专栏主要介绍怎样从零开发，开发的步骤，以及开发过程中的涉及的原理，遇到的问题等，让大家能跟上并且可以一起开发，让每个需要的人成为参与者，在开源无穷的公众号更新会更及时。
  

  一、概述

---

解析器就是将用户输入的命令字符串转换为程序内部的数据结构，然后就可以执行命令并返回结果。
通过一个简朴的C程序来看一下数据库的解析和执行流程。

二、模拟数据库

---

程序是一个模拟数据库创建表，插入数据，查询数据，删除数据，更新数据等操作，整个数据生存在内存当中，每张表由一个二维数组来存储。
表的数据结构成员有表名、表的字段fields、表中每行的数据records和数据行数。
每个字段界说包罗字段名和字段类型两部分，数组采用固定大小，所以字段和数据行数量都不能超过上限。

1. #include <stdio.h>
2. #include <stdlib.h>
3. #include <string.h>
5. #define MAX_FIELDS 10
6. #define MAX_FIELD_LEN 20
7. #define MAX_RECORDS 100
9. struct field
10. {
11.     char name[MAX_FIELD_LEN];
12.     char type[MAX_FIELD_LEN];
13. };
15. struct record
16. {
17.     int id;
18.     char fields[MAX_FIELDS][MAX_FIELD_LEN];
19. };
21. struct table
22. {
23.     char name[MAX_FIELD_LEN];
24.     struct field fields[MAX_FIELDS];
25.     int num_fields;
26.     struct record records[MAX_RECORDS];
27.     int num_records;
28. };

复制代码

在主函数中开始先创建表，然后根据菜单来选择操作命令，分别将输入的信息分发给命令处理函数。

1. int main()
2. {
3.     struct table t;
4.     create_table(&t);
6.     while (1)
7.     {
8.         printf("Enter command (insert/select/update/delete/exit): ");
9.         char command[MAX_FIELD_LEN];
10.         scanf("%s", command);
11.         if (strcmp(command, "insert") == 0)
12.         {
13.             insert_record(&t);
14.         } else if (strcmp(command, "select") == 0)
15.         {
16.             print_table(&t);
17.         } else if (strcmp(command, "update") == 0)
18.         {
19.             update_record(&t);
20.         } else if (strcmp(command, "delete") == 0)
21.         {
22.             delete_record(&t);
23.         } else if (strcmp(command, "exit") == 0)
24.         {
25.             break;
26.         } else
27.         {
28.             printf("Invalid command\n");
29.         }
30.     }
31.     return 0;
32. }

复制代码

每一个命令对应了一个处理函数:

• 创建表命令添补表的结构中字段数量，字段的名称与类型界说；
  
• 插入一条记录，将用户输入的各字段数据插入表数据的尾部，并递增记录数；
  
• 查询表中的数据时，遍历字段界说并打印，然后遍历记录数据的二维数据，每行按字段分别打印；
  
• 删除和更新数据时，默认按数据行的序号作为索引，操作时输入对应序号。
  

1. void create_table(struct table *t)
2. {
3.     printf("Enter table name: ");
4.     scanf("%s", t->name);
5.     printf("Enter number of fields: ");
6.     scanf("%d", &t->num_fields);
7.     printf("Enter field names and types:\n");
9.     for (int i = 0; i < t->num_fields; i++)
10.     {
11.         printf("Field %d name: ", i+1);
12.         scanf("%s", t->fields[i].name);
13.         printf("Field %d type: ", i+1);
14.         scanf("%s", t->fields[i].type);
15.     }
16. }
18. void insert_record(struct table *t)
19. {
20.     if (t->num_records >= MAX_RECORDS)
21.     {
22.         printf("Table is full\n");
23.         return;
24.     }
26.     t->records[t->num_records].id = t->num_records + 1;
28.     printf("Enter field values:\n");
29.     for (int i = 0; i < t->num_fields; i++)
30.     {
31.         printf("%s: ", t->fields[i].name);
32.         scanf("%s", t->records[t->num_records].fields[i]);
33.     }
34.     t->num_records++;
35. }
37. void print_table(struct table *t)
38. {
39.     printf("%s:\n\t", t->name);
40.     for (int i = 0; i < t->num_fields; i++)
41.     {
42.         printf("%s\t", t->fields[i].name);
43.     }
45.     printf("\n");
46.     for (int i = 0; i < t->num_records; i++)
47.     {
48.         printf("%d\t", t->records[i].id);
49.         for (int j = 0; j < t->num_fields; j++)
50.         {
51.             printf("%s\t", t->records[i].fields[j]);
52.         }
53.         printf("\n");
54.     }
55. }
57. void update_record(struct table *t)
58. {
59.     int id;
61.     printf("Enter record id: ");
62.     scanf("%d", &id);
63.     if (id < 1 || id > t->num_records)
64.     {
65.         printf("Invalid id\n");
66.         return;
67.     }
69.     printf("Enter field values:\n");
70.     for (int i = 0; i < t->num_fields; i++)
71.     {
72.         printf("%s: ", t->fields[i].name);
73.         scanf("%s", t->records[id-1].fields[i]);
74.     }
75. }
77. void delete_record(struct table *t)
78. {
79.     int id;
80.     printf("Enter record id: ");
81.     scanf("%d", &id);
82.     if (id < 1 || id > t->num_records)
83.     {
84.         printf("Invalid id\n");
85.         return;
86.     }
88.     for (int i = id-1; i < t->num_records-1; i++)
89.     {
90.         t->records[i] = t->records[i+1];
91.     }
92.     t->num_records--;
93. }

复制代码

当前模拟程序，只能支持对一张表的操作，基本包罗了数据库的核心模块：解析模块，执行模块，存储模块。
在主函数中的菜单选项，再通太过发到命令处理函数，这个过程是将用户的意图和用户数据解析的过程，转换为程序内部的数据结构，对应就是解析模块。
命令处理函数将命令对应的数据，按照命令的业务流程处理，修改存储数据，返回用户结果，其实数据库的执行模块大要也是这样的思路。
在存储部分，主要管理数据存储的构造结构，内存中的形式与磁盘上存储的形式，一般内存与磁盘的数据有对应的规则，两者存储的结构并不相同。
二、操作运行结果

---

编译运行上面的模拟演示程序，增长一个student门生表，有门生号和门生名两个属性列，数据可以自由添加。

1. [senllang@hatch exam_01]$ gcc demo_1.c -o demo
2. [senllang@hatch exam_01]$ ./demo
3. Enter table name: student
4. Enter number of fields: 2
5. Enter field names and types:
6. Field 1 name: sid
7. Field 1 type: int
8. Field 2 name: sname
9. Field 2 type: varchar
10. Enter command (insert/select/update/delete/exit): insert
11. Enter field values:
12. sid: 100
13. sname: liqiang
14. Enter command (insert/select/update/delete/exit): insert
15. Enter field values:
16. sid: 101
17. sname: liuye
18. Enter command (insert/select/update/delete/exit): select
19. student:
20.         sid     sname
21. 1       100     liqiang
22. 2       101     liuye
23. Enter command (insert/select/update/delete/exit): update
24. Enter record id: 2
25. Enter field values:
26. sid: 101
27. sname: liuyewen
28. Enter command (insert/select/update/delete/exit): select
29. student:
30.         sid     sname
31. 1       100     liqiang
32. 2       101     liuyewen
33. Enter command (insert/select/update/delete/exit): exit

复制代码

三、结尾

---

通过一个简朴的C语言程序，来模拟数据库的运行机制，固然数据库功能非常繁多，但此中最核心的SQL的解析，命令的执行，结果的输出原理是一样的，别的怎样让执行性能提拔，并发时怎样处理冲突，故障时保障数据等机制将在此核心功能之上进一步使数据库更加强盛。
大家对数据库内核有兴趣的话，可以关注我，从今天开始从零编写一个可以利用的数据库内核。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。