[apue] apue_db：一個可以充當"系統資料庫"的 key-value 資料庫

從經典名著中淘到的寶貝

apue 最後兩章都是通過一個完整的執行個體來解釋一些 linux 功能，第20章就是通過一個資料庫執行個體來解釋檔案鎖的使用，

說實話，當時沒興趣，因為滿頁都是源碼和解析，有點看不下去。但是再拾起來硬着頭皮看的時候，發現這哪裡是個小 demo，明明是個五髒俱全的 key-value 資料庫嘛，

而且這個資料庫，提供多程序并發讀寫的安全性保證（通過檔案鎖）、提供已删除節點循環再利用的能力、提供根據使用者需求調節内部 hash 表參數的能力……

特别是它的索引與資料檔案格式，采用字元串存儲各種偏移量與數字，非常便于直接打開檔案去做一些 “觀察”，然後也能很友善地基于 SDK 建構查找、增删改資料庫的工具……

這簡直就是一個 linux 上的 “系統資料庫” 工具！

先來看看這個資料庫提供的 SDK 接口：

apue_db.h

1 #ifndef __APUE_DB_H__
 2 #define __APUE_DB_H__
 3 
 4 typedef void* DBHANDLE;
 5 
 6 // db_store flags
 7 #define DB_INSERT 1
 8 #define DB_REPLACE 2
 9 #define DB_STORE 3
10 
11 #define IDXLEN_MIN 6
12 #define IDXLEN_MAX 1024 // single index can not exceed this size
13 #define DATLEN_MIN 2
14 #define DATLEN_MAX 1024 // single data can not exceed this size
15 #define NHASH_DEF 137 // default hash table size
16 
17 DBHANDLE db_open (char const* pathname, int oflag, .../*mode*/); 
18 void db_close (DBHANDLE db); 
19 int db_store (DBHANDLE db, const char *key, const char *data, int flag); 
20 char* db_fetch (DBHANDLE db, char *key); 
21 int db_delete (DBHANDLE db, const char *key); 
22 void db_rewind (DBHANDLE db); 
23 char *db_nextrec (DBHANDLE db, char *key); 
24 void db_dump (DBHANDLE db); 
25 
26 #endif

通過 db_open/db_close 打開關閉資料庫，拿到DBHANDLE後就可以基于這個做操作了：

db_store 存儲一個key，flag 指定覆寫方式：
- DB_INSERT 當已經有這個key時會傳回失敗
- DB_REPLACE 當沒有這個key時會傳回失敗
- DB_STORE 綜合了上面兩種情況，有時REPLACE，沒有時INSERT
db_fetch 擷取一個key對應的data
db_delete 删除一個key
db_rewind/db_nextrec 用來無序周遊資料庫中的所有key
db_dump 是我自己加的一個接口，用來列印資料庫内部狀态，如索引哈希表、索引空閑節點清單，調試時使用

實作比較長，就不貼了，隻給一個連結：apue_db.c

依據書中代碼，純手工輸入，同時加入了習題中可以指定索引哈希表大小的能力

（編譯時指定 HAS_HASHSIZE 宏，運作時通過環境變量 APUE_DB_HASH_SIZE 指定具體的哈希值，當然這個隻在建立資料庫時起作用，如果資料庫已經存在，

将直接使用資料庫中記錄的哈希表大小值，如果沒有環境變量，使用 NHASH_DEF 作為預設的哈希表尺寸，PS：盡量使用質數來保證哈希效果）

有了SDK，搞個資料庫小工具就是小菜一碟了：

db.c

