看过很多C或是C＋＋操作MySQL数据库的文章，大部分太吃力了，甚至有一部分根本没有很好的组织文字，初学者比较难以接受，即使是C++或是C高手也是比较难看懂。写这篇文章的目的不是别的，就一个，告诉您用MySQL的C API直接操作MySQL数据，并做了比较高效的封装，可以帮助开发人员大幅度提高采用MySQL的C API操作MySQL数据库的效率。
直接进入主题：
 
准备工作我就不介绍了，请参考上一篇博客：http://www.cnblogs.com/mlgjb/p/8798361.html
 
在工程建立添加以下两个文件：
第一个文件头文件：VspdCTOMySQL.h
  1. /****************************MYSQL IN C*******************************/
  2. /*************************2007 -03 -07 *******************************/
  3. /*************************李克喜**************************************/
  4.  
  5.  
  6. #include <stdio.h>
  7. #include <string>
  8. #include <afxsock.h>
  9. #include "mysql.h"
  10. using   namespace   std;
  11. class VspdCToMySQL 
  12. {
  13. public:
  14.       
  15.        //变量
  16.        MYSQL mysql;
  17.  
  18.        /*
  19.        构造函数和稀构函数
  20.        */
  21.        VspdCToMySQL();
  22.        ~VspdCToMySQL();
  23.  
  24.        /*
  25.        主要的功能：
  26.        初始化数据库
  27.        连接数据库
  28.        设置字符集
  29.  
  30.        入口参数：
  31.        host ：MYSQL服务器IP
  32.        port:数据库端口
  33.        Db：数据库名称
  34.        user：数据库用户
  35.        passwd：数据库用户的密码
  36.        charset：希望使用的字符集
  37.        Msg:返回的消息，包括错误消息
  38.  
  39.        出口参数：
  40.        int ：0表示成功；1表示失败
  41.        */
  42.        int ConnMySQL(char *host,char * port,char * Db,char * user,char* passwd,char * charset,char * Msg);
  43.  
  44.        /*
  45.        主要的功能：
  46.        查询数据
  47.  
  48.        入口参数：
  49.        SQL：查询的SQL语句
  50.        Cnum:查询的列数
  51.        Msg:返回的消息，包括错误消息
  52.  
  53.        出口参数：
  54.        string 准备放置返回的数据，多条记录则用0x06隔开,多个栏位用0x05隔开
  55.        如果 返回的长度＝ 0，责表示舞结果
  56.        */
  57.        string SelectData(char * SQL,int Cnum ,char * Msg);
  58.       
  59.        /*
  60.        主要功能：
  61.        插入数据
  62.       
  63.        入口参数
  64.        SQL：查询的SQL语句
  65.        Msg:返回的消息，包括错误消息
  66.  
  67.        出口参数：
  68.        int ：0表示成功；1表示失败
  69.        */
  70.        int InsertData(char * SQL,char * Msg);
  71.  
  72.        /*
  73.        主要功能：
  74.        修改数据
  75.       
  76.        入口参数
  77.        SQL：查询的SQL语句
  78.        Msg:返回的消息，包括错误消息
  79.  
  80.        出口参数：
  81.        int ：0表示成功；1表示失败
  82.        */
  83.        int UpdateData(char * SQL,char * Msg);
  84.  
  85.  
  86.        /*
  87.        主要功能：
  88.        删除数据
  89.       
  90.        入口参数
  91.        SQL：查询的SQL语句
  92.        Msg:返回的消息，包括错误消息
  93.  
  94.        出口参数：
  95.        int ：0表示成功；1表示失败
  96.        */
  97.        int DeleteData(char * SQL,char * Msg);
  98.       
  99.        /*
  100.        主要功能：
  101.        关闭数据库连接
  102.        */
  103.        void CloseMySQLConn();
  104.  
  105. };
  106.

 

 
 
第二个文件实现文件：VspdCTOMySQL.cpp
  1. /****************************MYSQL IN C*******************************/
  2. /*************************2007 -03 -07 *******************************/
  3. /*************************李克喜**************************************/
  4.  
  5. #include "stdafx.h"
  6. #include "VspdCTOMySQL.h"
  7.  
  8.  
  9. VspdCToMySQL::VspdCToMySQL()
  10. {
  11. }
  12.  
  13. VspdCToMySQL::~VspdCToMySQL()
  14. {
  15. }
  16.  
  17. //初始化数据
  18. int VspdCToMySQL::ConnMySQL(char *host,char * port ,char * Db,char * user,char* passwd,char * charset,char * Msg)
  19. {
  20.        if( mysql_init(&mysql) == NULL )
  21.        {
  22.               Msg = "inital mysql handle error";
  23.               return 1;
  24.        }    
  25.  
  26.        if (mysql_real_connect(&mysql,host,user,passwd,Db,0,NULL,0) == NULL)
  27.        {
  28.               Msg = "Failed to connect to database: Error";
  29.               return 1;
  30.        }    
  31.  
  32.        if(mysql_set_character_set(&mysql,"GBK") != 0)
  33.        {
  34.               Msg = "mysql_set_character_set Error";
  35.               return 1;
  36.        }
  37.        return 0;
  38. }
  39.  
  40. //查询数据
  41. string VspdCToMySQL::SelectData(char * SQL,int Cnum,char * Msg)
  42. {
  43.        MYSQL_ROW m_row;
  44.     MYSQL_RES *m_res;
  45.     char sql[2048];
  46.     sprintf(sql,SQL);
  47.        int rnum = 0;
  48.        char rg = 0x06;//行隔开
  49.        char cg = {0x05};//字段隔开
  50.  
  51.        if(mysql_query(&mysql,sql) != 0)
  52.        {
  53.               Msg = "select ps_info Error";
  54.               return "";
  55.        }
  56.        m_res = mysql_store_result(&mysql);
  57.  
  58.        if(m_res==NULL)
  59.        {
  60.               Msg = "select username Error";
  61.               return "";
  62.        }
  63.        string str("");
  64.        while(m_row = mysql_fetch_row(m_res))
  65.        {
  66.               for(int i = 0;i < Cnum;i++)
  67.               {
  68.                      str += m_row[i];
  69.                      str += rg;
  70.               }
  71.               str += rg;             
  72.               rnum++;
  73.        }
  74.  
  75.        mysql_free_result(m_res);
  76.  
  77.        return str;
  78. }

 

 
 
