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 条评论
登录 后参与评论

相关文章

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

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

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

4252
来自专栏程序员宝库

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

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

51314
来自专栏java一日一条

如何从 MongoDB 迁移到 MySQL

最近的一个多月时间其实都在做数据库的迁移工作,我目前在开发的项目其实在上古时代是使用 MySQL 作为主要数据库的,后来由于一些业务上的原因从 MySQL 迁移...

1415
来自专栏腾讯Bugly的专栏

《Android 创建线程源码与OOM分析》

| 导语 企鹅FM近几个版本的外网Crash出现很多OutOfMemory(以下简称OOM)问题,Crash的堆栈都在Thread::start方法上。该文详细...

1.1K5
来自专栏编程

近期做的比较好的web

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

2198
来自专栏性能与架构

Redis Stream 实践

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

3362
来自专栏嵌入式程序猿

Polyspace不认识Interrupt,肿么办?

曾经在公众号中介绍过优秀的软件验证工具Polyspace,有好多猿友在交流群里咨询这个软件的问题,今天我们就典型的如何处理中断来给大家介绍下。 ...

3074
来自专栏Python中文社区

Python云计算框架:OpenStack源码分析之RabbitMQ(二)

之前发布的文章因为在编辑后代码部分在手机上看不清已被及时删除,本文重新编辑好之后再发布一次,带来不便请谅解! 專 欄 ❈ ZZR,Python中文社区专栏作者...

3139
来自专栏Java后端技术栈

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

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

1633
来自专栏计算机视觉与深度学习基础

Leetcode 146 LRU Cache 模拟操作系统LRU

科研学习压力比较大,最近更新的不多,有时间尽量多做一点吧!上来就是一个大模拟。 Design and implement a data structure ...

21510

扫码关注云+社区

领取腾讯云代金券