1 #include "../apue.h"
  2 #include "apue_db.h"
  3 #include <fcntl.h>
  4 #include <strings.h>
  5 #include <errno.h>
  6 
  7 void Usage ()
  8 {
  9     printf ("Usage: db filename insert key data\n"); 
 10     printf ("       db filename query key\n"); 
 11     printf ("       db filename delete key\n"); 
 12     printf ("       db filename walk\n"); 
 13     printf ("       db filename dump\n"); 
 14     exit (-1); 
 15 }
 16 
 17 int main (int argc, char *argv[])
 18 {
 19     if (argc < 3) 
 20         Usage (); 
 21 
 22     char *filename = argv[1]; 
 23     char *action = argv[2]; 
 24     char *key = NULL; 
 25     char *data = NULL; 
 26     if (strcasecmp (action, "walk") == 0 
 27             || strcasecmp (action, "dump") == 0)
 28     {
 29         // no extra param
 30     }
 31     else if (strcasecmp (action, "delete") == 0 
 32             || strcasecmp (action, "query") == 0)
 33     {
 34         if (argc < 4)
 35             Usage (); 
 36 
 37         key = argv[3]; 
 38     }
 39     else if (strcasecmp (action, "insert") == 0)
 40     {
 41         if (argc < 5)
 42             Usage (); 
 43 
 44         key = argv[3]; 
 45         data = argv[4]; 
 46     }
 47     else 
 48     {
 49         Usage (); 
 50     }
 51 
 52     DBHANDLE db; 
 53     char *ptr = NULL; 
 54 #ifdef HAS_HASHSIZE
 55     int hashsize = 0; 
 56     ptr = getenv ("APUE_DB_HASH_SIZE"); 
 57     if (ptr)
 58         hashsize = atoi (ptr); 
 59 
 60     if (hashsize <= 0)
 61         hashsize = NHASH_DEF; 
 62 
 63     if ((db = db_open (filename, O_RDWR | O_CREAT /*| O_TRUNC*/, FILE_MODE, hashsize)) == NULL)
 64 #else
 65     if ((db = db_open (filename, O_RDWR | O_CREAT /*| O_TRUNC*/, FILE_MODE)) == NULL)
 66 #endif
 67         err_sys ("db_open error"); 
 68 
 69     int ret = 0; 
 70     if (strcasecmp (action, "dump") == 0)
 71     {
 72         db_dump (db); 
 73     }
 74     else if (strcasecmp (action, "walk") == 0)
 75     {
 76         //db_rewind (); 
 77         int n = 0; 
 78         char buf[IDXLEN_MAX] = { 0 }; 
 79         while ((ptr = db_nextrec(db, buf)) != NULL)
 80         {
 81             n ++; 
 82             printf ("[%5d] %s --- %s\n", n, buf, ptr); 
 83         }
 84 
 85         printf ("walk done!\n"); 
 86     }
 87     else if (strcasecmp (action, "insert") == 0)
 88     {
 89         ret = db_store (db, key, data, DB_STORE); 
 90         if (ret < 0)
 91             fprintf (stderr, "insert %s.%s failed, errno %d\n", key, data, errno); 
 92         else if (ret == 1)
 93             fprintf (stderr, "insert %s.%s cover old data\n", key, data); 
 94         else 
 95             printf ("db %s '%s' code %d\n", action, key, ret); 
 96     }
 97     else if (strcasecmp (action, "delete") == 0)
 98     {
 99         ret = db_delete (db, key); 
100         if (ret < 0)
101             fprintf (stderr, "delete %s failed, errno %d\n", key, errno); 
102         else 
103             printf ("db %s '%s' code %d\n", action, key, ret); 
104     }
105     else if (strcasecmp (action, "query") == 0)
106     {
107         ptr = db_fetch (db, key); 
108         //printf ("%s === %s\n", key, ptr); 
109         // only print data to allow assigned in shell script
110         printf ("%s\n", ptr == NULL ? "nil" : ptr); 
111     }
112     else
113         Usage (); 
114 
115     db_close (db); 
116     return ret; 
117 }

如果給定的參數不合法，會彈出 usage:

Usage: db filename insert key data
       db filename query key
       db filename delete key
       db filename walk
       db filename dump

其中：

insert 底層使用 db_store(..., DB_STORE); 來插入一條資料
query 底層使用 db_fetch 來查詢一條資料
delete 底層使用 db_delete 來删除一條資料
walk 底層使用 db_nextrec 來周遊所有資料
dump 底層使用 db_dump 來檢視資料庫内部狀态

好了，有了這個工具，我們就可以用腳本來開展測試工作了，為了驗證這個資料庫是“靠譜”的，我主要測試的是多程序并行寫入、删除的能力。

