C&C++   发布时间:2022-04-03  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了Linux下实现C++操作Mysql数据库大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

想用C++写项目,数据库是必须的,所以这两天学了一下C++操作MysqL数据库方法。也没有什么教程,就是在网上搜的知识,下面汇总一下。

连接MysqL数据库有两种方法:第一种是使用ADO连接,不过这种只适合Windows平台;第二种是使用MysqL自己的C API函数连接数据库。我是在Linux平台下开发,所以就采用第二种方法,有很多Api函数,但是常用的就几个,我也是就用到其中的几个。

API函数

1.MysqL_real_connect()

连接一个MysqL服务器

MysqL *MysqL_real_connect (MysqL *MysqL,const char *host,const char *user,const char *passwd,const char *db,unsigned int port,const char *unix_socket,unsigned long client_flag)

如果连接成功,返回MysqL*连接句柄。如果连接失败,返回NULL。对于成功的连接,返回值与第1个参数的值相同

2.MysqL_query()

执行指定”以NULL终结的字符串”的SQL查询

返回一个结果表,假定查询成功,可以调用 MysqL_num_rows() 来查看对应于 SELECT 语句返回了多少行,或者调用 MysqL_affected_rows() 来查看对应于 deletE,INSERT,replaCE 或 updatE 语句影响到了多少行。

3.MysqL_store_result()

MysqL_RES *MysqL_store_result(MysqL *MysqL)

检索完整的结果集至客户端。客户端处理结果集最常用的方式是通过调用MysqL_store_result(),一次性地检索整个结果集。该函数能从服务器获得查询返回的所有行,并将它们保存在客户端。对于成功检索了数据的每个查询SELECT、SHOW、DESCRIBE、EXPLAIN、checK TABLE等),必须调用MysqL_store_result()或MysqL_use_result() 。对于其他查询,不需要调用MysqL_store_result()或MysqL_use_result(),但是如果在任何情况下均调用MysqL_store_result(),它也不会导致任何伤害或性能降低。

4.MysqL_num_rows()

返回结果集中的行数。

5.MysqL_num_fields()

返回结果集中的字段数,如果失败,则返回 false。

6.MysqL_fetch_field()

MysqL_FIELD* MysqL_fetch_field(MysqL_RES *result);
获取一个表字段的类型,结束返回NULL。

7.MysqL_fetch_row()

MysqL_ROW MysqL_fetch_row(MysqL_RES *result);
从结果集中获取下一行,成功返回一个数组,值大于0。

8.MysqL_fetch_field_direct()

MysqL_FIELD* MysqL_fetch_field_direct(MysqL_RES *result,int i);
给定字段编号,返回表字段的类型,结束返回NULL。

简单的学生信息管理代码

