在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 intport,

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。

 

簡單的學生信息管理代碼

光看也記不住啊，就用這些函數寫了一個學生信息管理界面，下面是代碼：

#include <iostream>

#include <string>

#include <stack>

#include <algorithm>

#include <sstream>

#include <mysql/mysql.h>

#include <unistd.h>

 

usingnamespacestd;

 

 

MYSQL mysql;  

MYSQL_ROW row; 

MYSQL_FIELD* field = NULL;      

MYSQL_RES* result;                                                 

 

string IntToStr(intnum)

{        

  stringstream ss;

  ss.clear();

  ss << num;

  returnss.str();

}

 

voidAdd()

{

  string fname,fsex,ftel,faddr;

  intfage;

  charchoice;

  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,sex,age,tel,addr) values('小紅','女',18,'13333333333',          '陝西省西安市雁塔區');";

 

  ┊  mysql_query(&mysql,sql.c_str());

  ┊  ┊              

  ┊  cout << "是否繼續添加(y/n)？： ";

  ┊  cin >> choice;                                               

  }while(choice == 'y');      

 

}                  

 

voidSelect()            

{                  

  intid;             

  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(inti=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(inti=0; i<mysql_num_fields(result); i++)

  ┊  {             

  ┊  ┊  cout << row[i] << "\t\t";                                        

  ┊  }             

  ┊  cout << endl;       

  ┊  row = mysql_fetch_row(result);

  }               

}                 

 

 

voidUpdate()           

{                 

  intid;            

  charchoice;          

  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());                                      

  ┊    

}      

 

intmain() 

{      

  charchoice[5];

  mysql_init(&mysql);

  /*鏈接數據庫*/

  if(!mysql_real_connect(&mysql,"localhost","root","dxm242012","Student",0,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))

  ┊  { 

  ┊  ┊  case1:

  ┊  ┊  ┊  Add();

  ┊  ┊  ┊  break;

  ┊  ┊  case2:

  ┊  ┊  ┊  Select();

  ┊  ┊  ┊  break;

  ┊  ┊  case3:

  ┊  ┊  ┊  Update();

  ┊  ┊  ┊  break;

  ┊  ┊  default:

  ┊  ┊  ┊  break;

  ┊  } 

  }

 

  mysql_close(&mysql);

  return0;

}

 

 

C++封裝MyDB類

後來又把這些函數簡單的封裝了一下，方便之後直接用。

#ifndef _MYDB_H

#define _MYDB_H

 

#include <string>

#include <iostream>

#include <mysql/mysql.h>

usingnamespacestd;

 

classMyDB

{

 

public:

  MyDB();

  ~MyDB();

  boolInitDB(string host,string user,string pwd,string dbname);                         

  boolExeSQL(string sql);

private:

  MYSQL* mysql;

  MYSQL* mysql;

  MYSQL_ROW row;

  MYSQL_RES* result;

  MYSQL_FIELD* field;                                               

};

#endif     

 

#include <iostream>

#include <string>

#include <stack>

#include <algorithm>  

#include <mysql/mysql.h>

#include "myDB.h"

 

usingnamespacestd;

 

MyDB::MyDB()  

{

  mysql = mysql_init(NULL);

  if(mysql == NULL)

  {

  ┊  cout << "Error: "<< mysql_error(mysql);

  ┊  exit(-1);

  }     

}

 

MyDB::~MyDB()

{                                                          

  if(!mysql)

  {

  ┊  mysql_close(mysql);

  }

}

 

boolMyDB::InitDB(string host,string user,string pwd,string dbname)

{

  /*鏈接數據庫*/

  if(!mysql_real_connect(mysql,host.c_str(),user.c_str(),pwd.c_str(),dbname.c_str(),0,NULL,0))

  {

  ┊  cout << "connect fial: "<< mysql_error(mysql);

  ┊  exit(-1);

  }

  returntrue;

}

 

boolMyDB::ExeSQL(string sql)

{

  /*執行失敗*/

  if(mysql_query(mysql,sql.c_str()))

  {

  ┊  cout << "query fail: "<< mysql_error(mysql);

  ┊  exit(1);                                                  

  }

 

  else

  {

  ┊  /*獲取結果集*/

  ┊  result = mysql_store_result(mysql);

 

  ┊  intfieldnum = mysql_num_fields(result);

  ┊  for(inti=0; i<fieldnum; i++)

  ┊  {

  ┊  ┊  row = mysql_fetch_row(result);

  ┊  ┊  if(row <= 0)

  ┊  ┊  ┊  break;

  ┊  ┊  for(intj=0; j<fieldnum; j++)

  ┊  ┊  {

  ┊  ┊  ┊  cout << row[j] << "\t\t";

  ┊  ┊  }

  ┊  ┊  cout << endl;

  ┊  }

  ┊  mysql_free_result(result);

  }

  returntrue;

}

 

#include <iostream>

#include <string>

#include <stack>

#include <algorithm>

#include <mysql/mysql.h>

#include "myDB.h"

 

usingnamespacestd;

 

 

intmain()

{  

  MyDB db;

  db.InitDB("localhost","root","xxxxxx","Student");

  db.ExeSQL("SELECT * FROM Infor;");

  return0;

}  

如下是運行結果：

 

下面是遇到的問題： 

1. 編譯時出錯 

沒有那個文件或目錄 

#include<mysql/mysql.h>

^

編譯中斷。 

解決：除了mysql-client和mysql-server，又安裝了mysql-devel，而後就解決了。 

2. 自定義的變量傳入sql語句時，出現問題 

在網上查找到這樣一種格式， 

string sql = "INSERT INTO Infor (name,sex,tel,addr,age) values('"+fname+"','"+fsex+"','"+ftel+"','"+faddr+"', "+IntToStr(fage)+");"; 

而後string類型的能夠成功，整型的變量仍是不行，我又寫了個函數把int轉爲string。

string IntToStr(intnum)

{        

  stringstream ss;

  ss.clear();

  ss << num;

  returnss.str();

}

大概就是這樣，門衛大叔很兇，我也很絕望，就寫到這吧，有問題再補充。

文章來源：做者——Tanswer_ 

今天文章就介紹到這了,有什麼問題歡迎評論區留言。

 

最後，若是你也想成爲程序員，想要快速掌握編程，趕忙加入學習企鵝圈子！

裏面有資深專業軟件開發工程師，在線解答你的全部疑惑~編程語言入門「so easy」

編程學習書籍：

 

編程學習視頻：