在開始搞事情之前，我需要先準備一些測試資料，這個由一個awk腳本來完成：

gen.awk

1 #! /bin/awk -f
 2 BEGIN {
 3     WORDNUM = 10
 4     for (i = 1; i <= WORDNUM; i++) {
 5         printf("%s %s\n", randword(randint(20)), randword(randint(150))) 
 6     }
 7 }
 8 
 9 # randint(n): return a random integer number which is >= 1 and <= n
10 function randint(n) {
11     return int(n *rand()) + 1
12 }
13 
14 # randlet(): return a random letter, which maybe upper, lower or number. 
15 function randlet() {
16     return substr("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", randint(62), 1)
17 }
18 
19 # randword(LEN): return a rand word with a length of LEN
20 function randword(LEN) {
21     randw=""
22     for( j = 1; j <= LEN; j++) {
23         randw=randw randlet()
24     }
25     return randw
26 }

執行這個腳本，得到測試資料檔案：

$./gen.awk > demo
$ cat demo 
s0jKl kEjwE4q3nNJugFJ0cgNaSgDpP3VS45x3Wum9kRF6SgmIReFmrNBcCecjyQHQqCrB5fC61hao1BV2x6XZ6KLtA4jZTEnhcAugAMMWE95NU7FnsYar4wz279jHoV
TmD516yvmt JB2NG30NDAaL5vpzp8DQX0rLRiVxjONIm64AN6UVc7uTLIIRpEq
BOhc40pKXhCbCu8 yo1vVWxtP4uJIbRFwNo6eZnxbOnzwrRvrcX0Xi1DcKsHcsaCgoqkbr1PWoqSdcG5jbwi4sMrlGf
Pw1o1fcg6kHIm ZmDlGY0OEsAsWYzRprJJcjxOZ0h9OBP5ORTqmvxU2XgS9lRXAfCuIzFHOLVt1eE
GalRFwb YpHtiHoEVu46gDh6X55JbQMr9T9mI5PIwCllwe1sy1lUkQn2EqJAE9tZ0bTpMNj7nVenVaEpJEBHai
2X staN43MMZxs8H3wITgkcuTKWGRxLE8pYpUTc2SUETv9igtejxiiM2B6x44ch9XGZjkXSMp2Rewv2WjRBHSVfZAmTAYz32h5l5PRKsdHqMMU1l
zW4dQI 6tnikssfMBLVJs4jbTXkFylvdEcVGMB1eYpdCvnvqBxcUuMPmDgSDuFVl726MkkgzMU5nFLoQrcM4Y8aTHRnMXilQTEaMe5aYdgJ5jEVnKMwRt9mQWE8sYKVSLHjtDJ9LwsGcN2IZ2Eznmn6ElzbY7
0Jde UQQFJQpluZKXybyfzyLrdIGYNn8Rs09tXwv7uMjlYRpe7C1frEB5hGHwuEu37bSCj0v5L1cxnYLabzF4t4loXtiV97O7XXg4qMK5IR2
yNSPh9ev0rnu0yU I3XVWF8h7to0
UivjVVXnSN60cre Grro31PCJDUx83CjbThVEksrvQHZcxnLwBa3RCpUS0Yhwm4OXisdZN0Jnj

這個檔案每行都是一個 "key data"，其中 key 為 1-20 長度的随機字元串，data 為 1-150 長度的随機字元串，共10條。

寫入資料的測試腳本就可以這樣寫了：

testi.sh

1 #! /bin/sh
 2 OLD_IFS="$IFS"
 3 IFS=" "
 4 while read line
 5 do
 6 #  echo $line
 7   array=($line)
 8   key=${array[0]}
 9   data=${array[1]}
10   echo "$key -> $data"
11   ./db yunh insert $key $data
12 done <demo
13 
14 IFS="$OLD_IFS"

執行這個腳本，結果如下：