光看也记不住啊,就用这些函数写了一个学生信息管理界面,唉,去年这时候C语言课程设计,当时还不知道用数据库,全用文件写的,知道晚了很后悔啊。。。。下面是代码

 /*************************************************************************
   > File Name: student.cpp
   > Author: Tanswer_ 
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 16时50分34秒
 ************************************************************************/
          
 #include <iostream>
 #include <String> 
 #include <stack> 
 #include <algorithm>
 #include <sstream>
 #include <MysqL/MysqL.h>
 #include <unistd.h>
          
 using namespace std;
          
          
 MysqL MysqL;   
 MysqL_ROW row;  
 MysqL_FIELD* field = NULL;       
 MysqL_RES* result;                                                  
          
 String IntToStr(int num)
 {         
   Stringstream ss;
   ss.clear();
   ss << num;
   return ss.str();
 }
                                                            
 void Add()
 {
   String fname,fsex,ftel,faddr;
   int fage;
   char choice; 
   do
   {
   ┊  cout << "请依次输入以下信息:" << endl;
   ┊  cout << "\nName: ";cin >> fname;
   ┊  cout << "\nSex: ";cin >> fsex;
   ┊  cout << "\nAge: "; cin >> fage;
   ┊  cout << "\nTel: "; cin >> ftel;
   ┊  cout << "\nAddr: "; cin >> faddr;
 
   ┊  String sql = "INSERT INTO Infor (name,sex,tel,addr,agE) values('"+fname+"','"+fsex+"','"+ftel+"','"+faddr+"',"+IntToStr(fagE)+");";
   ┊  //String sql = "INSERT INTO Infor (name,age,addr) values('小红','女',18,'13333333333','陕西省西安市雁塔区');";

   ┊  MysqL_query(&MysqL,sql.c_str());
   ┊  ┊               
   ┊  cout << "是否继续添加(y/n)?: ";
   ┊  cin >> choice;                                                
   }while(choice == 'y');       
                    
 }                   
                    
 void SELEct()             
 {                   
   int id;              
   cout << "请输入要查询学生的学号: ";
   cin >> id;             
                    
   String sql = "SELECT * FROM Infor WHERE id = "+IntToStr(id)+";";
   MysqL_query(&MysqL,sql.c_str());
            
   result = MysqL_store_result(&MysqL);
   if(result == NULL)
   ┊  cout << "fail\n";
            
   for(int i=0; i<MysqL_num_fields(result); i++)
   {         
   ┊  field = MysqL_fetch_field_direct(result,i);
   ┊  cout << field->name << "\t\t";
   }                
   cout << endl;          
                   
   row = MysqL_fetch_row(result);  
   while(row != NULL)        
   {                
   ┊  for(int i=0; i<MysqL_num_fields(result); i++)
   ┊  {              
   ┊  ┊  cout << row[i] << "\t\t";                                         
   ┊  }              
   ┊  cout << endl;        
   ┊  row = MysqL_fetch_row(result);
   }                
 }                  
                   
                   
 void update()            
 {                  
   int id;             
   char choice;           
   String newaddr;         
   ┊  cout << "请输入要修改同学的学号: ";
   ┊  cin >> id;          
   ┊  cout << endl << "请输入修改后的地址: ";
   ┊  cin >> newaddr;
   ┊  String sql = "updatE Infor SET addr = '"+newaddr+"'WHERE id= "+IntToStr(id)+"; ";
   ┊  MysqL_query(&MysqL,sql.c_str());                                       
   ┊     
 }       
        
        
 int main()  
 {       
   char choice[5];
        
   MysqL_init(&MysqL);
   /*连接数据库*/
   if(!MysqL_real_connect(&MysqL,"localhost","root","dxm242012","student",NULL,0))
   {     
   ┊  cout << "connect fial\n";
   ┊  return -1;
   }     
        
   while(atoi(choicE) != 'q')
   {     
   ┊  sleep(4);
   ┊  system("clear");
   ┊  cout << "1.添加学生信息" << endl;
   ┊  cout << "2.查询学生信息" << endl;
   ┊  cout << "3.修改学生信息" << endl;
                                                            
   ┊  cin >> choice;
   
   ┊  cout << choice << endl;
   ┊  switch(atoi(choicE))
   ┊  {  
   ┊  ┊  case 1:
   ┊  ┊  ┊  Add();
   ┊  ┊  ┊  break;
   ┊  ┊  case 2:
   ┊  ┊  ┊  SELEct();
   ┊  ┊  ┊  break;
   ┊  ┊  case 3:
   ┊  ┊  ┊  update();
   ┊  ┊  ┊  break;
   ┊  ┊  default:
   ┊  ┊  ┊  break;
   ┊  }  
   }
 
   MysqL_close(&MysqL);
   return 0;
 }

C++封装MyDB类

