BDB读、写、删除、更新事物的简单例子。

2024-02-18 15:48
文章标签 简单 更新 删除 例子 事物 bdb

本文主要是介绍BDB读、写、删除、更新事物的简单例子。，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

#include <db.h>
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <string.h>

int fun_main(int ,int ,int);
int  generate_db_data(); //生成数据库
int output_db_data();  //输出数据库
int operate_db_data();  //对数据库的操作选择
int DB_Insert();     //插入
int DB_Delete();   //删除
int DB_Modify();    //修改
int DB_Seach();   //查找

void print_error(int ret)
{
 if(ret != 0)
  printf("ERROR: %s/n",db_strerror(ret));
}

void init_DBT(DBT * key, DBT * data)
{
 memset(key, 0, sizeof(DBT));
 memset(data, 0, sizeof(DBT));
}


int main(int argc, char *argv[])
{
 int ret;
 int generate, output, process;
 
 ret = 0; generate = 0; output = 0; process = 0;
 if(argc != 2)
 {
  printf("argv error! Please run the program with parameter./n");
  printf("Sample : ./fun -g/n");
  exit(ret);
 }
 while(*argv[1] != '/0')
 {
  if(*argv[1] == '-'){
   argv[1]++;
   continue;
  }
  else if(*argv[1] == 'g')
   generate = 1;
  else if(*argv[1] == 'o')
   output = 1;
  else if(*argv[1] == 'p')
   process = 1;
  argv[1]++;
 }
 ret = fun_main(generate, output, process);
 
 exit(ret);
}

