Chinaunix首页 | 论坛 | 博客

尔广强的博客

首页　| 　博文目录　| 　关于我

xuzhuzi2008

  • 博客访问： 46654
  • 博文数量： 5
  • 博客积分： 35
  • 博客等级： 民兵
  • 技术积分： 105
  • 用 户 组： 普通用户
  • 注册时间： 2010-11-16 17:40
文章分类

全部博文（5）

文章存档

2017年（1）

2016年（1）

2015年（2）

2013年（1）

我的朋友
最近访客
推荐博文
相关博文
Mysql操作类，自制，已测试成功

分类： C/C++

2013-03-13 09:02:50

    准备要自己做点小项目了，一直没有用过关系型数据库，这次选用的是Mysql，大致看了一下甲骨文提供的API，能够领会其中的意思，但是感觉总是写API过于繁琐，因此写个类吧，这样能好一点。以下贴出代码是我写的关于mysql操作的类，不足之处，请指正，谢谢哈。

一、mysqlapi.h主要定义了错误代码

点击(此处)折叠或打开

  1. /*
  2.  * mysqlapi.h
  3.  *
  4.  * Created on: 2013-3-11
  5.  * Author: er_guangqiang
  6.  */

  8. #ifndef MYSQLAPI_H_
  9. #define MYSQLAPI_H_
  10. //Errno number
  11. #define MO_OK    0x00000000    //操作成功
  12. #define HOST_TOO_LONG    0xFFFF0001 //主机名过长
  13. #define USERNAME_TOO_LONG    0xFFFF0002 //数据库用户名过长
  14. #define PASSWD_TOO_LONG    0xFFFF0003    //数据库密码过长
  15. #define DATABASENAME_TOO_LONG    0xFFFF0004 //数据库名字过长
  16. #define PORT_SET_ERR    0xFFFF0005    //端口设置错误
  17. #define MYSQL_INIT_ERR    0xFFFF0007    //Mysql初始化失败
  18. #define MYSQL_CONNECT_ERR    0xFFFF0008    //数据库连接失败
  19. #define MYSQL_STOR_RESULTS_ERR    0xFFFF0009    //储存数据库结果失败
  20. #define MYSQL_FIELDS_ZERO    0xFFFF000a    //获取的字段列为0
  21. #define MYSQ_FETCH_FIELDS_ERR    0xFFFF000b    //获取字段失败
  22. #define HOST_NULL 0xFFFF000c    //主机名为空
  23. #define USERNAME_NULL    0xFFFF000d    //用户名为空
  24. #define PASSWD_NULL    0xFFFF000e    //数据库密码为空
  25. #define MYSQL_SWAP_OUT    0xFFFF000f    //mysql_fetch_row结果集已取空
  26. #define RESULT_NULL    0xFFFF0010    //结果指针为空，请确认是否执行了获取结果集方法
  27. #endif /* MYSQLAPI_H_ */
二、MysqlOperate.h定义了MysqlOperate类的成员变量和成员函数

点击(此处)折叠或打开

  1. /*
  2.  * MysqlOperate.h
  3.  *
  4.  * Created on: 2013-3-9
  5.  * Author: er_guangqiang
  6.  */

  8. #ifndef MYSQLOPERATE_H_
  9. #define MYSQLOPERATE_H_

  11. #include <string.h>
  12. #include <iostream>
  13. #include <mysql.h>
  14. #include "mysqlapi.h"


  17. class MysqlOperate {
  18. public:
  19.     MysqlOperate();
  20.     MysqlOperate(const char *host, const char *user, const char *passwd, const char *db, \
  21.             unsigned int port, unsigned long clientflag);
  22.     int InitMysql(const char *host, const char *user, const char *passwd, const char *db, \
  23.             unsigned int port, unsigned long clientflag);
  24.     int ConnectMysql();
  25.     int ExcuteQuery(const char *sqlquery);
  26.     int FetchResult();
  27.     unsigned int FetchRowtoBuffer(char **buffer);
  28.     unsigned long GetRowsCount();
  29.     unsigned int GetFieldsCount();
  30.     int FetchColumnName(char **column);
  31.     void ReleaseConnMysql();
  32.     virtual ~MysqlOperate();
  33. private:
  34.     MYSQL *m_mysql;
  35.     MYSQL_RES * m_results;
  36.     MYSQL_ROW m_record;
  37.     MYSQL_FIELD *m_fields;
  38.     char m_host[16];
  39.     char m_user[16];
  40.     char m_passwd[32];
  41.     char m_db[16];
  42.     int m_port;
  43.     long m_clientflag;
  44. };

  46. #endif /* MYSQLOPERATE_H_ */
三、MysqlOperate.cpp主要实现头文件中定义的成员函数


