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

相关文章

来自专栏企鹅号快讯

探索Android架构组件Room

文:栋栋 本文原创,转载请注明作者及出处 一、简介 Room是Google推出的Android架构组件库中的数据持久化组件库, 也可以说是在SQLite上实现的...

3015
来自专栏阿杜的世界

Mybatis 3学习笔记(一)主要内容:

MyBatis是一个开源持久化框架,用于简化持久层的实现。Mybatis可以减少很多JDBC相关的模板样式代码,还提供了方便使用的数据库API。

543
来自专栏java学习

Java每日一练(2017/8/2)

本期题目: (单选题)1、在 java 中,一个类可同时定义为许多同名的方法,这些方法的形式参数个数,类型或顺序各不相同,传回的值可能个不相同,这种面向对象的...

2527
来自专栏Kevin-ZhangCG

[ SSH框架 ] Hibernate框架学习之三

17911
来自专栏菜鸟致敬

MySQL 数据类型

MySQL中定义数据字段的类型对你数据库的优化是非常重要的。 MySQL支持多种类型,大致可以分为三类:数值、日期/时间和字符串(字符)类型。 ---- 数值类...

3037
来自专栏小灰灰

报警系统QuickAlarm之报警执行器的设计与实现

根据前面一篇总纲的博文,将整体结构划分为了四大块,本文则主要目标集中在第一块,报警执行器(AlarmExecute)的设计与加载上了 主要的关注点无外乎 定义-...

2725
来自专栏开发技术

cassandra高级操作之分页的java实现(有项目具体需求)

  接着上篇博客,我们来谈谈java操作cassandra分页,需要注意的是这个分页与我们平时所做的页面分页是不同的,具体有啥不同,大家耐着性子往下看。

751
来自专栏DOTNET

Entity Framework——建模建库

1数据库初始化策略选择 三种初始化策略: 1)CreateDatabaseIfNotExists:默认的策略。如果数据库不存在,那么就创建数据库。但是如果数据库...

2877
来自专栏猿人谷

mybatis调用视图和存储过程

    现在的项目是以Mybatis作为O/R映射框架,确实好用,也非常方便项目的开发。MyBatis支持普通sql的查询、视图的查询、存储过程调用,是一种非常...

2185
来自专栏xingoo, 一个梦想做发明家的程序员

Java程序员的日常——存储过程知识普及

存储过程是保存可以接受或返回用户提供参数的SQL语句集合。在日常的使用中,经常会遇到复杂的业务逻辑和对数据库的操作,使用存储过程可以进行封装。可以在数据库中定...

1748

扫码关注云+社区