int fun_main(int generate, int output, int process)
{
 int ret = 0;
 if(generate == 1&& process != 1){
  
     //DBデータの生成
     ret = generate_db_data();
    
 }
 if(output == 1&& process != 1){
  
  //DBデータの出力
  ret = output_db_data();
 }
 if(process == 1)
 {
  //DBデータの操作
  ret = operate_db_data();
 }
 if(generate == 0 && output == 0 && process == 0)
 {
  printf("parameter input error, please run again!/n");
  printf("Sample : ./fun -o/n");
 }
    return ret;
}
int generate_db_data()
{
 int ret = 0,i;
 DB *dbp1;          
 DBT key, data;
 DB_ENV *dbenv;
 u_int32_t flags; 

//生成10各元素的数据库。

 char *stu_name[10] = {"apple", "orange","banana","strawberry","watermelon","grapes","pineapple","plum","pear","peach"};   int stu_id[10];
 for(i=0; i<10; i++)
  stu_id[i] = i+1;

 ret = db_env_create(&dbenv, 0);
 print_error(ret);

 ret = dbenv->open(dbenv, "./dbtestENV", DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK| DB_INIT_MPOOL|DB_INIT_TXN, 0);
 print_error(ret);

 ret = db_create(&dbp1, dbenv, 0);
 print_error(ret);

 flags = DB_CREATE;
 ret = dbp1->open(dbp1, NULL, "single.db", NULL, DB_BTREE, flags, 0);
 print_error(ret);
 
 for(i=0; i<10; i++){
  init_DBT(&key, &data);
  key.data = stu_name[i];
  key.size = strlen(stu_name[i]) + 1;
  data.data = &stu_id[i];
  data.size = sizeof(int);
  ret = dbp1->put(dbp1, NULL, &key, &data, DB_NOOVERWRITE);
  print_error(ret);
 }
 
 if(dbp1 != NULL)
  dbp1->close(dbp1, 0);
     dbenv->close(dbenv, 0);
 return 0;
}
int output_db_data()
{
 int ret = 0;
 DB *dbp1;          
 DBT key, data;
 DB_ENV *dbenv;
 DBC *cur1;
 DB_TXN *txn1 = NULL;
 u_int32_t flags; 

 ret = db_env_create(&dbenv, 0);
 print_error(ret);

 ret = dbenv->open(dbenv, "./dbtestENV", DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK| DB_INIT_MPOOL|DB_INIT_TXN, 0);
 print_error(ret);

 ret = db_create(&dbp1, dbenv, 0);
 print_error(ret);

 ret = dbenv->txn_begin(dbenv, NULL, &txn1, 0);
 print_error(ret);

 flags = DB_CREATE;
 ret = dbp1->open(dbp1, txn1, "single.db", NULL, DB_BTREE, flags, 0);
 print_error(ret);
 
 ret = dbp1->cursor(dbp1, txn1, &cur1, 0);
 print_error(ret);
 
 init_DBT(&key, &data);
 while((ret = cur1->c_get(cur1, &key, &data, DB_NEXT)) == 0)
 {
  printf("The fruit = %s,/t The number = %d/n", (char *)(key.data), *(int*)(data.data));
 }

 ret = cur1->c_close(cur1);
 print_error(ret);
 ret = txn1->commit(txn1, 0);
 print_error(ret);

 if(dbp1 != NULL)
  dbp1->close(dbp1, 0);
     dbenv->close(dbenv, 0);
 return 0;
}
int operate_db_data()
{
 int ret = 0,sel = 0;
 printf("What do you want to do :/n1.Insert/n2.Delete/n3.Modify/n4.Search/n");
 scanf("%d",&sel);
 switch(sel)
 {
  case 1:
   DB_Insert();
   break;
  case 2:
   DB_Delete();
   break;
  case 3:
   DB_Modify();
   break;
  case 4:
   DB_Seach();
   break;
  default:
   printf("please select from 1-4! /n");
 }
 return ret;
}
int DB_Insert()
{
 int ret = 0;
 DB *dbp1;          
 DBT key, data;
 DB_ENV *dbenv;
 u_int32_t flags; 

 char name[20] = {0};
 int number;
 printf("Please input the data and value :");
 scanf("%s%d",name,&number);
 printf("You insert data : The fruit =/"%s/", the number = /"%d/"/n",name,number);

 ret = db_env_create(&dbenv, 0);
 print_error(ret);

 ret = dbenv->open(dbenv, "./dbtestENV", DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK| DB_INIT_MPOOL|DB_INIT_TXN, 0);
 print_error(ret);

 ret = db_create(&dbp1, dbenv, 0);
 print_error(ret);

 flags = DB_CREATE;
 ret = dbp1->open(dbp1, NULL, "single.db", NULL, DB_BTREE, flags, 0);
 print_error(ret);
 init_DBT(&key, &data);
 key.data = name;
 key.size = strlen(name) + 1;
 data.data = &number;
 data.size = sizeof(int);
 ret = dbp1->put(dbp1, NULL, &key, &data, DB_NOOVERWRITE);
 print_error(ret);

 if(ret == 0)
  printf("INSERT SUCCESS!/n");
 else
  printf("INSERT FAILED!/n");
 if(dbp1 != NULL)
  dbp1->close(dbp1, 0);
     dbenv->close(dbenv, 0);
 return ret;
}
int DB_Delete()
{
 int ret=0;
 char name[20];
 DB *dbp1;          
 DBT key, data;
 DB_ENV *dbenv;
 u_int32_t flags; 

 printf("Which data do you want to delete: ");
 scanf("%s",name);
 printf("You want to delete the data is :/"%s/"/n",name);
 
 ret = db_env_create(&dbenv, 0);
 print_error(ret);

 ret = dbenv->open(dbenv, "./dbtestENV", DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK| DB_INIT_MPOOL|DB_INIT_TXN, 0);
 print_error(ret);

 ret = db_create(&dbp1, dbenv, 0);
 print_error(ret);

 flags = DB_CREATE;
 ret = dbp1->open(dbp1, NULL, "single.db", NULL, DB_BTREE, flags, 0);
 print_error(ret);
 init_DBT(&key, &data);
 key.data = name;
 key.size = strlen(name) + 1;
 ret = dbp1->del(dbp1, NULL, &key, 0);
 print_error(ret);

 if(ret == 0)
  printf("DELETE SUCCESS!/n");
 else
  printf("DELETE FAILED!/n");
 if(dbp1 != NULL)
  dbp1->close(dbp1, 0);
     dbenv->close(dbenv, 0);

 return ret;
}
int DB_Modify()
{
 int ret = 0;
 DB *dbp1;          
 DBT key, data;
 DB_ENV *dbenv;
 DBC *cur1;
 DB_TXN *txn1 = NULL;
 u_int32_t flags; 
 
 char name_old[20], name_new[20];
 int number;
 printf("Which data do you want to modify(key name): ");
 scanf("%s",name_old);
 printf("The new data is :");
 scanf("%s%d",name_new, &number);

 ret = db_env_create(&dbenv, 0);
 print_error(ret);

 ret = dbenv->open(dbenv, "./dbtestENV", DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK| DB_INIT_MPOOL|DB_INIT_TXN, 0);
 print_error(ret);

 ret = db_create(&dbp1, dbenv, 0);
 print_error(ret);

 ret = dbenv->txn_begin(dbenv, NULL, &txn1, 0);
 print_error(ret);

 flags = DB_CREATE;
 ret = dbp1->open(dbp1, txn1, "single.db", NULL, DB_BTREE, flags, 0);
 print_error(ret);
 
 ret = dbp1->cursor(dbp1, txn1, &cur1, 0);
 print_error(ret);
 
 init_DBT(&key, &data);
 key.data = name_old;
 key.size = strlen(name_old) + 1;

 while((ret = cur1->c_get(cur1, &key, &data, DB_SET)) == 0)
 {
  printf("The data you want to modify is: The fruit = %s,/t The number = %d/n", (char *)(key.data), *(int*)(data.data));
  ret = cur1->c_del(cur1, 0);
  break;
 }
  init_DBT(&key, &data);
  key.data = name_new;
  key.size = strlen(name_new) + 1;
  data.data = &number;
  data.size = sizeof(int);
  ret = dbp1->put(dbp1, txn1, &key, &data, DB_NOOVERWRITE);

 if(ret == 0)
  printf("MODIFY SUCCESS!/n");
 else
  printf("MODIFY FAILED!/n");

 ret = cur1->c_close(cur1);
 print_error(ret);
 ret = txn1->commit(txn1, 0);
 print_error(ret);
 if(dbp1 != NULL)
  dbp1->close(dbp1, 0);
     dbenv->close(dbenv, 0);
 return 0;
}
int DB_Seach()
{
 int ret = 0;
 DB *dbp1;          
 DBT key, data;
 DB_ENV *dbenv;
 DBC *cur1;
 DB_TXN *txn1 = NULL;
 u_int32_t flags; 
 
 char name[20];
 printf("Which data do you want to search: ");
 scanf("%s",name);
 printf("You want to search the data is :/"%s/"/n",name);

 ret = db_env_create(&dbenv, 0);
 print_error(ret);

 ret = dbenv->open(dbenv, "./dbtestENV", DB_CREATE|DB_INIT_LOG|DB_INIT_LOCK| DB_INIT_MPOOL|DB_INIT_TXN, 0);
 print_error(ret);

 ret = db_create(&dbp1, dbenv, 0);
 print_error(ret);

 ret = dbenv->txn_begin(dbenv, NULL, &txn1, 0);
 print_error(ret);

 flags = DB_CREATE;
 ret = dbp1->open(dbp1, txn1, "single.db", NULL, DB_BTREE, flags, 0);
 print_error(ret);
 
 ret = dbp1->cursor(dbp1, txn1, &cur1, 0);
 print_error(ret);
 
 init_DBT(&key, &data);
 key.data = name;
 key.size = strlen(name) + 1;

 while((ret = cur1->c_get(cur1, &key, &data, DB_SET)) == 0)
 {
  printf("The fruit = %s,/t The number = %d/n", (char *)(key.data), *(int*)(data.data));
  break;
 }
 if(ret != 0)
  printf("The data which you want cannot found./n");
 
 ret = cur1->c_close(cur1);
 print_error(ret);
 ret = txn1->commit(txn1, 0);
 print_error(ret);
 if(dbp1 != NULL)
  dbp1->close(dbp1, 0);
     dbenv->close(dbenv, 0);
 return 0;

}

 