点击(此处)折叠或打开

  1. /*
  2.  * MysqlOperate.cpp
  3.  *
  4.  * Created on: 2013-3-9
  5.  * Author: er_guangqiang
  6.  */

  8. #include "MysqlOperate.h"

  10. //构造函数，主要任务复位成员变量
  11. MysqlOperate::MysqlOperate() {
  12.     // TODO Auto-generated constructor stub
  13.     memset(m_host, 0x00, 16);
  14.     memset(m_user, 0x00, 16);
  15.     memset(m_passwd, 0x00, 32);
  16.     memset(m_db, 0x00, 16);
  17.     m_port = 3306;
  18.     m_clientflag = 0;
  19.     m_mysql = NULL;
  20.     m_results = NULL;
  21. }

  23. /*重载构造函数
  24.  *输入： host：主机ip
  25.  *        user：mysql用户名
  26.  *        passwd：mysql密码
  27.  *        db：选择mysql中的数据库
  28.  *        port：设置mysql端口
  29.  *        clientflag：mysql客户端参数
  30.  *输出：
  31.  *        无
  32.  *    次函数主要负责初始化Mysql的信息
  33. */
  34. MysqlOperate::MysqlOperate(const char *host, const char *user, const char *passwd, const char *db, \
  35.             unsigned int port, unsigned long clientflag)
  36. {
  37.     int r = 0;
  38.     memset(m_host, 0x00, 16);
  39.     memset(m_user, 0x00, 16);
  40.     memset(m_passwd, 0x00, 32);
  41.     memset(m_db, 0x00, 16);
  42.     m_port = 3306;
  43.     m_clientflag = 0;
  44.     r = InitMysql(host,user,passwd,db,port,clientflag);
  45.     if(0 == r)
  46.         std::cout<< "InitMysql Success!!!"<<std::endl;
  47.     else
  48.         std::cout << "Errno = " << r << std::endl;

  50.     m_mysql = NULL;
  51.     m_results = NULL;
  52. }
  53. //初始化mysql信息
  54. /*
  55.  * 输入：与MysqlOperate（）构造函数相同
  56.  */
  57. int MysqlOperate::InitMysql(const char *host, const char *user, const char *passwd, const char *db, \
  58.             unsigned int port, unsigned long clientflag)
  59. {
  60.     if(NULL == host)
  61.         return HOST_NULL;
  62.     else if(strlen(host) > 16)
  63.         return HOST_TOO_LONG;
  64.     else if (strlen(host) >= 0 && strlen(host) <= 16)
  65.         strncpy(m_host, host, strlen(host));

  67.     if(NULL == user)
  68.         return USERNAME_NULL;
  69.     else if(strlen(user) > 16)
  70.         return     USERNAME_TOO_LONG;
  71.     else if(strlen(user) >= 0 && strlen(user) <= 16)
  72.         strncpy(m_user, user, strlen(user));

  74.     if(NULL == passwd)
  75.         return PASSWD_NULL;
  76.     else if(strlen(passwd) > 32)
  77.         return PASSWD_TOO_LONG;
  78.     else if(strlen(passwd) >= 0 && strlen(passwd) <= 32)
  79.         strncpy(m_passwd, passwd, strlen(passwd));

  81.     if(NULL == db)
  82.     {
  83.         std::cout << "Warning!!!---database set null---! Will you create database??"<< std::endl;
  84.         return MO_OK;
  85.     }
  86.     else if(strlen(db) > 16)
  87.         return DATABASENAME_TOO_LONG;
  88.     else
  89.         strncpy(m_db, db, strlen(db));
  90.     if(port <= 0)
  91.         return PORT_SET_ERR;
  92.     else
  93.         m_port = port;
  94.     m_clientflag = clientflag;
  95.     return MO_OK;
  96. }

  98. //连接Mysql数据库
  99. /*
  100.  * 输入：
  101.  *         无
  102.  * 输出：
  103.  *         无
  104.  * 此函数旨在连接Mysql数据库
  105.  */
  106. int MysqlOperate::ConnectMysql()
  107. {
  108.     m_mysql = mysql_init(NULL);
  109.     if(NULL == m_mysql)
  110.     {
  111.         std::cout << "mysql_init failed" << std::endl;
  112.         return MYSQL_INIT_ERR;
  113.     }
  114.     else
  115.         std::cout << "mysql_init success" << std::endl;
  116.     mysql_real_connect(m_mysql, m_host, m_user, m_passwd, m_db, m_port, NULL, m_clientflag);
  117.     if(NULL == m_mysql)
  118.     {
  119.         std::cout << "mysql_real_connect failed" << std::endl;
  120.         return MYSQL_CONNECT_ERR;
  121.     }
  122.     else
  123.         std::cout << "mysql_real_connect success" << std::endl;
  124.     return MO_OK;
  125. }

  127. //执行sql语句
  128. /*
  129.  * 输入：
  130.  *        sqlquery：sql语句字符串
  131.  * 输出：
  132.  *         无
  133.  * 此函数为执行定义的sql语句
  134.  */
  135. int MysqlOperate::ExcuteQuery(const char *sqlquery)
  136. {
  137.     return mysql_query(m_mysql, sqlquery);
  138. }

  140. int MysqlOperate::FetchResult()
  141. {
  142.     m_results = mysql_store_result(m_mysql);
  143.     if(NULL == m_results)
  144.     {
  145.         std::cout << "mysql_store_result failed" << std::endl;
  146.         return MYSQL_STOR_RESULTS_ERR;
  147.     }
  148.     else
  149.         std::cout << "mysql_store_result success" << std::endl;
  150.     return MO_OK;
  151. }

  153. //获取行内容（一行）
  154. /*
  155.  * 输入/输出：
  156.  *         buffer：行内容存储容器
  157.  * 此函数为获取结果集的一行内容（在此之前一定要先执行sql语句，保证m_results不为空）
  158.  */
  159. unsigned int MysqlOperate::FetchRowtoBuffer(char **buffer)
  160. {
  161.     if(NULL == m_results)
  162.         return RESULT_NULL;
  163.     if((m_record = mysql_fetch_row(m_results)))
  164.     {
  165.         int c = GetFieldsCount();
  166.         int i = 0;
  167.         while(i < c)
  168.         {
  169.             strncpy(*(buffer + i), m_record[i], strlen(m_record[i]));
  170.             i++;
  171.         }
  172.         return MO_OK;
  173.     }
  174.     return MYSQL_SWAP_OUT;

  176. }

  178. //获取字段个数
  179. /*
  180.  * 输入/输出：
  181.  *         无
  182.  * 此函数为获取结果集的字段个数
  183.  */
  184. unsigned int MysqlOperate::GetFieldsCount()
  185. {
  186.     if(NULL == m_results)
  187.     {
  188.         std::cout << "m_results is NULL, please confirm mysql_store_result success" << std::endl;
  189.         return MO_OK;
  190.     }
  191.     return mysql_num_fields(m_results);
  192. }

  194. //获取行数
  195. /*
  196.  * 输入/输出：
  197.  *         无
  198.  * 此函数为获取结果集的行数
  199.  */
  200. unsigned long MysqlOperate::GetRowsCount()
  201. {
  202.     if(NULL == m_results)
  203.     {
  204.         std::cout << "m_results is NULL, please confirm mysql_store_result success" << std::endl;
  205.         return MO_OK;
  206.     }
  207.     return (unsigned long)mysql_num_rows(m_results);
  208. }

  210. //获取字段内容
  211. /*
  212.  * 输入/输出：
  213.  *         column：字段内容容器
  214.  * 此函数为获取结果集的字段内容
  215.  */
  216. int MysqlOperate::FetchColumnName(char **column)
  217. {
  218.     unsigned int c = GetFieldsCount();
  219.     if(0 == c)
  220.     {
  221.         std::cout << "GetFieldsCount is zero." << std::endl;
  222.         return MYSQL_FIELDS_ZERO;
  223.     }
  224.     m_fields = mysql_fetch_field(m_results);
  225.     if(NULL == m_fields)
  226.     {
  227.         std::cout << "mysql_fetch_field is failed" << std::endl;
  228.         return MYSQ_FETCH_FIELDS_ERR;
  229.     }
  230.     else
  231.         std::cout << "mysql_fetch_field is success" <<std::endl;
  232.     unsigned int i = 0;
  233.     for(; i < c; i++)
  234.         strncpy(column[i], m_fields[i].name, m_fields[i].name_length);
  235.     return MO_OK;
  236. }

  238. //释放连接
  239. /*
  240.  * 输入/输出：
  241.  *         无
  242.  * 此函数为释放Mysql连接
  243. */
  244. void MysqlOperate::ReleaseConnMysql()
  245. {
  246.     if(NULL != m_results)
  247.         mysql_free_result(m_results);
  248.     if(NULL != m_mysql)
  249.         mysql_close(m_mysql);
  250. }

  252. MysqlOperate::~MysqlOperate() {
  253.     // TODO Auto-generated destructor stub
  254. }

以上就是我的代码，里面有函数的输入输出了功能简介，再次不赘述，我是新人，指教哈


阅读(2386) | 评论(0) | 转发(1) |
0

上一篇：没有了

下一篇：深入浅出《Unix环境高级编程》：Unix基础知识（一）

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6