日志系统是保证数据库管理系统正确执行事务的基本机制。根据作用的不同,日志系统分为UNDO和REDO两种,本文对UNDO类型日志的原理进行简单模拟说明。
1 UNDO日志要求- 日志记录了数据修改之前的旧值;
- 数据刷盘之前,把日志刷盘;(一致性)
- 数据刷盘之后,把日志COMMIT刷盘。(持久性)
UNDO日志提供了足够的信息可以保证事务的一致性和持久性。但是,为了保持一致性,采取的是被动保守的策略,即:用旧值覆盖不能确保成功的事务。未成功的事务不能重新执行,只能恢复到事务之前的一致状态。
2 模拟代码只是模拟了数据写入的过程,没有模拟数据恢复过程,待以后有时间补充。
/* UNDO 类型日志基本流程模拟 */ #include #include #include #include /* 日志文件,基本格式: * T1_START * A=100 * B=100 * T1_COMMIT */ #define LOG_FILE "test.log" /* 数据文件,基本格式: 每行一个键值对,长度固定为1024,右侧用空格填充。 * A=100 (padding) * B=100 (padding) */ #define DATA_FILE "test.data" #define LINE_MAX 1024 /* 键值对 */ typedef struct KV KV; struct KV { char* key; char* value; }; /* 从硬盘读取名为k的数据 */ static int fread_kv(char* k, char* v, FILE* fp) { rewind(fp); char line[LINE_MAX+1]={0}; int lineNo = 0; while(fread(line, 1, LINE_MAX, fp)==LINE_MAX){ int i=0; while(k[i] && line[i]!='='){ if(k[i] != line[i]){ break; } i++; } if(line[i] == '='){ strcpy(v, &line[i+1]); return lineNo; 1,1 Top } lineNo ++; } return -1; } /* 把数据刷入硬盘 */ static void fwrite_kv( char* k, char* v, FILE* fp) { int lineNo = -1; char newLine[LINE_MAX]; sprintf(newLine, "%s=%s", k, v); int offset = 0; if( (lineNo=fread_kv(k,v,fp))