$ ./testi.sh 
s0jKl -> kEjwE4q3nNJugFJ0cgNaSgDpP3VS45x3Wum9kRF6SgmIReFmrNBcCecjyQHQqCrB5fC61hao1BV2x6XZ6KLtA4jZTEnhcAugAMMWE95NU7FnsYar4wz279jHoV
db insert 's0jKl' code 0
TmD516yvmt -> JB2NG30NDAaL5vpzp8DQX0rLRiVxjONIm64AN6UVc7uTLIIRpEq
db insert 'TmD516yvmt' code 0
BOhc40pKXhCbCu8 -> yo1vVWxtP4uJIbRFwNo6eZnxbOnzwrRvrcX0Xi1DcKsHcsaCgoqkbr1PWoqSdcG5jbwi4sMrlGf
db insert 'BOhc40pKXhCbCu8' code 0
Pw1o1fcg6kHIm -> ZmDlGY0OEsAsWYzRprJJcjxOZ0h9OBP5ORTqmvxU2XgS9lRXAfCuIzFHOLVt1eE
db insert 'Pw1o1fcg6kHIm' code 0
GalRFwb -> YpHtiHoEVu46gDh6X55JbQMr9T9mI5PIwCllwe1sy1lUkQn2EqJAE9tZ0bTpMNj7nVenVaEpJEBHai
db insert 'GalRFwb' code 0
2X -> staN43MMZxs8H3wITgkcuTKWGRxLE8pYpUTc2SUETv9igtejxiiM2B6x44ch9XGZjkXSMp2Rewv2WjRBHSVfZAmTAYz32h5l5PRKsdHqMMU1l
db insert '2X' code 0
zW4dQI -> 6tnikssfMBLVJs4jbTXkFylvdEcVGMB1eYpdCvnvqBxcUuMPmDgSDuFVl726MkkgzMU5nFLoQrcM4Y8aTHRnMXilQTEaMe5aYdgJ5jEVnKMwRt9mQWE8sYKVSLHjtDJ9LwsGcN2IZ2Eznmn6ElzbY7
db insert 'zW4dQI' code 0
0Jde -> UQQFJQpluZKXybyfzyLrdIGYNn8Rs09tXwv7uMjlYRpe7C1frEB5hGHwuEu37bSCj0v5L1cxnYLabzF4t4loXtiV97O7XXg4qMK5IR2
db insert '0Jde' code 0
yNSPh9ev0rnu0yU -> I3XVWF8h7to0
db insert 'yNSPh9ev0rnu0yU' code 0
UivjVVXnSN60cre -> Grro31PCJDUx83CjbThVEksrvQHZcxnLwBa3RCpUS0Yhwm4OXisdZN0Jnj
db insert 'UivjVVXnSN60cre' code 0

使用工具進行 walk 的話，可以看到都插入進去了：

$ ./db yunh walk
[    1] s0jKl --- kEjwE4q3nNJugFJ0cgNaSgDpP3VS45x3Wum9kRF6SgmIReFmrNBcCecjyQHQqCrB5fC61hao1BV2x6XZ6KLtA4jZTEnhcAugAMMWE95NU7FnsYar4wz279jHoV
[    2] TmD516yvmt --- JB2NG30NDAaL5vpzp8DQX0rLRiVxjONIm64AN6UVc7uTLIIRpEq
[    3] BOhc40pKXhCbCu8 --- yo1vVWxtP4uJIbRFwNo6eZnxbOnzwrRvrcX0Xi1DcKsHcsaCgoqkbr1PWoqSdcG5jbwi4sMrlGf
[    4] Pw1o1fcg6kHIm --- ZmDlGY0OEsAsWYzRprJJcjxOZ0h9OBP5ORTqmvxU2XgS9lRXAfCuIzFHOLVt1eE
[    5] GalRFwb --- YpHtiHoEVu46gDh6X55JbQMr9T9mI5PIwCllwe1sy1lUkQn2EqJAE9tZ0bTpMNj7nVenVaEpJEBHai
[    6] 2X --- staN43MMZxs8H3wITgkcuTKWGRxLE8pYpUTc2SUETv9igtejxiiM2B6x44ch9XGZjkXSMp2Rewv2WjRBHSVfZAmTAYz32h5l5PRKsdHqMMU1l
[    7] zW4dQI --- 6tnikssfMBLVJs4jbTXkFylvdEcVGMB1eYpdCvnvqBxcUuMPmDgSDuFVl726MkkgzMU5nFLoQrcM4Y8aTHRnMXilQTEaMe5aYdgJ5jEVnKMwRt9mQWE8sYKVSLHjtDJ9LwsGcN2IZ2Eznmn6ElzbY7
[    8] 0Jde --- UQQFJQpluZKXybyfzyLrdIGYNn8Rs09tXwv7uMjlYRpe7C1frEB5hGHwuEu37bSCj0v5L1cxnYLabzF4t4loXtiV97O7XXg4qMK5IR2
[    9] yNSPh9ev0rnu0yU --- I3XVWF8h7to0
[   10] UivjVVXnSN60cre --- Grro31PCJDUx83CjbThVEksrvQHZcxnLwBa3RCpUS0Yhwm4OXisdZN0Jnj
walk done!

