一个简单的支持MySQL和SQLite3的DB接口

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: C++源代码:simple_db.zip相关联代码:https://github.com/eyjian/mooon/tree/master/common_library/include #ifndef MOOON_SYS_SIMPLE_DB_H ...
C++源代码: img_e25d4fb2f8de1caf41a735ec53088516.pngsimple_db.zip
相关联代码: https://github.com/eyjian/mooon/tree/master/common_library/include

  1. #ifndef MOOON_SYS_SIMPLE_DB_H
  2. #define MOOON_SYS_SIMPLE_DB_H
  3. #include "sys/db_exception.h"
  4. #include string>
  5. #include vector>
  6. SYS_NAMESPACE_BEGIN

  7. typedef std::vectorstd::string> DBRow; // 用来存储一行所有字段的值
  8. typedef std::vectorDBRow> DBTable; // 用来存储所有行

  9. /**
  10.  * 访问DB的接口,是一个抽象接口,当前只支持MySQL
  11.  *
  12.  * 使用示例:
  13. DBConnection* db_connection = DBConnection::create_connection("mysql");
  14. try
  15. {
  16.     DBTable db_table;

  17.     // 不指定DB名,以及不需要密码
  18.     db->set_host("127.0.0.1", 3600);
  19.     db->set_user("root", "");
  20.     db->set_charset("utf8");
  21.     db->enable_auto_reconnect();
  22.     db->set_timeout_seconds(600);
  23.     
  24.     db_connection->open();
  25.     db_connection->query(db_table, "select count(1) from test_table where id=%d", 2015);
  26. }
  27. catch (CDBException& db_error)
  28. {
  29.     log("%s error: %s at %s:%d", db_connection.str().c_str(), db_error.what(), db_error.file(), db_error.lien());
  30. }

  31. DBConnection::destroy_connection(db_connection);
  32.  */
  33. class DBConnection
  34. {
  35. public:
  36.     /***
  37.      * 工厂方法 - 创建一个DB连接
  38.      * @db_type_name DB类型名,如:mysql、oracle、postgreSQL,不区别大小写
  39.      * 当前只支持MySQL和SQLite3,也就是参数值只能输入mysql(不区别大小写)
  40.      * @sql_max 支持的最大SQL语句长度,单位为字节数,不含结尾符
  41.      * 如果是支持的DB类型,则返回非NULL,否则返回NULL
  42.      */
  43.     static DBConnection* create_connection(const std::string& db_type_name, size_t sql_max);

  44.     /***
  45.      * 销毁一个由create_connection()创建的DB连接
  46.      * @db_connection 需要销毁的DB连接
  47.      */
  48.     static void destroy_connection(DBConnection* db_connection);

  49.     /***
  50.      * 判断是否为网络连接断开异常,
  51.      * 如使用过程中,与MySQL间的网络中断,或MySQL进程死掉等,这种情况下可以尝试重连接
  52.      */
  53.     static bool is_disconnected_exception(CDBException& db_error);

  54. public:
  55.     virtual ~DBConnection() {}
  56.     
  57.     /***
  58.      * 设置需要连接的DB的IP和服务端口号
  59.      * 注意,只有在open()或reopen()之前调用才生效
  60.      */
  61.     virtual void set_host(const std::string& db_ip, uint16_t db_port) = 0;

  62.     /***
  63.      * 设置连接的数据库名
  64.      * 注意,只有在open()或reopen()之前调用才生效
  65.      */
  66.     virtual void set_db_name(const std::string& db_name) = 0;
  67.     
  68.     /***
  69.      * 设置用来连接DB的用户名和密码
  70.      * 注意,只有在open()或reopen()之前调用才生效
  71.      */
  72.     virtual void set_user(const std::string& db_user, const std::string& db_password) = 0;
  73.     
  74.     /***
  75.      * 设置访问DB的字符集
  76.      * 注意,只有在open()或reopen()之前调用才生效
  77.      */
  78.     virtual void set_charset(const std::string& charset) = 0;
  79.     
  80.     /***
  81.      * 设置为连接断开后自动重连接,如果不主动设置,默认不自动重连接
  82.      * 注意,只有在open()或reopen()之前调用才生效
  83.      */
  84.     virtual void enable_auto_reconnect() = 0;
  85.     
  86.     /***
  87.      * 设置用来连接的超时秒数,如果不主动设置,则使用默认的10秒
  88.      * 注意,只有在open()或reopen()之前调用才生效
  89.      */
  90.     virtual void set_timeout_seconds(int timeout_seconds) = 0;
  91.     
  92.     /***
  93.      * 设置空值,字段在DB表中的值为NULL时,返回的内容
  94.      * 如果不主动设置,则默认空值时被设置为"NULL"
  95.      */
  96.     virtual void set_null_value(const std::string& null_value) = 0;
  97.     
  98.     /***
  99.      * 建立一个DB连接
  100.      * 出错抛出异常CDBException
  101.      */
  102.     virtual void open() throw (CDBException) = 0;

  103.     /**
  104.      * 关闭一个DB连接
  105.      * 使用open()建立的连接,在使用完后,要使用close()关闭它
  106.      */
  107.     virtual void close() throw () = 0;

  108.     /***
  109.      * 重新建立DB连接
  110.      * reopen()会先调用close()关闭连接,然后才重新建立连接,
  111.      * 因此调用reopen()之前,可不调用close(),当然即使调用了close()也不会有问题
  112.      */
  113.     virtual void reopen() throw (CDBException) = 0;

  114.     /***
  115.       * 数据库查询类操作,包括:select, show, describe, explain和check table等,
  116.       * 如果某字段在DB表中为NULL,则返回结果为"NULL",如果内容刚好为"NULL",则无法区分
  117.       * 出错抛出CDBException异常
  118.       */
  119.     virtual void query(DBTable& db_table, const char* format, ...) throw (CDBException) __attribute__((format(printf, 3, 4))) = 0;

  120.     /**
  121.      * 查询,期望只返回一行记录,
  122.      * 如果某字段在DB表中为NULL,则返回结果为空字符串,因此不能区分字段无值还是值为空字符串
  123.      * 如果查询失败,抛出CDBException异常,异常的错误码为-1,
  124.      * 如果查询实际返回超过一行记录,抛出CDBException异常,异常的错误码为DB_ERROR_TOO_MANY_ROWS
  125.      */
  126.     virtual void query(DBRow& db_row, const char* format, ...) throw (CDBException) __attribute__((format(printf, 3, 4))) = 0;

  127.     /**
  128.      * 查询,期望只返回单行单列,
  129.      * 如果某字段在DB表中为NULL,则返回结果为空字符串,因此不能区分字段无值还是值为空字符串
  130.      * 如果查询失败,抛出CDBException异常,异常的错误码为-1,
  131.      * 如果查询实际返回超过一行记录,抛出CDBException异常,异常的错误码为DB_ERROR_TOO_MANY_ROWS,
  132.      * 如果查询实际返回只有一行,但超过一列,则抛出CDBException异常,异常的错误码为DB_ERROR_TOO_MANY_COLS
  133.      */
  134.     virtual std::string query(const char* format, ...) throw (CDBException) __attribute__((format(printf, 2, 3))) = 0;

  135.     /***
  136.       * 数据库insert和update更新操作
  137.       * 成功返回受影响的记录个数,出错则抛出CDBException异常
  138.       */
  139.     virtual int update(const char* format, ...) throw (CDBException) __attribute__((format(printf, 2, 3))) = 0;

  140.     /**
  141.      * 取得可读的字符串信息
  142.      */
  143.     virtual std::string str() throw () = 0;
  144. };

  145. SYS_NAMESPACE_END
  146. #endif // MOOON_SYS_SIMPLE_DB_H

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
打赏
0
0
0
0
9
分享
相关文章
Python处理数据库:MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库,包括安装必要的库、连接数据库、执行增删改查等基本操作,适合初学者快速上手。
202 15
node博客小项目:接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目:接口开发、连接mysql数据库
七天.NET 8操作SQLite入门到实战 - (2)第七天Blazor班级管理页面编写和接口对接
七天.NET 8操作SQLite入门到实战 - (2)第七天Blazor班级管理页面编写和接口对接
171 7
七天.NET 8操作SQLite入门到实战 - (3)第七天Blazor学生管理页面编写和接口对接
七天.NET 8操作SQLite入门到实战 - (3)第七天Blazor学生管理页面编写和接口对接
【sqlite的C语言访问接口】执行SQL语句的接口------sqlite3_exec回调函数的使用
【sqlite的C语言访问接口】执行SQL语句的接口------sqlite3_exec回调函数的使用
nacos 2.2.3版本 查看配置文件的历史版本的接口 是针对MySQL数据库的sql 改成postgresql后 sql语句报错 该怎么解决
在Nacos 2.2.3中切换到PostgreSQL后,执行配置文件历史版本分页查询出错,因`LIMIT 0, 10`语法不被PostgreSQL支持,需改为`LIMIT 10 OFFSET 0`。仅当存在历史版本时报错。解决方案是调整查询SQL以兼容PostgreSQL语法。
17. Python 数据库操作之MySQL和SQLite实例
17. Python 数据库操作之MySQL和SQLite实例
204 2
技术好文共享:(xxxx)十一:SQLite3的db数据库解密(三)数据库在线备份
技术好文共享:(xxxx)十一:SQLite3的db数据库解密(三)数据库在线备份
260 0
SQLite和MySQL指南
【5月更文挑战第18天】了解如何使用Python连接SQLite和MySQL数据库。首先,安装必要的库,如`sqlite3`(Python自带)和`mysql-connector-python`。接着,连接SQLite数据库,创建表、插入和查询数据。对于MySQL,同样建立连接,但需提供额外的连接信息。使用参数化查询防止SQL注入,并处理异常以增强程序稳定性。可选ORM框架如SQLAlchemy简化操作。考虑使用内存数据库、连接池、异步库(如`aiosqlite`)以优化性能。使用环境变量或配置文件安全管理连接信息,并实施安全性措施保护数据库。通过本文,提升Python数据库编程技能。
127 1
下一篇
开通oss服务