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, %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<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] end\n", 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, %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<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:%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

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏漏斗社区

代码审计|禅道7.3SQL注入复现

上周的zentaopms漏洞复现你们觉得还OK吗? 斗哥想要的是一个肯定。 如果你们觉得意犹未尽, 本期将进入, 代码审计的小练习。 Zentaopms v7....

3616
来自专栏lgp20151222

Vue生命周期-手动挂载理解

浏览器缓存,试了下确实一定概率可以显示,但是,哪怕浏览器不行,我们也只能从自己的代码里修改来配合它,兼容它。

611
来自专栏SDNLAB

SDNLAB技术分享(三):OpenDaylight中编程抽象的实现

这次主要分三部分说一下,首先我会粗略介绍一下maple system。 之后将以这个为例来阐述一下ODL模块的开发过程。 最后会说明一下ODL模块的结构。 目前...

35110
来自专栏编程

近期做的比较好的web

? 本文作者:p0desta。 感谢p0desta。来稿,本文稿费100元。持续小广告:各位大佬有安全方面新的创作都可以向小编砸过来,将文章以Word形式发送...

1888
来自专栏程序员宝库

购物网站的 redis 相关实现(Java)

本文主要内容: 登录cookie 购物车cookie 缓存数据库行 测试 必备知识点: WEB应用就是通过HTTP协议对网页浏览器发出的请求进行相应的服务器或者...

41013
来自专栏性能与架构

Redis Stream 实践

stream 是一个日志形式的存储结构,可以往里追加数据,每条数据都会生成一个时间戳ID,stream 也有便捷的读取数据的模型。

1912
来自专栏Java技术

Redis存储Key的一种设计实现方式:模式匹配

Redis是Key-Value数据库,存储的时候需要一个唯一的Key值,查询的时候根据根据key值进行查询,但是Redis毕竟只是key-value存储,所以有...

883
来自专栏FreeBuf

渗透测试中利用基于时间差反馈的远程代码执行漏洞(Timed Based RCE)进行数据获取

在最近的渗透测试项目中,为了进一步验证漏洞的可用性和危害性,我们遇到了这样一种情形:构造基于时间差反馈的系统注入命令(OS command injection ...

1989
来自专栏程序员的知识天地

使用 JS 实现一个本地数据库

前端很多时候还是需要保存一些数据的,这里的保存指的是长久的保存。以前的思想是把数据保存在 Cookie 中,或者将 key 保存在 Cookie 中,将其他数据...

1322
来自专栏Java架构沉思录

再谈如何优雅地使用Redis之位图操作

在之前的文章《如何优雅地使用Redis之位图操作》里为大家介绍了Redis位图操作常见的应用场景,今天继续聊聊Redis位图的其他应用。

941

扫码关注云+社区