C++ FFLIB 之FFDB： 使用 Mysql&Sqlite 实现CRUD

htbzwd

摘要：
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, %d\n", 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, %d\n", 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& ret_data_);
int  exe_sql(const string& sql_, vector& ret_data_, vector& 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
void dump(vector& 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.size(); ++j)
{
printf(" %s", ret_data[j].c_str());
}
printf(" =======row[%u] end\n", i);
}
ret_data.clear();
}
struct foo_t: public ffcrud_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 ret_data;
if (ffdb.connect("sqlite://./test.db"))
{
printf("connect error:%s, %d\n", 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:%s\n", ffdb.error_msg());
}
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%s\n", ffdb.error_msg());
}
dump(ret_data);

ffcrud_register_t::bind_table("dumy", "A")
.def(&foo_t::a, "A")
.def(&foo_t::c, "C")
.def(&foo_t::b, "B");

printf("foo insert:\n", foo.insert_sql().c_str());
printf("foo select:\n", foo.select_sql().c_str());
printf("foo update:\n", foo.update_sql().c_str());
printf("foo delete:\n", foo.del_sql().c_str());
if (foo.insert(ffdb))
{
printf("exist foo insert:\n", foo.insert_sql().c_str());
}
foo.select(ffdb);
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%s\n", ffdb.error_msg());
}
dump(ret_data);
foo.m_c = 23.99;
if (ffdb.exe_sql(foo.update_sql(), ret_data))
{
printf("exe error:%s\n", ffdb.error_msg());
}
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%s\n", ffdb.error_msg());
}
dump(ret_data);
/*
if (ffdb.exe_sql(foo.del_sql(), ret_data))
{
printf("exe error:%s\n", ffdb.error_msg());
}
if (ffdb.exe_sql("select * from dumy", ret_data))
{
printf("exe error:%s\n", 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:%s\n", 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:%s\n", ffdb.error_msg());
}
dump(ret_data);
return 0;
}
源代码:
https://github.com/fanchy/fflib/tree/master/example/book/sqlite