berkeley db 如何检测数据库已经存在

wangya072

berkeley db 如何检测数据库已经存在

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <unistd.h>
   
4. #include <string.h>
   
5. #include <pthread.h>
   
6. #include <errno.h>
   
7. #include <db.h>
   
8. 
   
9. void init_dbt (DBT *key, DBT *data)
   
10. {
    
11.         memset (key, 0, sizeof (DBT));
    
12.         memset (data, 0, sizeof (DBT));
    
13. }
    
14. 
    
15. int main ()
    
16. {
    
17.         DB_ENV        *dbenv         = NULL;
    
18.         DB        *dbp        = NULL;
    
19.         int         ret         = 0;
    
20.         DBC        *dbc        = NULL;
    
21.         DBT        key         = {0,};
    
22.         DBT        data        = {0,};
    
23.         int         i        = 10;       
    
24.         #if 1
    
25.         if (db_env_create (&dbenv, 0)) {
    
26.                 printf ("db_env_create %s\n", db_strerror (ret));
    
27.                 goto out;
    
28.         }
    
29.         printf ("env create success\n");
    
30.         //dbenv->set_errpfx (dbenv, "brick_name");
    
31.        
    
32.         ret = dbenv->open (dbenv, "/tmp/wyz",
    
33.                 DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK|
    
34.                         DB_INIT_MPOOL, 0);
    
35.         if (ret) {
    
36.                 printf ("dbenv_open :%s\n", db_strerror (ret));       
    
37.                 goto out;
    
38.         }
    
39.         #endif
    
40.         ret = db_create (&dbp, dbenv, 0);
    
41.         if (ret) {
    
42.                 printf ("db_create %s\n", db_strerror (ret));
    
43.                 goto out;
    
44.         }
    
45.         ret = dbp->open (dbp, NULL, "a.db", NULL, DB_HASH, DB_CREATE, 0);
    
46.         if (ret) {
    
47.                 printf ("db_open %s\n", db_strerror (ret));
    
48.                 goto out;
    
49.         }
    
50.         ret = dbp->cursor (dbp, NULL, &dbc, 0);
    
51.         if (ret) {
    
52.                 printf ("cursor : %s\n", db_strerror (ret));
    
53.                 goto out;
    
54.         }
    
55.         init_dbt (&key, &data);
    
56.         key.data = &i;
    
57.         key.size = sizeof (int);
    
58.         data.data = &i;
    
59.         data.size = sizeof (int);
    
60. 
    
61.         while (i) {
    
62.                 printf ("put ===============key = %d data = %d\n",*(int*)key.data, *(int*)data.data );
    
63.                 ret = dbp->put (dbp, NULL, &key, &data, DB_NOOVERWRITE);
    
64.                 if (ret) {
    
65.                         printf ("db_put %s\n", db_strerror (ret));
    
66.                         break;
    
67.                 }
    
68.                 i--;
    
69.         }
    
70.         while (1) {
    
71.                 ret = dbc->get (dbc, &key, &data, DB_NEXT);
    
72.                 sleep (1);
    
73.                 if (ret) {
    
74.                         printf ("cursor get : %s\n", db_strerror (ret));
    
75.                         break;
    
76.                 }
    
77.                 printf ("get ===================key = %d data = %d\n",*(int*)key.data, *(int*)data.data );
    
78.         }
    
79. out:
    
80.         return ret;       
    
81. }
    

复制代码

bsdc

同问啊,万一程序以外终止,没有进行正常关闭,销毁句柄,再次起来,就会出现在put时候卡住的情况.

真米那么

路过看看了~