//插入数据
  1. int VspdCToMySQL::InsertData(char * SQL,char * Msg)
  2. {
  3.        char sql[2048];
  4.     sprintf(sql,SQL);
  5.        if(mysql_query(&mysql,sql) != 0)
  6.        {
  7.               Msg = "Insert Data Error";
  8.               return 1;
  9.        }
  10.        return 0;
  11. }

 

 
//更新数据
  1. int VspdCToMySQL::UpdateData(char * SQL,char * Msg)
  2. {
  3.        char sql[2048];
  4.     sprintf(sql,SQL);
  5.        if(mysql_query(&mysql,sql) != 0)
  6.        {
  7.               Msg = "Update Data Error";
  8.               return 1;
  9.        }
  10.        return 0;
  11. }
  12.

 

//删除数据
  1. int VspdCToMySQL::DeleteData(char * SQL,char * Msg)
  2. {
  3.        char sql[2048];
  4.     sprintf(sql,SQL);
  5.        if(mysql_query(&mysql,sql) != 0)
  6.        {
  7.               Msg = "Delete Data error";
  8.               return 1;
  9.        }
  10.        return 0;
  11. }
  12.

 

//关闭数据库连接
  1. void VspdCToMySQL::CloseMySQLConn()
  2. {
  3.        mysql_close(&mysql);
  4. }

 

 
 
在main函数，（如果是其他工程级不是main了，可能是一个按钮里面的代码块）添加      一些代码，添加之后如下：
  1. #include "stdafx.h"
  2. #include "VspdCTOMySQL.h"
  3.  
  4. int main(int argc, char* argv[])
  5. {
  6.     char* host="MYSQL服务器IP";
  7.     char* user="root";
  8.     char* port ="3306";
  9.     char* passwd="用户密码";
  10.     char* dbname="数据库名称"; 
  11.     char* charset = "GBK";//支持中文
  12.     char* Msg = "";//消息变量
  13.     //初始化
  14.     VspdCToMySQL * vspdctomysql = new VspdCToMySQL;
  15.     if(vspdctomysql->ConnMySQL(host,port,dbname,user,passwd,charset,Msg) == 0)
  16.            printf("连接成功/r/n");
  17.     else
  18.            printf(Msg);
  19.    
  20.     //查询
  21.     char * SQL = "SELECT ids,username,passwd,address FROM vcaccesstest";
  22.     string str = vspdctomysql->SelectData(SQL,4,Msg);
  23.     if( str.length() > 0 )
  24.     {
  25.            printf("查询成功/r/n");
  26.            printf(str.data());
  27.            printf("/r/n");
  28.     }
  29.     else
  30.     {
  31.            printf(Msg);
  32.     }
  33.     //插入
  34.     SQL = "insert into vcaccesstest(ids,username,passwd,address) values(4,\'我的\',\'123210\',\'测试地址\')";
  35.     if(vspdctomysql->InsertData(SQL,Msg) == 0)
  36.            printf("插入成功/r/n");
  37.     //更新
  38.     SQL = "update vcaccesstest set username = \'修改了\',passwd=\'2345\' where ids = 3 ";
  39.     if(vspdctomysql->UpdateData(SQL,Msg) == 0)
  40.            printf("更新成功/r/n");
  41.     //删除
  42.     SQL = "delete from vcaccesstest where ids = 3 ";
  43.     if(vspdctomysql->DeleteData(SQL,Msg) == 0)
  44.            printf("删除成功/r/n");
  45.  
  46.     vspdctomysql->CloseMySQLConn();
  47.  
  48.     return 0;
  49. }

 

 
数据库表确认表存在，（程序中的表和字段是我的数据库里面的内容，你要自己搞定你的SQL语句了，你可以看main函数里面的SQL变量的内容。
补充：
在上面的例子中sql语句是对常量进行操作的，比较简单，但是如果对变量进行操作就比较麻烦了。
基本思路为：1、将这些变量用字符串的形式连接起来，如果里面含有数值变量还要将先转换为字符串的形式。2、再考虑逗号与单引号的问题（在sql语句中，字符串需要用单引号括起来）。
在C语言中，将数字转换成字符串和连接字符串这两项功能都可以用sprintf（）函数实现。
 
编译，运行，一切ok。
总结，你要做的事情很少了，两个主要的文件写好了，你看例子调用即可，其他MySQL的库文件和附加文件别人也为您准备好了，移植到其他系统也是很简单的，比如移植到Linux和Unix下也是很简单的，VspdCTOMySQL.h和VspdCTOMySQL.cpp基本上是采用标准的C＋＋编写的，在别的系统可能需要做少量修改即可。

 

原文传送门：https://blog.csdn.net/jemlee2002/article/details/1523164

版权声明：本文为mlgjb原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/mlgjb/p/8810314.html