- GreatSQL社区原创内容未经受权不得随便应用，转载请分割小编并注明起源。
- GreatSQL是MySQL的国产分支版本，应用上与MySQL统一。
前文回顾
实现一个简略的Database1(译文）
实现一个简略的Database2(译文）
实现一个简略的Database3(译文）
实现一个简略的Database4(译文）
实现一个简略的Database5(译文）
译注：cstsck在github保护了一个简略的、相似sqlite的数据库实现，通过这个简略的我的项目，能够很好的了解数据库是如何运行的。本文是第六篇，次要是实现数据长久化游标
Part 6 游标形象
跟上一节相比，这一节篇幅绝对要简短的多。咱们只是略微重构一下，这样就能够让开始实现B-tree更简略一些。
在代码中新增加一个Cursor对象，它用来代表表中的一个地位（location）。
你可能心愿对游标执行的操作：
- 在表结尾时创立一个游标
- 在表结尾时创立一个游标
- 拜访游标指向的行
- 将游标挪动到下一行
这就是咱们将要实现的游标的一些行为。而后，咱们还想做到：
- 删除游标指向的一行数据
- 批改游标指向的一行数据
- 应用给定的ID搜寻一张表，并创立一个游标指向这个ID所在的行
_译注：这里简略介绍一下游标，Cursor本来就有箭头、光标的意思，用来批示事物以示关注。游标是数据的一种拜访机制，一种解决数据的办法，例如查问返回的后果是一行或者多行的后果集（这曾经是SQL被解决后的后果集），咱们须要对后果集进行查问，sql语句就不论用了，因为这曾经是返回的后果集了，这个时候就须要用游标来遍历这个返回的后果集了。能够了解游标是一个指向Row的指针，拜访一行后，游标就会指向下一行。例如 fetchone()、fetchall() 等函数就是通过游标来拜访后果集的，返回具体一行或者多行的数据。上面是游标图示：
不磨叽了，上面就是Cursor类型构造：
+typedef struct {+ Table* table;+ uint32_t row_num;+ bool end_of_table; // Indicates a position one past the last element+} Cursor;依据当初咱们的表数据结构，只须要行号即可辨认表中的地位。
游标对它所属的表还有一个援用（所以咱们的游标函数还能够仅仅把游标作为参数）。
最初，它还有一个boolean类型的属性叫做 end_of_table 。这样咱们就能够用来示意表结尾之后的地位（在这里咱们可能会插入一个新行）。
table_start() 和 table_end() 创立一个新的游标:
+Cursor* table_start(Table* table) {+ Cursor* cursor = malloc(sizeof(Cursor));+ cursor->table = table;+ cursor->row_num = 0;+ cursor->end_of_table = (table->num_rows == 0);++ return cursor;+}++Cursor* table_end(Table* table) {+ Cursor* cursor = malloc(sizeof(Cursor));+ cursor->table = table;+ cursor->row_num = table->num_rows;+ cursor->end_of_table = true;++ return cursor;+}咱们的 row_slot() 函数要变成 cursor_value() 了，它返回一个指针类型，指向游标形容的地位：
-void* row_slot(Table* table, uint32_t row_num) {+void* cursor_value(Cursor* cursor) {+ uint32_t row_num = cursor->row_num; uint32_t page_num = row_num / ROWS_PER_PAGE;- void* page = get_page(table->pager, page_num);+ void* page = get_page(cursor->table->pager, page_num); uint32_t row_offset = row_num % ROWS_PER_PAGE; uint32_t byte_offset = row_offset * ROW_SIZE; return page + byte_offset; }在咱们以后的表构造中推动游标就像让行号递增一样简略。这在B-tree书中会有一点小简单。
+void cursor_advance(Cursor* cursor) {+ cursor->row_num += 1;+ if (cursor->row_num >= cursor->table->num_rows) {+ cursor->end_of_table = true;+ }+} 最初咱们就能扭转咱们的“虚拟机”办法来应用游标形象了。当插入一行数据时，咱们在表结尾关上一个游标，写入这个游标的地位，而后敞开游标。
Row* row_to_insert = &(statement->row_to_insert);+ Cursor* cursor = table_end(table);- serialize_row(row_to_insert, row_slot(table, table->num_rows));+ serialize_row(row_to_insert, cursor_value(cursor));table->num_rows += 1;+ free(cursor);+return EXECUTE_SUCCESS;}当查问表中的所有行时，咱们在表的结尾关上一个游标，打印行数据，而后推动游标到下一行，反复这个过程直到表的结尾。
ExecuteResult execute_select(Statement* statement, Table* table) {+ Cursor* cursor = table_start(table);+ Row row;- for (uint32_t i = 0; i < table->num_rows; i++) {- deserialize_row(row_slot(table, i), &row);+ while (!(cursor->end_of_table)) {+ deserialize_row(cursor_value(cursor), &row); print_row(&row);+ cursor_advance(cursor); }++ free(cursor);+ return EXECUTE_SUCCESS; }好了，就是它！就像我说的，这是短小的重构，应该可能有助于咱们把表的数据结构重写为B-tree。execute_select() 和 execute_insert() 函数齐全能够通过游标来与表交互，而对于表的存储形式不须要假如任何事件。
译注：在之前实现数据库的page组织形式的代码中，作者应用数组（array）来组织数据页page，次要是思考疾速实现存放数据，没有思考性能优化。前面会应用B-tree来进行重构，而在此之前，先实现了游标。_
这是于上一部分比照，代码的不同：
@@ -78,6 +78,13 @@ struct { } Table;+typedef struct {+ Table* table;+ uint32_t row_num;+ bool end_of_table; // Indicates a position one past the last element+} Cursor;+ void print_row(Row* row) { printf("(%d, %s, %s)\n", row->id, row->username, row->email); }@@ -126,12 +133,38 @@ void* get_page(Pager* pager, uint32_t page_num) { return pager->pages[page_num]; }-void* row_slot(Table* table, uint32_t row_num) {- uint32_t page_num = row_num / ROWS_PER_PAGE;- void *page = get_page(table->pager, page_num);- uint32_t row_offset = row_num % ROWS_PER_PAGE;- uint32_t byte_offset = row_offset * ROW_SIZE;- return page + byte_offset;+Cursor* table_start(Table* table) {+ Cursor* cursor = malloc(sizeof(Cursor));+ cursor->table = table;+ cursor->row_num = 0;+ cursor->end_of_table = (table->num_rows == 0);++ return cursor;+}++Cursor* table_end(Table* table) {+ Cursor* cursor = malloc(sizeof(Cursor));+ cursor->table = table;+ cursor->row_num = table->num_rows;+ cursor->end_of_table = true;++ return cursor;+}++void* cursor_value(Cursor* cursor) {+ uint32_t row_num = cursor->row_num;+ uint32_t page_num = row_num / ROWS_PER_PAGE;+ void *page = get_page(cursor->table->pager, page_num);+ uint32_t row_offset = row_num % ROWS_PER_PAGE;+ uint32_t byte_offset = row_offset * ROW_SIZE;+ return page + byte_offset;+}++void cursor_advance(Cursor* cursor) {+ cursor->row_num += 1;+ if (cursor->row_num >= cursor->table->num_rows) {+ cursor->end_of_table = true;+ } } Pager* pager_open(const char* filename) {@@ -327,19 +360,28 @@ ExecuteResult execute_insert(Statement* statement, Table* table) { } Row* row_to_insert = &(statement->row_to_insert);+ Cursor* cursor = table_end(table);- serialize_row(row_to_insert, row_slot(table, table->num_rows));+ serialize_row(row_to_insert, cursor_value(cursor)); table->num_rows += 1;+ free(cursor);+ return EXECUTE_SUCCESS; } ExecuteResult execute_select(Statement* statement, Table* table) {+ Cursor* cursor = table_start(table);+ Row row;- for (uint32_t i = 0; i < table->num_rows; i++) {- deserialize_row(row_slot(table, i), &row);+ while (!(cursor->end_of_table)) {+ deserialize_row(cursor_value(cursor), &row); print_row(&row);+ cursor_advance(cursor); }++ free(cursor);+ return EXECUTE_SUCCESS; }Enjoy GreatSQL :)
## 对于 GreatSQL
GreatSQL是由万里数据库保护的MySQL分支，专一于晋升MGR可靠性及性能，反对InnoDB并行查问个性，是实用于金融级利用的MySQL分支版本。
相干链接： GreatSQL社区 Gitee GitHub Bilibili
GreatSQL社区：
欢送来GreatSQL社区发帖发问
https://greatsql.cn/
技术交换群：
微信：扫码增加GreatSQL社区助手微信好友，发送验证信息加群。