想用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”
編程學習書籍：
編程學習視頻：
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/239991.html
標籤：MySQL
下一篇：MySQL 執行計劃