这篇关于BDB读、写、删除、更新事物的简单例子。的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/721640。

相关文章

Python实现自动化删除Word文档超链接的实用技巧

Python实现自动化删除Word文档超链接的实用技巧

《Python实现自动化删除Word文档超链接的实用技巧》在日常工作中,我们经常需要处理各种Word文档,本文将深入探讨如何利用Python,特别是借助一个功能强大的库,高效移除Word文档中的超链接... 目录为什么需要移除Word文档超链接准备工作：环境搭建与库安装核心实现：使用python移除超链接的
阅读更多...
Python 基于http.server模块实现简单http服务的代码举例

Python 基于http.server模块实现简单http服务的代码举例

《Python基于http.server模块实现简单http服务的代码举例》Pythonhttp.server模块通过继承BaseHTTPRequestHandler处理HTTP请求,使用Threa... 目录测试环境代码实现相关介绍模块简介类及相关函数简介参考链接测试环境win11专业版python
阅读更多...
MySQL 数据库表操作完全指南:创建、读取、更新与删除实战

MySQL 数据库表操作完全指南:创建、读取、更新与删除实战

《MySQL数据库表操作完全指南:创建、读取、更新与删除实战》本文系统讲解MySQL表的增删查改（CURD）操作,涵盖创建、更新、查询、删除及插入查询结果,也是贯穿各类项目开发全流程的基础数据交互原... 目录mysql系列前言一、Create(创建)并插入数据1.1 单行数据 + 全列插入1.2 多行数据
阅读更多...
linux安装、更新、卸载anaconda实践