可以觀察到周遊的順序其實就是元素的插入順序。

使用工具進行 dump 的話，還可以看到 hash 表中的元素配置設定：

$ ./db yunh dump
hash nodes: 
  hash[0] nodes: 
  hash[1] nodes: 
  hash[2] nodes: 
  hash[3] nodes: 
  hash[4] nodes: 
  hash[5] nodes: 
  hash[6] nodes: 
  hash[7] nodes: 
  hash[8] nodes: 
  hash[9] nodes: 
  hash[10] nodes: 
  hash[11] nodes: 
  hash[12] nodes: 
  hash[13] nodes: 
    1     key 10, dat 52: TmD516yvmt
  hash[14] nodes: 
  hash[15] nodes: 
  hash[16] nodes: 
  hash[17] nodes: 
  hash[18] nodes: 
  hash[19] nodes: 
  hash[20] nodes: 
  hash[21] nodes: 
  hash[22] nodes: 
  hash[23] nodes: 
  hash[24] nodes: 
  hash[25] nodes: 
  hash[26] nodes: 
  hash[27] nodes: 
  hash[28] nodes: 
  hash[29] nodes: 
  hash[30] nodes: 
  hash[31] nodes: 
  hash[32] nodes: 
  hash[33] nodes: 
  hash[34] nodes: 
  hash[35] nodes: 
  hash[36] nodes: 
  hash[37] nodes: 
  hash[38] nodes: 
  hash[39] nodes: 
  hash[40] nodes: 
  hash[41] nodes: 
    1     key 15, dat 13: yNSPh9ev0rnu0yU
  hash[42] nodes: 
  hash[43] nodes: 
  hash[44] nodes: 
  hash[45] nodes: 
  hash[46] nodes: 
  hash[47] nodes: 
  hash[48] nodes: 
  hash[49] nodes: 
  hash[50] nodes: 
  hash[51] nodes: 
    1     key 6, dat 151: zW4dQI
  hash[52] nodes: 
  hash[53] nodes: 
  hash[54] nodes: 
  hash[55] nodes: 
  hash[56] nodes: 
  hash[57] nodes: 
  hash[58] nodes: 
  hash[59] nodes: 
  hash[60] nodes: 
  hash[61] nodes: 
    1     key 15, dat 59: UivjVVXnSN60cre
  hash[62] nodes: 
  hash[63] nodes: 
  hash[64] nodes: 
    1     key 7, dat 79: GalRFwb
  hash[65] nodes: 
  hash[66] nodes: 
  hash[67] nodes: 
  hash[68] nodes: 
  hash[69] nodes: 
  hash[70] nodes: 
  hash[71] nodes: 
  hash[72] nodes: 
  hash[73] nodes: 
  hash[74] nodes: 
  hash[75] nodes: 
  hash[76] nodes: 
  hash[77] nodes: 
  hash[78] nodes: 
    1     key 4, dat 104: 0Jde
  hash[79] nodes: 
  hash[80] nodes: 
  hash[81] nodes: 
  hash[82] nodes: 
  hash[83] nodes: 
  hash[84] nodes: 
  hash[85] nodes: 
  hash[86] nodes: 
  hash[87] nodes: 
  hash[88] nodes: 
  hash[89] nodes: 
    1     key 2, dat 110: 2X
  hash[90] nodes: 
  hash[91] nodes: 
  hash[92] nodes: 
  hash[93] nodes: 
  hash[94] nodes: 
    1     key 15, dat 76: BOhc40pKXhCbCu8
  hash[95] nodes: 
  hash[96] nodes: 
  hash[97] nodes: 
  hash[98] nodes: 
  hash[99] nodes: 
  hash[100] nodes: 
  hash[101] nodes: 
  hash[102] nodes: 
  hash[103] nodes: 
  hash[104] nodes: 
  hash[105] nodes: 
  hash[106] nodes: 
  hash[107] nodes: 
  hash[108] nodes: 
  hash[109] nodes: 
  hash[110] nodes: 
  hash[111] nodes: 
  hash[112] nodes: 
  hash[113] nodes: 
  hash[114] nodes: 
  hash[115] nodes: 
    1     key 13, dat 64: Pw1o1fcg6kHIm
  hash[116] nodes: 
  hash[117] nodes: 
  hash[118] nodes: 
  hash[119] nodes: 
  hash[120] nodes: 
  hash[121] nodes: 
  hash[122] nodes: 
  hash[123] nodes: 
  hash[124] nodes: 
  hash[125] nodes: 
  hash[126] nodes: 
  hash[127] nodes: 
  hash[128] nodes: 
  hash[129] nodes: 
  hash[130] nodes: 
  hash[131] nodes: 
  hash[132] nodes: 
  hash[133] nodes: 
  hash[134] nodes: 
  hash[135] nodes: 
  hash[136] nodes: 
    1     key 5, dat 123: s0jKl
