专栏首页H2CloudC++ FFLIB 之FFDB: 使用 Mysql&Sqlite 实现CRUD

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

相关文章

  • FF ASIO 异步消息网络框架

    在前边 https://cloud.tencent.com/developer/article/1056482 我提到,针对前面使用boost asio 中遇到...

    知然
  • C++ 多进程并发框架FFLIB之Tutorial

          FFLIB框架是为简化分布式/多进程并发而生的。它起始于本人尝试解决工作中经常遇到的问题如消息定义、异步、多线程、单元测试、性能优化等。基本介绍可以...

    知然
  • Boost asio 心得笔记

    Boost asio中有两点用的不爽: 1. asio中的所有对象都引用io_service 2. async_write还要自己保证内存在completed之...

    知然
  • Java后端技术从0到1技术路线,一步步走向大神!

    最近很多入群的小伙伴私聊我Java后端怎么学?学了之后能干什么?学了这个之后接着学什么?我曾和他们一样迷茫的走了一步步,现在抽时间给大家整理一份学习的技术路线,...

    Java后端技术
  • Spring面试27道高频考点,你能答出几道?

    Spring框架是一个为Java应用程序开发提供综合、广泛的基础性支持的Java平台。 Spring帮助开发者解决了开发中基础性的问题,使得开发人员可以专注于应...

    挨踢小子部落阁
  • POSTGRESQL WAL 机制理解

    最近和POSTGRESQL 较劲的多,如果能更多的理解POSTGRESQL 的工作原理,并且深入分析,对日后的管理和适用会比较有帮助,多学点是没有坏处的,并且P...

    AustinDatabases
  • 27道高频Spring面试题,你能答对几个?

    Spring框架是一个为Java应用程序开发提供综合、广泛的基础性支持的Java平台。 Spring帮助开发者解决了开发中基础性的问题,使得开发人员可以专注于应...

    程序员追风
  • SpringMVC-易于同其它View框架无缝集成

    Spring MVC属于SpringFrameWork的后续产品,已经融合在Spring Web Flow里面。Spring 框架提供了构建 ...

    一点博客
  • 无需用户输入,Adobe提出自动生成高质量合成图像新方法

    图像合成是指组合不同图像中的部分区域以合成一张新的图像,一个常见的用例是肖像图片的背景替换。为了获得高质量的合成图像,经常需要专业人员手动执行多个编辑步骤,例如...

    机器之心
  • 无需用户输入,Adobe提出自动高质量图像合成新方法

    图像合成是指组合不同图像中的部分区域以合成一张新的图像,一个常见的用例是肖像图片的背景替换。为了获得高质量的合成图像,经常需要专业人员手动执行多个编辑步骤,例如...

    CV君

扫码关注云+社区

领取腾讯云代金券