AI 助理
文档备案控制台
开发者社区 数据库 文章 正文

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

2015-04-14 1057
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL DuckDB 分析主实例，基础系列 4核8GB
RDS MySQL DuckDB 分析主实例，集群系列 4核8GB
RDS AI 助手，专业版
简介： 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

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

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

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

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

  49.     /***
  50.      * 销毁一个由create_connection()创建的DB连接
  51.      * @db_connection 需要销毁的DB连接
  52.      */
  53.     static void destroy_connection(DBConnection* db_connection);

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

  61. public:
  62.     virtual ~DBConnection() {}
  63.     
  64.     /***
  65.      * 设置需要连接的DB的IP和服务端口号
  66.      * 注意，只有在open()或reopen()之前调用才生效
  67.      */
  68.     virtual void set_host(const std::string& db_ip, uint16_t db_port) = 0;

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

  112.     /**
  113.      * 关闭一个DB连接
  114.      * 使用open()建立的连接，在使用完后，要使用close()关闭它
  115.      */
  116.     virtual void close() throw () = 0;

  118.     /***
  119.      * 重新建立DB连接
  120.      * reopen()会先调用close()关闭连接，然后才重新建立连接，
  121.      * 因此调用reopen()之前，可不调用close()，当然即使调用了close()也不会有问题
  122.      */
  123.     virtual void reopen() throw (CDBException) = 0;

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

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

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

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

  155.     /**
  156.      * 取得可读的字符串信息
  157.      */
  158.     virtual std::string str() throw () = 0;
  159. };

  161. SYS_NAMESPACE_END
  162. #endif // MOOON_SYS_SIMPLE_DB_H

文章标签：
云数据库 RDS MySQL 版
关系型数据库
数据库
MySQL
C++
SQL
数据安全/隐私保护
Oracle
PostgreSQL
存储
关键词：
云数据库 RDS MySQL 版接口
云数据库 RDS MySQL 版sqlite
mysql sqlite
sqlite接口
sqlite db
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL，然后进行数据表的CRUD操作。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
一见蓝天
目录
相关文章
蓝易云
|
9月前
|
开发框架 Java 关系型数据库
在Linux系统中安装JDK、Tomcat、MySQL以及部署J2EE后端接口
校验时，浏览器输入：http://[your_server_IP]:8080/myapp。如果你看到你的应用的欢迎页面，恭喜你，一切都已就绪。
蓝易云
620 17
蓝易云
|
9月前
|
Java 关系型数据库 MySQL
在Linux操作系统上设置JDK、Tomcat、MySQL以及J2EE后端接口的部署步骤
让我们总结一下，给你的Linux操作系统装备上最强的军队，需要先后装备好JDK的弓箭，布置好Tomcat的阵地，再把MySQL的物资原料准备好，最后部署好J2EE攻城车，那就准备好进军吧，你的Linux军团，无人可挡！
蓝易云
284 18
蓝易云
|
9月前
|
开发框架 关系型数据库 Java
Linux操作系统中JDK、Tomcat、MySQL的完整安装流程以及J2EE后端接口的部署
然后Tomcat会自动将其解压成一个名为ROOT的文件夹。重启Tomcat，让新“植物”适应新环境。访问http://localhost:8080/yourproject看到你的项目页面，说明“植物”种植成功。
蓝易云
294 10
追逐时光者
|
开发框架 .NET 中间件
七天.NET 8操作SQLite入门到实战 - （2）第七天Blazor班级管理页面编写和接口对接
七天.NET 8操作SQLite入门到实战 - （2）第七天Blazor班级管理页面编写和接口对接
追逐时光者
411 7
AIweker
|
关系型数据库 MySQL 数据库
Python处理数据库：MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库，包括安装必要的库、连接数据库、执行增删改查等基本操作，适合初学者快速上手。
AIweker
1252 15
快乐就是哈哈哈
|
SQL JavaScript 关系型数据库
node博客小项目：接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目：接口开发、连接mysql数据库
快乐就是哈哈哈
435 2
追逐时光者
|
开发框架 前端开发 .NET
七天.NET 8操作SQLite入门到实战 - （3）第七天Blazor学生管理页面编写和接口对接
七天.NET 8操作SQLite入门到实战 - （3）第七天Blazor学生管理页面编写和接口对接
追逐时光者
259 1
以山向海
|
关系型数据库 MySQL Java
关系型数据库mysql多种编程语言接口
【6月更文挑战第13天】
以山向海
423 2
邢仕冲的一亩三分地
|
SQL 数据库 C语言
【sqlite的C语言访问接口】执行SQL语句的接口------sqlite3_exec回调函数的使用
【sqlite的C语言访问接口】执行SQL语句的接口------sqlite3_exec回调函数的使用
邢仕冲的一亩三分地
572 1
游客ep32quzlpfvj4
|
SQL 关系型数据库 数据库
nacos 2.2.3版本 查看配置文件的历史版本的接口 是针对MySQL数据库的sql 改成postgresql后 sql语句报错 该怎么解决
在Nacos 2.2.3中切换到PostgreSQL后，执行配置文件历史版本分页查询出错，因`LIMIT 0, 10`语法不被PostgreSQL支持，需改为`LIMIT 10 OFFSET 0`。仅当存在历史版本时报错。解决方案是调整查询SQL以兼容PostgreSQL语法。
游客ep32quzlpfvj4
508 4

热门文章

最新文章

  • 1
    阿里云DTS踩坑经验分享系列｜如何使用DTS进行MySQL->ClickHouse同步
  • 2
    MySQL表连接（内连接、交叉连接、外连接、联合查询）
  • 3
    MySQL 小心使用 replace into
  • 4
    对比MySQL，一文看透HBase的能力及使用场景
  • 5
    MySQL慢查询优化
  • 6
    (六)MySQL索引原理篇：深入数据库底层揭开索引机制的神秘面纱！
  • 7
    寻找最大值：解析MySQL中的MAX()函数
  • 8
    linux下MySQL使用方法
  • 9
    Mysql(3)—数据库相关概念及工作原理
  • 10
    mysql+keepalived 双主热备高可用
  • 1
    什么情况，一夜之间冲上热搜，狂揽29.6k星，再见吧SQLite！这个嵌入式分析引擎实在太香了
    1066
  • 2
    在C++的QT框架中实现SQLite数据库的连接与操作
    672
  • 3
    【YashanDB知识库】启动yasom时报错：sqlite connection error
    131
  • 4
    【YashanDB知识库】启动yasom时报错：sqlite connection error
    189
  • 5
    一篇文章带你掌握SQLite3基本用法
    1801
  • 6
    Python处理数据库：MySQL与SQLite详解 | python小知识
    1252
  • 7
    SQLite 如何创建自增字段？
    446
  • 8
    go语言中SQLite3驱动安装
    515
  • 9
    SQLite中的B-Tree实现细节分析
    357
  • 10
    从零开始构建员工管理系统：Python与SQLite3的完美结合
    646

    • 相关课程

    更多
  • MySQL企业常见架构与调优经验分享
  • 阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
  • MySQL实战进阶
  • 阿里云数据库产品家族及特性
  • 数据库及SQL/MySQL基础
  • 云数据库MySQL快速入门

    • 相关电子书

    更多
  • PolarDB MySQL引擎重磅功能及产品能力盛大发布
  • 阿里云MySQL云数据库产品体系介绍
  • One Box： 解读事务与分析一体化数据库 HybridDB for MySQL

    • 推荐镜像

    更多
  • mysql
    • 下一篇
    ECS账号安全防护最佳实践