free nodes: 

total free: 0

可以看到預設的137個 hash 槽足夠散列這10條記錄，是以基本上一個 hash 槽最多隻有一條記錄，如果記錄多的話，才有可能看到索引記錄在 hash 槽中串成隊列的情形。

另外，這裡因為沒有删除記錄，也沒有發生插入同名 key 的情況（此種場景也會删除記錄），是以 freelist 沒有任何元素。

如果有興趣的話，其實也可以打開資料庫的索引與資料檔案，一探究竟：

$ cat yunh.idx
     0   137     0     0     0     0     0     0     0     0     0     0     0     0     0   857     
0     0     0     0     0     0     0     0     0     0     0     0     0     0     0     0     0
     0     0     0     0     0     0     0     0     0     0  1043     0     0     0     0     0
     0     0     0     0   995     0     0     0     0     0     0     0     0     0  1076     0
     0   949     0     0     0     0     0     0     0     0     0     0     0     0     0  1020
     0     0     0     0     0     0     0     0     0     0   974     0     0     0     0   885
     0     0     0     0     0     0     0     0     0     0     0     0     0     0     0     0
     0     0     0     0   918     0     0     0     0     0     0     0     0     0     0     0
     0     0     0     0     0     0     0     0     0   835
     0  12s0jKl:0:123
     0  18TmD516yvmt:123:52
     0  23BOhc40pKXhCbCu8:175:76
     0  21Pw1o1fcg6kHIm:251:64
     0  15GalRFwb:315:79
     0  112X:394:110
     0  15zW4dQI:504:151
     0  130Jde:655:104
     0  23yNSPh9ev0rnu0yU:759:13
     0  23UivjVVXnSN60cre:772:59
