C++ FFLIB 之FFDB: 使用 Mysql&Sqlite 实现CRUD
摘要:
C++ 操作DB真心不是太省心的事,一方面C++操作DB的接口大部分都使用C API,如Mysql、Sqlite 提供的API。尽管其C API文档已经足够清晰详细,仍然存在一些问题,如内存申请、释放,结果集的遍历等。大多数人都会稍作封装来隐藏CAPI 的细节,毕竟常用的操作无非是增删改查。另一方面目前没有比较方便易用的C++ 数据库操作框架,导致C++ 的面向对象的内存模型与SQL DB 的关系型模型很难适配。我曾在几个项目中看到过非常究竟的C++对象与SQL 行的映射框架。从那时起我就想完成一个轻量又实用的DB操作类库。今天,此类库已经初具雏形, 那就是FFDB。
FFDB 只是一个非常轻量的C++ 类库,然而他实现的功能绝对能让人印象深刻,某种意义上说具有些许的开创性。FFDB 是与可扩展的,FFDB 当前已经实现了Mysql和Sqlite的支持, 增加其他sql 支持也是很容易的。FFDB具有如下功能:
- FFDB 封装针对DB 连接,统一了接口,当前FFDB 做了相当大的取舍,在我的大部分日常工作中,他读完全满足需求。
- FFDB 封装了各个SQL DB 之间的区别,当需要换DB时,只需修稿连接的参数,而不是去修改所有相关的API 调用代码。
- FFDB 提供了一个工具类FFCRUD, 封装了对SQL DB的CRUD操作,FFCRUD保证了C++中操作内存对象后,同步到DB的操作变得舒服又容易。
FFDB 封装DB连接
连接SQL DB, ffdb 提供了非常简易的语法,连接sqlite的代码:
if (ffdb.connect("sqlite:///tmp/test.db"))
{
printf("connect error:%s, %dn", ffdb.error_msg(), ffdb.is_connected());
return 1;
}
而连接mysql 则只需该成:
if (ffdb.connect("mysql://127.0.0.1:3306/user/passwd/db"))
{
printf("connect error:%s, %dn", ffdb.error_msg(), ffdb.is_connected());
return 1;
}
FFDB 执行SQL
FFDB 中执行sql的接口为:
int exe_sql(const string& sql_, db_each_row_callback_i* cb_ = NULL);
int exe_sql(const string& sql_, vector<vector<string> >& ret_data_);
int exe_sql(const string& sql_, vector<vector<string> >& ret_data_, vector<string>& col_names_);
第一个版本接口可以通过传递回调函数定制如何获取结果集数据。一般而言,要遍历结果集只需要第二个版本的接口,将所有数据集转换为字符串数组。使用者剩了关心内存分配释放细节。
FFDB 的关闭和影响行数
void close();
int affect_rows();
ffcrud 实现内存对象在SQL DB的增删改查
ffcrud是模板类,重要的接口如下:
string insert_sql()
string select_sql()
string update_sql()
string del_sql()
int insert(ffdb_t& ffdb)
int select(ffdb_t& ffdb)
int update(ffdb_t& ffdb)
int del(ffdb_t& ffdb)
xx_sql相关的操作返回要执行相关操作的sql字符串,ffcrud没有限定必须使用ffdb,这样某些场合可以使用该sql语句用来异步执行。同时ffcrud与 ffdb可以完美的结合,只要提供ffdb实例对象,内存对象数据可以直接同步到sql db中。
ffcrud如何映射内存对象到sql db中
ffcrud_register_t 完成内存对象和sql db中表的映射,在日常开发中,我发现最烦的最易变化的就是对象中的字段和数据库中的字段的对应关系。使用ffcrud_register_t,尽最大程度的把映射关系做出配置,如果你愿意,完全可以从配置文件中读入映射关系。
示例代码:
#include "db/ffdb.h"
#include "db/ffcrud.h"
using namespace ff;
#include <stdio.h>
void dump(vector<vector<string> >& ret_data)
{
for (size_t i = 0; i < ret_data.size(); ++i)
{
printf("row[%u] begin======= ", i);
for (size_t j = 0; j < ret_data[i].size(); ++j)
{
printf(" %s", ret_data[i][j].c_str());
}
printf(" =======row[%u] endn", i);
}
ret_data.clear();
}
struct foo_t: public ffcrud_t<foo_t>
{
foo_t():
a(167),
b("ddd"),
m_c(11.22){}
int a;
string b;
double& c() { return m_c; }
double m_c;
};
int main(int argc, char* argv[])
{
ffdb_t ffdb;
foo_t foo;
vector<vector<string> > ret_data;
if (ffdb.connect("sqlite://./test.db"))
{
printf("connect error:%s, %dn", ffdb.error_msg(), ffdb.is_connected());
return 1;
}
if (ffdb.exe_sql("CREATE TABLE IF NOT EXISTS dumy (A int, c float, b varchar(200), primary key (A))"))
{
printf("exe error:%sn", ffdb.error_msg());
}
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
dump(ret_data);
ffcrud_register_t<foo_t>::bind_table("dumy", "A")
.def(&foo_t::a, "A")
.def(&foo_t::c, "C")
.def(&foo_t::b, "B");
printf("foo insert:<%s>n", foo.insert_sql().c_str());
printf("foo select:<%s>n", foo.select_sql().c_str());
printf("foo update:<%s>n", foo.update_sql().c_str());
printf("foo delete:<%s>n", foo.del_sql().c_str());
if (foo.insert(ffdb))
{
printf("exist foo insert:<%s>n", foo.insert_sql().c_str());
}
foo.select(ffdb);
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
dump(ret_data);
foo.m_c = 23.99;
if (ffdb.exe_sql(foo.update_sql(), ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
dump(ret_data);
/*
if (ffdb.exe_sql(foo.del_sql(), ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
dump(ret_data);
*/
//if (ffdb.exe_sql("SELECT C FROM foo WHERE A = 167 limit 1;", ret_data))
if (ffdb.exe_sql(foo.select_sql(), ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
dump(ret_data);
foo.b += "a";
foo.update(ffdb, &foo_t::b);
if (ffdb.exe_sql(foo.select_sql(), ret_data))
{
printf("exe error:%sn", ffdb.error_msg());
}
dump(ret_data);
return 0;
}
源代码:
https://github.com/fanchy/fflib/tree/master/example/book/sqlite
- Hygieia 为何物?DevOps 利器也
- 汽车攻击离你很近:一分钟变成汽车黑客
- LIFX智能灯泡漏洞泄露WIFI密码
- android ViewPager+Fragment之懒加载
- 逆向APK进行smali注入实现“秒破WIFI”
- 我所理解的Android 启动模式
- 搭建开源入侵检测系统Snort,并实现与防火墙联动
- 如何在Python中为长短期记忆网络扩展数据
- android 开发Handler源码剖析
- Keras作为TensorFlow的简化界面:教程
- Android基础:Fragment,看这篇就够了
- Rest api简介
- crossdomain.xml文件配置不当利用手法
- Android 常用的ORM框架详解
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 基于STM32+RT-Thread的新冠肺炎疫情监控平台
- Python 基础(二十):sys 模块
- [Oracle 故障处理]记一次Windows监听启动失败
- Python 基础(二十一):argparse 模块
- LeetCode 4 题解
- 操作系统与 CPU 是怎么执行线程的?
- LeetCode 5 题解
- 详细齐全!Docker常用基本命令
- angular浏览器兼容性问题解决方案
- Python 基础(二十二):正则表达式
- Python 进阶(一):多线程
- Python 进阶(二):多进程
- MySQL information_schema详解 EVENTS
- Python 进阶(三):邮件的发送与收取
- MySQL information_schema详解 FILES