备案控制台
探索云世界
开发者社区 数据库 文章 正文

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

2015-04-14 921
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL Serverless，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
简介： 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 版db
云数据库 RDS MySQL 版接口
云数据库 RDS MySQL 版sqlite3
云数据库 RDS MySQL 版支持
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境，其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
一见蓝天
目录
相关文章
Love-Java.
|
5月前
|
关系型数据库 MySQL Linux
【Linux】jdk & Tomcat & MySql的安装及Linux后端接口部署
【Linux】jdk & Tomcat & MySql的安装及Linux后端接口部署
Love-Java.
107 0
穆雄雄.
|
24天前
Mybatis+mysql动态分页查询数据案例——房屋信息的接口(IHouseDao)
Mybatis+mysql动态分页查询数据案例——房屋信息的接口(IHouseDao)
穆雄雄.
12 1
红目香薰
|
2月前
|
SQL 关系型数据库 MySQL
MySQL技能完整学习列表14、应用开发和接口
MySQL技能完整学习列表14、应用开发和接口
红目香薰
48 0
q7s2kces74wvy
|
7月前
|
存储 关系型数据库 分布式数据库
云原生关系型数据库Polar DB MySQL版（二）
云原生关系型数据库Polar DB MySQL版（二）
q7s2kces74wvy
169 0
q7s2kces74wvy
|
7月前
|
存储 关系型数据库 MySQL
云原生关系型数据库Polar DB MySQL版（一）
云原生关系型数据库Polar DB MySQL版（一）
q7s2kces74wvy
227 0
蓝易云
|
3月前
|
JavaScript 关系型数据库 MySQL
百度搜索：蓝易云【Node.js写接口连接MySQL数据库教程】
现在，你的Node.js应用已经启动，可以通过访问 `http://localhost:3000/users`来获取所有用户的信息。注意替换上述代码中的数据库连接信息为你自己的实际数据。
蓝易云
47 0
怒放de生命
|
4月前
|
SQL 关系型数据库 MySQL
mysql转sqlite3实战+部署sqlite3应用
mysql转sqlite3实战+部署sqlite3应用
怒放de生命
105 0
kgduu
|
8月前
|
关系型数据库 MySQL
mysql转sqlite3
mysql转sqlite3
kgduu
84 0
東方幻想鄉
|
4月前
|
前端开发 JavaScript 关系型数据库
【前端必备】使用NodeJs写接口(本地连接MySQL + 连接到云服务MySQL)
【前端必备】使用NodeJs写接口(本地连接MySQL + 连接到云服务MySQL)
東方幻想鄉
86 0
.29.
|
4月前
|
存储 SQL 关系型数据库
⑩⑤【DB】详解MySQL存储过程：变量、游标、存储函数、循环，判断语句、参数传递..
⑩⑤【DB】详解MySQL存储过程：变量、游标、存储函数、循环，判断语句、参数传递..
.29.
43 0

热门文章

最新文章

  • 1
    超1/3中国500强企业都在用的「汇联易」，为什么选用阿里云RDS？
  • 2
    详解MySQL字符集和Collation
  • 3
    RDS MySQL 数据库运维简述
  • 4
    阿里云mysql数据库价格购买和使用教程
  • 5
    阿里云MySQL云数据库优惠价格、购买和使用教程分享！
  • 6
    阿里云MySQL数据库价格、购买、创建账号密码和连接数据库教程
  • 7
    使用阿里云的数据传输服务DTS（Data Transmission Service）进行MySQL 5.6到MySQL 8.0的迁移
  • 8
    Docker安装详细步骤及相关环境安装配置（mysql、jdk、redis、自己的私有仓库Gitlab 、C和C++环境以及Nginx服务代理）
  • 9
    购买阿里云RDS实例
  • 10
    MySQL学习（三）
  • 1
    Linux联网安装MySQL Server
    10
  • 2
    用MySQL创建公司资料库表格
    8
  • 3
    一文带你拿下MySQL之增删查改(基础)（下）
    19
  • 4
    centos7安装mysql-带网盘安装包
    29
  • 5
    web简易开发——通过php与HTML+css+mysql实现用户的登录，注册
    14
  • 6
    数据库基础（mysql）
    8
  • 7
    DQL语言之基础查询（mysql）
    7
  • 8
    DQL语言之常见函数（mysql）
    7
  • 9
    DQL语言之连接查询（mysql）
    8
  • 10
    MySQL全局库表查询准确定位字段
    18

    • 相关课程

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

    • 相关电子书

    更多
  • 搭建电商项目架构连接MySQL
  • 搭建4层电商项目架构，实战连接MySQL
  • PolarDB MySQL引擎重磅功能及产品能力盛大发布

    • 相关实验场景

    更多
  • 测试场景（RDS无优惠）
  • MySQL引擎及架构优化
  • 基于EBS部署高性能的MySQL服务
  • 使用Python完成RDS数据开发及分析
  • Excel文件转存到RDS数据库
  • 使用CloudLens采集RDS日志并进行审计分析

    • 推荐镜像

    更多
  • mysql
  • postgresql
  • mariadb
    • 下一篇
    阿里云oss简介和使用流程
    为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
    产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
    解决方案技术解决方案
    文档与社区文档开发者社区天池大赛培训与认证
    权益中心免费试用高校计划企业扶持计划推荐返现计划
    支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
    关注阿里云
    关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
    阿里云APP阿里云微信
    联系我们：4008013260
    法律声明Cookies政策廉正举报安全举报联系我们加入我们
    阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
    © 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
    浙公网安备 33010602009975号浙B2-20080101-4