$ cat yunh.dat 
kEjwE4q3nNJugFJ0cgNaSgDpP3VS45x3Wum9kRF6SgmIReFmrNBcCecjyQHQqCrB5fC61hao1BV2x6XZ6KLtA4jZTEnhcAugAMMWE95NU7FnsYar4wz279jHoV
JB2NG30NDAaL5vpzp8DQX0rLRiVxjONIm64AN6UVc7uTLIIRpEq
yo1vVWxtP4uJIbRFwNo6eZnxbOnzwrRvrcX0Xi1DcKsHcsaCgoqkbr1PWoqSdcG5jbwi4sMrlGf
ZmDlGY0OEsAsWYzRprJJcjxOZ0h9OBP5ORTqmvxU2XgS9lRXAfCuIzFHOLVt1eE
YpHtiHoEVu46gDh6X55JbQMr9T9mI5PIwCllwe1sy1lUkQn2EqJAE9tZ0bTpMNj7nVenVaEpJEBHai
staN43MMZxs8H3wITgkcuTKWGRxLE8pYpUTc2SUETv9igtejxiiM2B6x44ch9XGZjkXSMp2Rewv2WjRBHSVfZAmTAYz32h5l5PRKsdHqMMU1l
6tnikssfMBLVJs4jbTXkFylvdEcVGMB1eYpdCvnvqBxcUuMPmDgSDuFVl726MkkgzMU5nFLoQrcM4Y8aTHRnMXilQTEaMe5aYdgJ5jEVnKMwRt9mQWE8sYKVSLHjtDJ9LwsGcN2IZ2Eznmn6ElzbY7
UQQFJQpluZKXybyfzyLrdIGYNn8Rs09tXwv7uMjlYRpe7C1frEB5hGHwuEu37bSCj0v5L1cxnYLabzF4t4loXtiV97O7XXg4qMK5IR2
I3XVWF8h7to0
Grro31PCJDUx83CjbThVEksrvQHZcxnLwBa3RCpUS0Yhwm4OXisdZN0Jnj

這裡就不細說了，不過總的感覺，這個資料庫還是比較“透明”的。

做多程序并發，這點兒資料當然不夠了，我們修改gen.awk，讓它生成1000條資料，

然後在插入腳本調用 db 指令的位置，使用背景運作來同時跑多個程序：

./db yunh insert $key $data &

這樣執行之後，再觀察資料庫中的資料，通過執行 walk 或 dump，可以看到确确實實有1000條資料插入了。

為了驗證資料準确性，甚至我還寫了一個校驗腳本，這個腳本每次一行從測試資料中讀出key與data，然後再去資料庫中取資料做對比，

經過驗證，一條不差！

感興趣的可以參考一下這個腳本：

testq.sh

1 #! /bin/sh
 2 OLD_IFS="$IFS"
 3 IFS=" "
 4 n=0
 5 while read line
 6 do
 7 #  echo $line
 8   array=($line)
 9   key=${array[0]}
10   data=${array[1]}
11   resp=`./db yunh query $key $data`
12   if [ "$resp" != "$data" ]; then 
13     echo "query $key with $resp != $data"
14     n=$(($n+1))
15   fi 
16 done <demo
17 echo "total different: $n"
18 
19 IFS="$OLD_IFS"
20

最近在做 windows 到 linux 程式移植的工作，其中系統資料庫通路的部分一直很頭疼，因為寫配置檔案實在是又零散又不能保證并發問題，

于是自然而然想到，把這個SDK封裝在一個跨平台通路配置資訊的類中，用于模拟 windows 上通路系統資料庫的機制，結果很完美。

（隻是有一點需要注意，因為底層的檔案鎖隻支援程序級别的互斥，同一程序内的多個線程之間，如果已經有鎖，則再加鎖并不等待，直接進入臨界區，

是以這塊還是需要注意通路“系統資料庫”最好局限在該程序的一個線程中，特别是有寫入的場景時）

最後總結一下，就是 apue 本身是個大寶庫，看似簡單的一個demo都蘊藏着巨大的潛力，作者不愧為一代巨匠，贊~~~

[apue] apue_db：一個可以充當"系統資料庫"的 key-value 資料庫

繼續閱讀

我的.vimrc檔案

配置檔案2012.2.14

Spring+Hibernate配置hbm.xml檔案在jar檔案中。

python操作配置檔案

查詢Oracle表空間資訊

Google App Engine錯誤解決方案之Class com.xxx.xxx does not seem to have been enhanced. You may want to rerun the enhancer and check for

IntelliJ IDEA 2020.1.2 設定多個project共享database插件

利用ado壓縮資料庫(vc源代碼)HOWTO: Compacting Microsoft Access Database Through OLE DB

關系資料庫設計理論函數依賴(FD)函數依賴的規則BC範式

HPM Note1,Book Organization

Partitioning Concepts

MySQL安裝時常見問題和解決方案【詳解】

Doris資料更新及删除1.資料更新

使用JDeveloper Remote debug PLSQL程式

單字母域名

testlink 切換資料庫