请教Berkeley DB的游标操作

bsdc

网上翻了下，没有找到完整的测试代码，即使有c的api相关介绍也是列了一下流程，贴了少许代码，测试下不行。郁闷啊，请大家帮我看看。

版本是libdb4.6-dev

测试代码如下：

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include <db.h>
   
5. 
   
6. #define DBNAME "test.db"
   
7. 
   
8. typedef struct emp {
   
9.         int empid;
   
10.         char lastname[50];
    
11.         char firstname[50];
    
12.         float salary;
    
13. } emp_t;
    
14. 
    
15. DB *openDB(const char *dbFile)
    
16. {
    
17.         DB *dbp = NULL;
    
18.         int ret = 0;
    
19. 
    
20.         ret = db_create(&dbp, NULL, 0);
    
21.         if (ret != 0) {
    
22.                 printf("ERROR: %s\n",db_strerror(ret));
    
23.                 return NULL;
    
24.         }
    
25.         ret = dbp->open(dbp, NULL, dbFile, NULL, DB_BTREE, DB_CREATE, 0);
    
26.         if (ret != 0) {
    
27.                 printf("ERROR: %s\n",db_strerror(ret));
    
28.                 return NULL;
    
29.         }
    
30.         return dbp;
    
31. }
    
32. 
    
33. int main(int argc, char* argv[])
    
34. {
    
35.         DB *dbp;
    
36.         DBC *cursor;
    
37.         int ret = 0;
    
38.     DBT key, data;
    
39.         emp_t emp;
    
40.         if ((dbp = openDB(DBNAME)) == NULL) {
    
41.                 printf("open failed\n");
    
42.                 return 1;
    
43.         }
    
44. 
    
45.         /* insert */
    
46.         while (1) {
    
47.                 printf("Enter Employee ID: ");
    
48.                 scanf("%d", &emp.empid);
    
49.                 if (emp.empid == 0)
    
50.                         break;
    
51.                 printf("Enter Last name: ");
    
52.                 scanf("%s", emp.lastname);
    
53.                 printf("Enter first name: ");
    
54.                 scanf("%s", emp.firstname);
    
55.                 printf("Enter Salary: ");
    
56.                 scanf("%f", &emp.salary);
    
57. 
    
58.                 memset(&key, 0, sizeof(DBT));
    
59.                 memset(&data, 0, sizeof(DBT));
    
60. 
    
61.                 key.data = &(emp.empid);
    
62.                 key.size = sizeof(emp.empid);
    
63.                 data.data = &emp;
    
64.                 data.size = sizeof(emp_t);
    
65. 
    
66.                 ret = dbp->put(dbp, NULL, &key, &data, DB_NOOVERWRITE);
    
67.                 if (ret != 0) {
    
68.                         printf("Employee ID exists\n");
    
69.                         continue;
    
70.                 }
    
71.         }
    
72. 
    
73.         /* search */
    
74.         while (1) {
    
75.                 printf("Enter Employee ID you wana search: ");
    
76.                 scanf("%d", &emp.empid);
    
77.                 if (emp.empid == 0)
    
78.                         break;
    
79.                 memset(&key, 0, sizeof(DBT));
    
80.                 memset(&data, 0, sizeof(DBT));
    
81. 
    
82.                 key.data = &(emp.empid);
    
83.                 key.size = sizeof(emp.empid);
    
84.                 data.data = &emp;
    
85.                 data.ulen = sizeof(emp_t);
    
86.                 data.flags = DB_DBT_USERMEM;
    
87.                 ret = dbp->get(dbp, NULL, &key, &data, 0);
    
88.                 if (ret != 0) {
    
89.                         printf("Employee ID doesn't exist\n");
    
90.                 } else {
    
91.                         printf("  Employee: %d - %s, %s\n  Salary: $%.2lf\n", emp.empid, emp.lastname, emp.firstname, emp.salary);
    
92.                 }
    
93.         }
    
94. 
    
95.         /* delete */
    
96.         while (1) {
    
97.                 printf("Enter Employee ID you wana delete: ");
    
98.                 scanf("%d", &emp.empid);
    
99.                 if (emp.empid == 0)
    
100.                         break;
     
101.                 memset(&key, 0, sizeof(DBT));
     
102.                 memset(&data, 0, sizeof(DBT));
     
103. 
     
104.                 key.data = &(emp.empid);
     
105.                 key.size = sizeof(emp.empid);
     
106. 
     
107.                 ret = dbp->del(dbp, NULL, &key, 0);
     
108.                 if (ret != 0) {
     
109.                         if (ret == DB_NOTFOUND)
     
110.                                 printf("Employee ID doesn't exist\n");
     
111.                 } else {
     
112.                         printf("  Employee %d deleted.\n", emp.empid);
     
113.                 }
     
114. 
     
115.         }
     
116. 
     
117.         /* cursor */
     
118.         ret = dbp->cursor(dbp, NULL, &cursor, 0);
     
119.         if (ret != 0) {
     
120.                 printf("ERROR: %s\n",db_strerror(ret));
     
121.                 return 1;
     
122.         }
     
123.         memset(&key, 0, sizeof(DBT));
     
124.         memset(&data, 0, sizeof(DBT));
     
125.         data.data = &emp;
     
126.         data.size = sizeof(emp);
     
127.         /* data.flags = DB_DBT_USERMEM; */
     
128. 
     
129.         while ((ret = cursor->get(cursor, &key, &data, DB_NEXT)) == 0) {
     
130.                 printf("ret = %d\n", ret);
     
131.                 printf("%d - %s, %s    $%.2lf\n", emp.empid, emp.lastname, emp.firstname, emp.salary);
     
132.                 memset(&key, 0, sizeof(DBT));
     
133.                 memset(&data, 0, sizeof(DBT));
     
134.         }
     
135.         if (ret < 0) {
     
136.                 printf("ERROR: %s\n",db_strerror(ret));
     
137.         }
     
138.         cursor->close(cursor);
     
139. 
     
140.         dbp->close(dbp, 0);
     
141. 
     
142.         return 0;
     
143. }