linux安装、更新、卸载anaconda实践

《linux安装、更新、卸载anaconda实践》Anaconda是基于conda的科学计算环境,集成1400+包及依赖,安装需下载脚本、接受协议、设置路径、配置环境变量,更新与卸载通过conda命令... 目录随意找一个目录下载安装脚本检查许可证协议，ENTER就可以安装完毕之后激活anaconda安装更
阅读更多...
python中update()函数的用法和一些例子

python中update()函数的用法和一些例子

《python中update()函数的用法和一些例子》update()方法是字典对象的方法,用于将一个字典中的键值对更新到另一个字典中,：本文主要介绍python中update()函数的用法和一些... 目录前言用法注意事项示例示例 1: 使用另一个字典来更新示例 2: 使用可迭代对象来更新示例 3: 使用
阅读更多...
python连接sqlite3简单用法完整例子

python连接sqlite3简单用法完整例子

《python连接sqlite3简单用法完整例子》SQLite3是一个内置的Python模块,可以通过Python的标准库轻松地使用,无需进行额外安装和配置,：本文主要介绍python连接sqli... 目录1. 连接到数据库2. 创建游标对象3. 创建表4. 插入数据5. 查询数据6. 更新数据7. 删除
阅读更多...
Jenkins的安装与简单配置过程

Jenkins的安装与简单配置过程

《Jenkins的安装与简单配置过程》本文简述Jenkins在CentOS7.3上安装流程,包括Java环境配置、RPM包安装、修改JENKINS_HOME路径及权限、启动服务、插件安装与系统管理设置... 目录www.chinasem.cnJenkins安装访问并配置JenkinsJenkins配置邮件通知
阅读更多...
mybatisplus的逻辑删除过程

mybatisplus的逻辑删除过程

《mybatisplus的逻辑删除过程》：本文主要介绍mybatisplus的逻辑删除过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录myBATisplus的逻辑删除1、在配置文件中添加逻辑删除的字段2、在实体类上加上@TableLogic3、业务层正常删除即
阅读更多...
MybatisPlus中removeById删除数据库未变解决方案

MybatisPlus中removeById删除数据库未变解决方案

《MybatisPlus中removeById删除数据库未变解决方案》MyBatisPlus中,removeById需实体类标注@TableId注解以识别数据库主键,若字段名不一致,应通过value属... 目录MyBATisPlus中removeBypythonId删除数据库未变removeById(Se
阅读更多...
Nginx进行平滑升级的实战指南(不中断服务版本更新)

Nginx进行平滑升级的实战指南(不中断服务版本更新)

《Nginx进行平滑升级的实战指南(不中断服务版本更新)》Nginx的平滑升级（也称为热升级）是一种在不停止服务的情况下更新Nginx版本或添加模块的方法,这种升级方式确保了服务的高可用性,避免了因升... 目录一.下载并编译新版Nginx1.下载解压2.编译二.替换可执行文件，并平滑升级1.替换可执行文件
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2