使用C語言操做Tokyo Cabinet 的數據庫

首先天然要安裝Tokyo Cabinet

 

Sh代碼 

1. tar zxvf tokyocabinet-1.4.28.tar.gz  

2. cd tokyocabinet-1.4.28/  

3. ./configure  

4. make  

5. make install  

6. cd ../  

 

如下是對Tokyo Cabinet 的操做，具體解釋能夠看代碼—代碼是最好的解釋.

文件名稱是:tcbdb.c

 C代碼 

1. /** 

2.  * Operate the Tokyo Cabinet 

3.  * @author zhoubaochuan 

4.  * @email :rtxbc@163.com 

5.  * @date:2011-07-13 

6.  * @gcc : gcc tcbdb.c  -I/usr/local/include/ -L/usr/local/lib/ -ltokyocabinet -lz -lbz2 -lrt -lpthread -lm -lc -O2 -g --static 

7.  */  

8.   

9. #include <stdio.h>  

10.   

11. /* Import the Tokyo Cabinet C's library*/  

12. #include <tcbdb.h>  

13.   

14. int main(int argc, char *argv[]){  

15.     char *datapath = "/opt/data/test/C/queue/tcbdb.db";  

16.     /* Allocate a region on memory */  

17.     char *dataname = (char *)tccalloc(1,1024);  

18.   

19.       

20.     TCBDB *db = tcbdbnew(); /* Create a B+ tree database object  */  

21.     tcbdbsetmutex(db);  

22.     tcbdbtune(db,128,256, 32749,8,10,100);  

23.     tcbdbsetcache(db,1024,512);  

24.     tcbdbsetxmsiz(db,1024100);  

25.   

26.       

27.     if(!tcbdbopen(db,datapath,BDBOWRITER|BDBOREADER)){  /* Open a database file and connect a B+ tree database object. */  

28.         fprintf(stderr,"It is failure to open a database !\n");  

29.         exit(1);  

30.     }     

31.     //free((void *)datapath);  

32.     //fprintf(stderr,"==============It is successful to open a database : ===============\n");  

33.   

34.     char *key = "t_key";  

35.     char *value = "zhoubaochuan";  

36.   

37.     fprintf(stderr, "============== Store value. ================\n key:%s; \n value:%s \n ", key, value);  

38.     /* Store a new record into a B+ tree database object. */  

39.     tcbdbput2(db, key, value);  

40.   

41.     fprintf(stderr, "============== Retrieve a record. ================\n");  

42.     /* Retrieve a record in a B+ tree database object as a volatile buffer. */  

43.     char *retrieve = tcbdbget2(db,key);  

44.     fprintf(stderr, "Retriver's Value:%s \n", retrieve);  

45.   

46.     /* Synchronize updated contents of a B+ tree database object with the file and the device. */  

47.     tcbdbsync(db);   /* 實時刷新到磁盤 */  

48.   

49.     /* Close a B+ tree database object. */  

50.     tcbdbclose(db);  

51.       

52.     return 0;  

53. }  

 

 編譯

 Sh代碼 

1. gcc tcbdb.c  -I/usr/local/include/ -L/usr/local/lib/ -ltokyocabinet -lz -lbz2 -lrt -lpthread -lm -lc -O2 -g --static  

 

 

執行結果

 Sh代碼 

1. [root@zhoubc queue]# ./a.out   

2. ============== Store value. ================  

3.  key:t_key;   

4.  value:zhoubaochuan   

5.  ============== Retrieve a record. ================  

6. Retriver's Value:zhoubaochuan   

 

 參考文獻:

http://fallabs.com/tokyocabinet/