后来又把这些函数简单的封装了一下,方便以后直接用。

 /*************************************************************************
   > File Name: myDB.h
   > Author: Tanswer_
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 22时26分22秒
 ************************************************************************/
  
 #ifndef _MYDB_H
 #define _MYDB_H
  
 #include <String>
 #include <iostream>
 #include <MysqL/MysqL.h>
 using namespace std;
  
 class MyDB
 { 
  
 public:
   mydb();
   ~mydb();
   bool InitDB(String host,String user,String pwd,String db@R_197_8313@;                          
   bool Exesql(String sql);
 private:
   MysqL* MysqL;
   MysqL* MysqL;
   MysqL_ROW row;
   MysqL_RES* result;
   MysqL_FIELD* field;                                                
 };
  
  
 #endif                                                           

 /*************************************************************************                      
   > File Name: myDB.cpp
   > Author: Tanswer_
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 22时27分18秒
 ************************************************************************/
 
 #include <iostream>
 #include <String>
 #include <stack>
 #include <algorithm>   
 #include <MysqL/MysqL.h> 
 #include "myDB.h"
 
 using namespace std;
 
 MyDB::mydb()   
 {
   MysqL = MysqL_init(null);
   if(MysqL == NULL)
   {
   ┊  cout << "Error: " << MysqL_error(MysqL);
   ┊  exit(-1);
   }      
 }
 
 MyDB::~mydb()
 {                                                           
   if(!MysqL)
   {MysqL_close(MysqL);
   }
 }
 
 bool MyDB::InitDB(String host,String db@R_197_8313@
 {
   /*连接数据库*/
   if(!MysqL_real_connect(MysqL,host.c_str(),user.c_str(),pwd.c_str(),dbname.c_str(),0))
   {
   ┊  cout << "connect fial: " << MysqL_error(MysqL);
   ┊  exit(-1);
   }
   return true;
 }
 
 bool MyDB::Exesql(String sql)
 {
   /*执行失败*/
   if(MysqL_query(MysqL,sql.c_str()))
   {
   ┊  cout << "query fail: " << MysqL_error(MysqL);
   ┊  exit(1);                                                   
   }
 
   else
   {
   ┊  /*获取结果集*/
   ┊  result = MysqL_store_result(MysqL);
 
   ┊  int fieldnum = MysqL_num_fields(result);
   ┊  for(int i=0; i<fieldnum; i++)
   ┊  {
   ┊  ┊  row = MysqL_fetch_row(result);
   ┊  ┊  if(row <= 0)
   ┊  ┊  ┊  break;
   ┊  ┊  for(int j=0; j<fieldnum; j++)
   ┊  ┊  {
   ┊  ┊  ┊  cout << row[j] << "\t\t";
   ┊  ┊  }
   ┊  ┊  cout << endl;
   ┊  }
   ┊  MysqL_free_result(result);
   }
   return true;
 }

 /*************************************************************************                      
   > File Name: main.cpp
   > Author: Tanswer_
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 22时53分43秒
 ************************************************************************/
    
 #include <iostream>
 #include <String>
 #include <stack>
 #include <algorithm>
 #include <MysqL/MysqL.h>
 #include "myDB.h"
    
 using namespace std;
    
    
 int main()
 {   
   MyDB db;
   db.InitDB("localhost","xxxxxx","student");
   db.Exesql("SELECT * FROM Infor;");
   return 0;
 }   

以下是运行结果:

Linux下实现C++操作Mysql数据库

下面是遇到的问题:
1. 编译时出错
没有那个文件或目录

#include<MysqL/MysqL.h> 
^ 

编译中断。
解决:除了MysqL-client和MysqL-server,又安装了MysqL-devel,然后就解决了。

2. 自定义的变量传入sql语句时,出现问题

在网上查找到这样一种格式,
String sql = "INSERT INTO Infor (name,"+IntToStr(fagE)+");";
然后String类型的可以成功,整型的变量还是不行,我又写了个函数把int转为String。

 String IntToStr(int num)
 {         
   Stringstream ss;
   ss.clear();
   ss << num;
   return ss.str();
 }

大概就是这样,门卫大叔很凶,我也很绝望,就写到这吧,有问题再补充。

大佬总结

以上是大佬教程为你收集整理的Linux下实现C++操作Mysql数据库全部内容,希望文章能够帮你解决Linux下实现C++操作Mysql数据库所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签:操作Mysql