复制代码

gcc -Wall test.c -ldb即可
首先提示你输入一些数据，id, 用户名,薪水。然后是测试查找，删除，这些都是没有问题。输入0可以退出一个测试项目
关键是下面的游标，加上DB_DBT_USERMEM，还报“ERROR: DB_BUFFER_SMALL: User memory too small for return value”
游标还不能打出数据，请教到底何处写错了？

zzyong08

memset(&key, 0, sizeof(DBT));
memset(&data, 0, sizeof(DBT));

是不是循环里面，这两行的缘故？还有，key在外面也是初始化为0，为啥？

yulihua49

网上翻了下，没有找到完整的测试代码，即使有c的api相关介绍也是列了一下流程，贴了少许代码，测试下不行。 ...
bsdc 发表于 2010-08-29 21:34

很喜欢berkekeyDB的这种用法，最近把ORACLE也弄成这样了，直接用结构读写数据库。
没用过这个，有一个问题，cursor是需要定义数据访问语句的，或定义一个数据范围，你为何用NULL定义？应该定义成什么？

alonesniper

回复 1# bsdc
我用你的代码在新版本的bdb上运行是没有问题的。


http://www.oracle.com/technetwor ... ownloads/index.html

alonesniper

回复 3# yulihua49
他那个null是txn参数。 bdb的cursor在调用get的时候可以指定一范围参数。请参考：
http://download.oracle.com/docs/ ... g.html#cursorsearch

zhangsuozhu

哇，见识了。这个数据库操起来真简单。

ydfgic

同意2楼，感觉132这两行有问题
        data.data = &emp;
        data.size = sizeof(emp);
        /* data.flags = DB_DBT_USERMEM; */
是不是要放循环里，或者就不用DB_DBT_USERMEM ，直接用db的内存地址

ddgfff

125行，没有对
key.data
key.size
进行赋值，设置吧

bsdc

已经从老外的dba网站上看到原因了，没有设置data的ulen成员大小，ulen我猜想是user memory的大小，具体可以参考手册，有空看看，
重新贴出coursor部分代码
/* cursor */
        ret = dbp->cursor(dbp, NULL, &cursor, 0);
        if (ret != 0) {
                printf("ERROR: %s\n",db_strerror(ret));
                return 1;
        }
        memset(&key, 0, sizeof(DBT));
        memset(&data, 0, sizeof(DBT));
        data.data = &emp;
        data.ulen = sizeof(emp);
        data.flags = DB_DBT_USERMEM;

        while ((ret = cursor->get(cursor, &key, &data, DB_NEXT)) == 0) {
                printf("%d - %-8s,%8s    $%.2lf\n", emp.empid, emp.lastname, emp.firstname, emp.salary);
        }
        cursor->close(cursor);

bsdc

另外，我是参考<<  Professional Linux programming>>里的，那里的代码真不敢恭维，难道是翻译版给整错了？代码写出好多毛病啊，而且还不对。