Chinaunix首页 | 论坛 | 博客
  • 博客访问: 7812132
  • 博文数量: 593
  • 博客积分: 13065
  • 博客等级: 上将
  • 技术积分: 10313
  • 用 户 组: 普通用户
  • 注册时间: 2008-03-26 16:44
个人简介

推荐: blog.csdn.net/aquester https://github.com/eyjian https://www.cnblogs.com/aquester http://blog.chinaunix.net/uid/20682147.html

文章分类

全部博文(593)

分类: LINUX

2015-04-14 21:18:03

C++源代码:simple_db.zip
相关联代码:

  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::vector<std::string> DBRow; // 用来存储一行所有字段的值
  8. typedef std::vector<DBRow> 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

阅读(2380) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~