C++利用MySQLAPI連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

1.C++連接和操作MySQL的方式

成都創(chuàng)新互聯(lián)一直秉承“誠(chéng)信做人，踏實(shí)做事”的原則，不欺瞞客戶，是我們最起碼的底線！以服務(wù)為基礎(chǔ)，以質(zhì)量求生存，以技術(shù)求發(fā)展，成交一個(gè)客戶多一個(gè)朋友！為您提供成都網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、外貿(mào)網(wǎng)站建設(shè)、成都網(wǎng)頁(yè)設(shè)計(jì)、重慶小程序開(kāi)發(fā)、成都網(wǎng)站開(kāi)發(fā)、成都網(wǎng)站制作、成都軟件開(kāi)發(fā)、App定制開(kāi)發(fā)是成都本地專(zhuān)業(yè)的網(wǎng)站建設(shè)和網(wǎng)站設(shè)計(jì)公司，等你一起來(lái)見(jiàn)證！

系列文章：

MySQL 設(shè)計(jì)和命令行模式下建立詳解

C++利用MySQL API連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

在Windows平臺(tái)，我們可以使用ADO、ODBC或者M(jìn)ySQL API進(jìn)行連接和操作。ADO (ActiveX Data Objects，ActiveX數(shù)據(jù)對(duì)象）是Microsoft提出的一個(gè)用于存取數(shù)據(jù)源的COM組件。它提供了程序語(yǔ)言和統(tǒng)一數(shù)據(jù)訪問(wèn)方式OLE DB的一個(gè)中間層，也就是Microsoft提出的應(yīng)用程序接口（API）用以實(shí)現(xiàn)訪問(wèn)關(guān)系或非關(guān)系數(shù)據(jù)庫(kù)中的數(shù)據(jù)。

ODBC(Open DataBase Connection)開(kāi)放式系統(tǒng)互連，是一種數(shù)據(jù)庫(kù)訪問(wèn)協(xié)議，提供了訪問(wèn)數(shù)據(jù)庫(kù)的API接口?；贠DBC的應(yīng)用程序，對(duì)數(shù)據(jù)庫(kù)操作不依賴(lài)于具體的DBMS，不直接與DBMS打交道，所有數(shù)據(jù)庫(kù)操作由對(duì)應(yīng)DBMS的ODBC驅(qū)動(dòng)程序完成，即：系統(tǒng)中不需要安裝DBMS系統(tǒng)，如SQL SERVER 2005，但必須有SQL SERVER 2005的ODBC驅(qū)動(dòng)程序，然后在ODBC管理器中注冊(cè)數(shù)據(jù)源后，就可以在應(yīng)用程序中通過(guò)ODBC API訪問(wèn)該數(shù)據(jù)庫(kù)。ODBC數(shù)據(jù)庫(kù)訪問(wèn)技術(shù)只適用于windows系統(tǒng)，因?yàn)樾枰贠DBC驅(qū)動(dòng)程序管理器中進(jìn)行數(shù)據(jù)源注冊(cè)，而只有windows才集成了ODBC驅(qū)動(dòng)程序管理器(“控制面板/管理工具/數(shù)據(jù)源”)。

ADO具有跨系統(tǒng)平臺(tái)特性，它直接對(duì)DBMS數(shù)據(jù)庫(kù)進(jìn)行操作，即系統(tǒng)中必須有DBMS，但不需要驅(qū)動(dòng)程序，不需要注冊(cè)數(shù)據(jù)源，所以具有很好的可移植性。

那么，在Linux平臺(tái)如何連接和使用MSQL數(shù)據(jù)庫(kù)呢？我們同樣可以使用ADO、unixODBC或者M(jìn)ySQL API。這里不再贅述前兩者的用法，讀者可自行研究實(shí)踐，下文將詳細(xì)講解MySQL創(chuàng)建數(shù)據(jù)庫(kù)和C++利用MSQL API連接和操作數(shù)據(jù)庫(kù)。

2.MSQL數(shù)據(jù)庫(kù)的設(shè)計(jì)和建立

MySQL數(shù)據(jù)庫(kù)管理系統(tǒng)（DBMS）中，包含的MySQL中定義數(shù)據(jù)字段的類(lèi)型對(duì)你數(shù)據(jù)庫(kù)的優(yōu)化是非常重要的。MySQL支持多種類(lèi)型，大致可以分為三類(lèi)：數(shù)值、日期/時(shí)間和字符串(字符)類(lèi)型。

本文以大學(xué)熟悉的學(xué)生選課管理系統(tǒng)中用到的數(shù)據(jù)庫(kù)為例，來(lái)實(shí)現(xiàn)對(duì)數(shù)據(jù)庫(kù)的訪問(wèn)。本文數(shù)據(jù)庫(kù)的建立，是在Linux平臺(tái)使用msyql命令完成

主要有三張表：學(xué)生表，課程表和選課表。下面是數(shù)據(jù)表的詳細(xì)情況。

學(xué)生表：
C++利用MySQL API連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

課程表：
C++利用MySQL API連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

選課表：
C++利用MySQL API連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

3.MSQL數(shù)據(jù)庫(kù)的連接和操作

下面將講解利用MySQL API來(lái)編寫(xiě)我們自己的用于訪問(wèn)MySQL的中間件，也是我們自己的組件。我們的組件在應(yīng)用程序和MySQL數(shù)據(jù)庫(kù)之間構(gòu)成的層次結(jié)構(gòu)如下圖所示：
C++利用MySQL API連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

下面就來(lái)設(shè)計(jì)和實(shí)現(xiàn)我們自己的C++訪問(wèn)MySQL數(shù)據(jù)庫(kù)的組件。

3.1頭文件的設(shè)計(jì)

//mysqlhelper.h

#ifndef __MYSQL_HELPER_H__
#define __MYSQL_HELPER_H__

#include 

#include 
#include 
#include 
using namespace std;

#include 

namespace mysqlhelper
{

/*********************
*@brief 數(shù)據(jù)庫(kù)異常類(lèi)
**********************/
struct MysqlHelper_Exception //: public TC_Exception
{
 MysqlHelper_Exception(const string &sBuffer):errorInfo(sBuffer){}; //: TC_Exception(sBuffer){};
 ~MysqlHelper_Exception() throw(){}; 

 string errorInfo;
};

/***********************
* @brief 數(shù)據(jù)庫(kù)配置接口
***********************/
struct DBConf
{

 string _host;//主機(jī)地址
 string _user; //用戶名 
 string _password;//密碼
 string _database; //數(shù)據(jù)庫(kù)
 string _charset; //字符集
 int _port;//端口
 int _flag; //客戶端標(biāo)識(shí)

 /*****************
 * @brief 構(gòu)造函數(shù)
 *****************/
 DBConf():_port(0), _flag(0){}

 /**********************************
 * @brief 讀取數(shù)據(jù)庫(kù)配置. 
 * @param mpParam 存放數(shù)據(jù)庫(kù)配置的map 
 * dbhost: 主機(jī)地址
 * dbuser:用戶名
 * dbpass:密碼
 * dbname:數(shù)據(jù)庫(kù)名稱(chēng)
 * dbport:端口
 **********************************/
 void loadFromMap(const map &mpParam)
 {
 map mpTmp = mpParam;

 _host = mpTmp["dbhost"];
 _user = mpTmp["dbuser"];
 _password = mpTmp["dbpass"];
 _database = mpTmp["dbname"];
 _charset = mpTmp["charset"];
 _port = atoi(mpTmp["dbport"].c_str());
 _flag = 0;

 if(mpTmp["dbport"] == "")
 {
 _port = 3306;
 }
 }
};

/**************************************************************
* @brief:MySQL數(shù)據(jù)庫(kù)操作類(lèi) 
* @feature:非線程安全，通常一個(gè)線程一個(gè)MysqlHelper對(duì)象；
* 對(duì)于insert/update可以有更好的函數(shù)封裝，保證SQL注入；
* MysqlHelper::DB_INT表示組裝sql語(yǔ)句時(shí)，不加””和轉(zhuǎn)義；
* MysqlHelper::DB_STR表示組裝sql語(yǔ)句時(shí)，加””并轉(zhuǎn)義；
**************************************************************/
class MysqlHelper{

public:
 /**
 * @brief 構(gòu)造函數(shù)
 */
 MysqlHelper();

 /**
 * @brief 構(gòu)造函數(shù). 
 * @param: sHost:主機(jī)IP
 * @param sUser 用戶
 * @param sPasswd 密碼
 * @param sDatebase 數(shù)據(jù)庫(kù)
 * @param port 端口
 * @param iUnixSocket socket
 * @param iFlag 客戶端標(biāo)識(shí)
 */
 MysqlHelper(const string& sHost, const string& sUser = "", const string& sPasswd = "", const string& sDatabase = "", const string &sCharSet = "", int port = 0, int iFlag = 0);

 /**
 * @brief 構(gòu)造函數(shù). 
 * @param tcDBConf 數(shù)據(jù)庫(kù)配置
 */
 MysqlHelper(const DBConf& tcDBConf);

 /**
 * @brief 析構(gòu)函數(shù).
 */
 ~MysqlHelper();

 /**
 * @brief 初始化. 
 * 
 * @param sHost 主機(jī)IP
 * @param sUser 用戶
 * @param sPasswd 密碼
 * @param sDatebase 數(shù)據(jù)庫(kù)
 * @param port 端口
 * @param iUnixSocket socket
 * @param iFlag 客戶端標(biāo)識(shí)
 * @return 無(wú)
 */
 void init(const string& sHost, const string& sUser = "", const string& sPasswd = "", const string& sDatabase = "", const string &sCharSet = "", int port = 0, int iFlag = 0);

 /**
 * @brief 初始化. 
 * 
 * @param tcDBConf 數(shù)據(jù)庫(kù)配置
 */
 void init(const DBConf& tcDBConf);

 /**
 * @brief 連接數(shù)據(jù)庫(kù). 
 * 
 * @throws MysqlHelper_Exception
 * @return 無(wú)
 */
 void connect();

 /**
 * @brief 斷開(kāi)數(shù)據(jù)庫(kù)連接. 
 * @return 無(wú)
 */
 void disconnect();

 /**
 * @brief 獲取數(shù)據(jù)庫(kù)變量. 
 * @return 數(shù)據(jù)庫(kù)變量
 */
 string getVariables(const string &sName);

 /**
 * @brief 直接獲取數(shù)據(jù)庫(kù)指針. 
 * 
 * @return MYSQL* 數(shù)據(jù)庫(kù)指針
 */
 MYSQL *getMysql();

 /**
 * @brief 字符轉(zhuǎn)義. 
 * 
 * @param sFrom 源字符串
 * @param sTo 輸出字符串
 * @return 輸出字符串
 */
 string escapeString(const string& sFrom);

 /**
 * @brief 更新或者插入數(shù)據(jù). 
 * 
 * @param sSql sql語(yǔ)句
 * @throws MysqlHelper_Exception
 * @return
 */
 void execute(const string& sSql);

 /**
 * @brief mysql的一條記錄
 */
 class MysqlRecord
 {
 public:
 /**
 * @brief 構(gòu)造函數(shù).
 * 
 * @param record
 */
 MysqlRecord(const map &record);

 /**
 * @brief 獲取數(shù)據(jù)，s一般是指數(shù)據(jù)表的某個(gè)字段名 
 * @param s 要獲取的字段
 * @return 符合查詢(xún)條件的記錄的s字段名
 */
 const string& operator[](const string &s);
 protected:
 const map &_record;
 };

 /**
 * @brief 查詢(xún)出來(lái)的mysql數(shù)據(jù)
 */
 class MysqlData
 {
 public:
 /**
 * @brief 所有數(shù)據(jù).
 * 
 * @return vector>&
 */
 vector >& data();

 /**
 * 數(shù)據(jù)的記錄條數(shù)
 * 
 * @return size_t
 */
 size_t size();

 /**
 * @brief 獲取某一條記錄. 
 * 
 * @param i 要獲取第幾條記錄 
 * @return MysqlRecord類(lèi)型的數(shù)據(jù)，可以根據(jù)字段獲取相關(guān)信息，
 */
 MysqlRecord operator[](size_t i);

 protected:
 vector > _data;
 };

 /**
 * @brief Query Record. 
 * 
 * @param sSql sql語(yǔ)句
 * @throws MysqlHelper_Exception
 * @return MysqlData類(lèi)型的數(shù)據(jù)，可以根據(jù)字段獲取相關(guān)信息
 */
 MysqlData queryRecord(const string& sSql);

 /**
 * @brief 定義字段類(lèi)型， 
 * DB_INT:數(shù)字類(lèi)型 
 * DB_STR:字符串類(lèi)型
 */
 enum FT
 {
 DB_INT, 
 DB_STR, 
 };

 /**
 * 數(shù)據(jù)記錄
 */
 typedef map > RECORD_DATA;

 /**
 * @brief 更新記錄. 
 * 
 * @param sTableName 表名
 * @param mpColumns 列名/值對(duì)
 * @param sCondition where子語(yǔ)句,例如:where A = B
 * @throws MysqlHelper_Exception
 * @return size_t 影響的行數(shù)
 */
 size_t updateRecord(const string &sTableName, const map > &mpColumns, const string &sCondition);

 /**
 * @brief 插入記錄. 
 * 
 * @param sTableName 表名
 * @param mpColumns 列名/值對(duì)
 * @throws MysqlHelper_Exception
 * @return size_t 影響的行數(shù)
 */
 size_t insertRecord(const string &sTableName, const map > &mpColumns);

 /**
 * @brief 替換記錄. 
 * 
 * @param sTableName 表名
 * @param mpColumns 列名/值對(duì)
 * @throws MysqlHelper_Exception
 * @return size_t 影響的行數(shù)
 */
 size_t replaceRecord(const string &sTableName, const map > &mpColumns);

 /**
 * @brief 刪除記錄. 
 * 
 * @param sTableName 表名
 * @param sCondition where子語(yǔ)句,例如:where A = B
 * @throws MysqlHelper_Exception
 * @return size_t 影響的行數(shù)
 */
 size_t deleteRecord(const string &sTableName, const string &sCondition = "");

 /**
 * @brief 獲取Table查詢(xún)結(jié)果的數(shù)目. 
 * 
 * @param sTableName 用于查詢(xún)的表名
 * @param sCondition where子語(yǔ)句,例如:where A = B
 * @throws MysqlHelper_Exception
 * @return size_t 查詢(xún)的記錄數(shù)目
 */
 size_t getRecordCount(const string& sTableName, const string &sCondition = "");

 /**
 * @brief 獲取Sql返回結(jié)果集的個(gè)數(shù). 
 * 
 * @param sCondition where子語(yǔ)句,例如:where A = B
 * @throws MysqlHelper_Exception
 * @return 查詢(xún)的記錄數(shù)目
 */
 size_t getSqlCount(const string &sCondition = "");

 /**
 * @brief 存在記錄. 
 * 
 * @param sql sql語(yǔ)句
 * @throws MysqlHelper_Exception
 * @return 操作是否成功
 */
 bool existRecord(const string& sql);

 /**
 * @brief 獲取字段最大值. 
 * 
 * @param sTableName 用于查詢(xún)的表名
 * @param sFieldName 用于查詢(xún)的字段
 * @param sCondition where子語(yǔ)句,例如:where A = B
 * @throws MysqlHelper_Exception
 * @return 查詢(xún)的記錄數(shù)目
 */
 int getMaxValue(const string& sTableName, const string& sFieldName, const string &sCondition = "");

 /**
 * @brief 獲取auto_increment最后插入得ID. 
 * 
 * @return ID值
 */
 long lastInsertID();

 /**
 * @brief 構(gòu)造Insert-SQL語(yǔ)句. 
 * 
 * @param sTableName 表名
 * @param mpColumns 列名/值對(duì)
 * @return string insert-SQL語(yǔ)句
 */
 string buildInsertSQL(const string &sTableName, const map > &mpColumns);

 /**
 * @brief 構(gòu)造Replace-SQL語(yǔ)句. 
 * 
 * @param sTableName 表名
 * @param mpColumns 列名/值對(duì)
 * @return string insert-SQL語(yǔ)句
 */
 string buildReplaceSQL(const string &sTableName, const map > &mpColumns);

 /**
 * @brief 構(gòu)造Update-SQL語(yǔ)句. 
 * 
 * @param sTableName 表名
 * @param mpColumns 列名/值對(duì)
 * @param sCondition where子語(yǔ)句
 * @return string Update-SQL語(yǔ)句
 */
 string buildUpdateSQL(const string &sTableName,const map > &mpColumns, const string &sCondition);

 /**
 * @brief 獲取最后執(zhí)行的SQL語(yǔ)句.
 * 
 * @return SQL語(yǔ)句
 */
 string getLastSQL() { return _sLastSql; }

 /**
 * @brief 獲取查詢(xún)影響數(shù)
 * @return int
 */
 size_t getAffectedRows();
protected:
 /**
 * @brief copy contructor，只申明,不定義,保證不被使用 
 */
 MysqlHelper(const MysqlHelper &tcMysql);

 /**
 * 
 * @brief 只申明,不定義,保證不被使用
 */
 MysqlHelper &operator=(const MysqlHelper &tcMysql);


private:

 /**
 * 數(shù)據(jù)庫(kù)指針
 */
 MYSQL *_pstMql;

 /**
 * 數(shù)據(jù)庫(kù)配置
 */
 DBConf _dbConf;

 /**
 * 是否已經(jīng)連接
 */
 bool _bConnected;

 /**
 * 最后執(zhí)行的sql
 */
 string _sLastSql;

};
}
#endif //__MYSQL_HELPER_H__

3.2源文件具體實(shí)現(xiàn)

//mysqlhelper.cpp

#include "mysqlHelper.h"

#include 
#include 

using namespace std;

namespace mysqlhelper{

MysqlHelper::MysqlHelper():_bConnected(false)
{
 _pstMql = mysql_init(NULL);
}

MysqlHelper::MysqlHelper(const string& sHost, const string& sUser, const string& sPasswd, const string& sDatabase, const string &sCharSet, int port, int iFlag)
:_bConnected(false)
{
 init(sHost, sUser, sPasswd, sDatabase, sCharSet, port, iFlag);

 _pstMql = mysql_init(NULL);
}

MysqlHelper::MysqlHelper(const DBConf& tcDBConf)
:_bConnected(false)
{
 _dbConf = tcDBConf;

 _pstMql = mysql_init(NULL); 
}

MysqlHelper::~MysqlHelper()
{
 if (_pstMql != NULL)
 {
 mysql_close(_pstMql);
 _pstMql = NULL;
 }
}

void MysqlHelper::init(const string& sHost, const string& sUser, const string& sPasswd, const string& sDatabase, const string &sCharSet, int port, int iFlag)
{
 _dbConf._host = sHost;
 _dbConf._user = sUser;
 _dbConf._password = sPasswd;
 _dbConf._database = sDatabase;
 _dbConf._charset = sCharSet;
 _dbConf._port = port;
 _dbConf._flag = iFlag;
}

void MysqlHelper::init(const DBConf& tcDBConf)
{
 _dbConf = tcDBConf;
}

void MysqlHelper::connect()
{
 disconnect();

 if( _pstMql == NULL)
 {
 _pstMql = mysql_init(NULL);
 }

 //建立連接后, 自動(dòng)調(diào)用設(shè)置字符集語(yǔ)句
 if(!_dbConf._charset.empty()) {
 if (mysql_options(_pstMql, MYSQL_SET_CHARSET_NAME, _dbConf._charset.c_str())) {
 throw MysqlHelper_Exception(string("MysqlHelper::connect: mysql_options MYSQL_SET_CHARSET_NAME ") + _dbConf._charset + ":" + string(mysql_error(_pstMql)));
 }
 }

 if (mysql_real_connect(_pstMql, _dbConf._host.c_str(), _dbConf._user.c_str(), _dbConf._password.c_str(), _dbConf._database.c_str(), _dbConf._port, NULL, _dbConf._flag) == NULL) 
 {
 throw MysqlHelper_Exception("[MysqlHelper::connect]: mysql_real_connect: " + string(mysql_error(_pstMql)));
 }

 _bConnected = true;
}

void MysqlHelper::disconnect()
{
 if (_pstMql != NULL)
 {
 mysql_close(_pstMql);
 _pstMql = mysql_init(NULL);
 }

 _bConnected = false; 
}

string MysqlHelper::escapeString(const string& sFrom)
{
 if(!_bConnected)
 {
 connect();
 }

 string sTo;
 string::size_type iLen = sFrom.length() * 2 + 1;
 char *pTo = (char *)malloc(iLen);

 memset(pTo, 0x00, iLen);

 mysql_real_escape_string(_pstMql, pTo, sFrom.c_str(), sFrom.length());

 sTo = pTo;

 free(pTo);

 return sTo;
}

MYSQL *MysqlHelper::getMysql(void)
{
 return _pstMql;
}

string MysqlHelper::buildInsertSQL(const string &sTableName, const RECORD_DATA &mpColumns)
{
 ostringstream sColumnNames;
 ostringstream sColumnValues;

 map >::const_iterator itEnd = mpColumns.end();

 for(map >::const_iterator it = mpColumns.begin(); it != itEnd; ++it)
 {
 if (it == mpColumns.begin())
 {
 sColumnNames << "`" << it->first << "`";
 if(it->second.first == DB_INT)
 {
 sColumnValues << it->second.second;
 }
 else
 {
 sColumnValues << "'" << escapeString(it->second.second) << "'";
 }
 }
 else
 {
 sColumnNames << ",`" << it->first << "`";
 if(it->second.first == DB_INT)
 {
 sColumnValues << "," + it->second.second;
 }
 else
 {
 sColumnValues << ",'" + escapeString(it->second.second) << "'";
 }
 }
 }

 ostringstream os;
 os << "insert into " << sTableName << " (" << sColumnNames.str() << ") values (" << sColumnValues.str() << ")";
 return os.str();
}

string MysqlHelper::buildReplaceSQL(const string &sTableName, const RECORD_DATA &mpColumns)
{
 ostringstream sColumnNames;
 ostringstream sColumnValues;

 map >::const_iterator itEnd = mpColumns.end();
 for(map >::const_iterator it = mpColumns.begin(); it != itEnd; ++it)
 {
 if (it == mpColumns.begin())
 {
 sColumnNames << "`" << it->first << "`";
 if(it->second.first == DB_INT)
 {
 sColumnValues << it->second.second;
 }
 else
 {
 sColumnValues << "'" << escapeString(it->second.second) << "'";
 }
 }
 else
 {
 sColumnNames << ",`" << it->first << "`";
 if(it->second.first == DB_INT)
 {
 sColumnValues << "," + it->second.second;
 }
 else
 {
 sColumnValues << ",'" << escapeString(it->second.second) << "'";
 }
 }
 }

 ostringstream os;
 os << "replace into " << sTableName << " (" << sColumnNames.str() << ") values (" << sColumnValues.str() << ")";
 return os.str();
}

string MysqlHelper::buildUpdateSQL(const string &sTableName,const RECORD_DATA &mpColumns, const string &sWhereFilter)
{
 ostringstream sColumnNameValueSet;

 map >::const_iterator itEnd = mpColumns.end();

 for(map >::const_iterator it = mpColumns.begin(); it != itEnd; ++it)
 {
 if (it == mpColumns.begin())
 {
 sColumnNameValueSet << "`" << it->first << "`";
 }
 else
 {
 sColumnNameValueSet << ",`" << it->first << "`";
 }

 if(it->second.first == DB_INT)
 {
 sColumnNameValueSet << "= " << it->second.second;
 }
 else
 {
 sColumnNameValueSet << "= '" << escapeString(it->second.second) << "'";
 }
 }

 ostringstream os;
 os << "update " << sTableName << " set " << sColumnNameValueSet.str() << " " << sWhereFilter;

 return os.str();
}

string MysqlHelper::getVariables(const string &sName)
{
 string sql = "SHOW VARIABLES LIKE '" + sName + "'";

 MysqlData data = queryRecord(sql);
 if(data.size() == 0)
 {
 return "";
 }

 if(sName == data[0]["Variable_name"])
 {
 return data[0]["Value"];
 }

 return "";
}

void MysqlHelper::execute(const string& sSql)
{
 /**
 沒(méi)有連上, 連接數(shù)據(jù)庫(kù)
 */
 if(!_bConnected)
 {
 connect();
 }

 _sLastSql = sSql;

 int iRet = mysql_real_query(_pstMql, sSql.c_str(), sSql.length());
 if(iRet != 0)
 {
 /**
 自動(dòng)重新連接
 */
 int iErrno = mysql_errno(_pstMql);
 if (iErrno == 2013 || iErrno == 2006)
 {
 connect();
 iRet = mysql_real_query(_pstMql, sSql.c_str(), sSql.length());
 }
 }

 if (iRet != 0)
 {
 throw MysqlHelper_Exception("[MysqlHelper::execute]: mysql_query: [ " + sSql+" ] :" + string(mysql_error(_pstMql))); 
 }
}

MysqlHelper::MysqlData MysqlHelper::queryRecord(const string& sSql)
{
 MysqlData data;

 /**
 沒(méi)有連上, 連接數(shù)據(jù)庫(kù)
 */
 if(!_bConnected)
 {
 connect();
 }

 _sLastSql = sSql;

 int iRet = mysql_real_query(_pstMql, sSql.c_str(), sSql.length());
 if(iRet != 0)
 {
 /**
 自動(dòng)重新連接
 */
 int iErrno = mysql_errno(_pstMql);
 if (iErrno == 2013 || iErrno == 2006)
 {
 connect();
 iRet = mysql_real_query(_pstMql, sSql.c_str(), sSql.length());
 }
 }

 if (iRet != 0)
 {
 throw MysqlHelper_Exception("[MysqlHelper::execute]: mysql_query: [ " + sSql+" ] :" + string(mysql_error(_pstMql))); 
 }

 MYSQL_RES *pstRes = mysql_store_result(_pstMql);

 if(pstRes == NULL)
 {
 throw MysqlHelper_Exception("[MysqlHelper::queryRecord]: mysql_store_result: " + sSql + " : " + string(mysql_error(_pstMql)));
 }

 vector vtFields;
 MYSQL_FIELD *field;
 while((field = mysql_fetch_field(pstRes)))
 {
 vtFields.push_back(field->name);
 }

 map mpRow;
 MYSQL_ROW stRow;

 while((stRow = mysql_fetch_row(pstRes)) != (MYSQL_ROW)NULL)
 {
 mpRow.clear();
 unsigned long * lengths = mysql_fetch_lengths(pstRes);
 for(size_t i = 0; i < vtFields.size(); i++)
 {
 if(stRow[i])
 {
 mpRow[vtFields[i]] = string(stRow[i], lengths[i]);
 }
 else
 {
 mpRow[vtFields[i]] = "";
 }
 }

 data.data().push_back(mpRow);
 }

 mysql_free_result(pstRes);

 return data;
}

size_t MysqlHelper::updateRecord(const string &sTableName, const RECORD_DATA &mpColumns, const string &sCondition)
{
 string sSql = buildUpdateSQL(sTableName, mpColumns, sCondition);
 execute(sSql);

 return mysql_affected_rows(_pstMql);
}

size_t MysqlHelper::insertRecord(const string &sTableName, const RECORD_DATA &mpColumns)
{
 string sSql = buildInsertSQL(sTableName, mpColumns);
 execute(sSql);

 return mysql_affected_rows(_pstMql);
}

size_t MysqlHelper::replaceRecord(const string &sTableName, const RECORD_DATA &mpColumns)
{
 string sSql = buildReplaceSQL(sTableName, mpColumns);
 execute(sSql);

 return mysql_affected_rows(_pstMql);
}

size_t MysqlHelper::deleteRecord(const string &sTableName, const string &sCondition)
{
 ostringstream sSql;
 sSql << "delete from " << sTableName << " " << sCondition;

 execute(sSql.str());

 return mysql_affected_rows(_pstMql);
}

size_t MysqlHelper::getRecordCount(const string& sTableName, const string &sCondition)
{
 ostringstream sSql;
 sSql << "select count(*) as num from " << sTableName << " " << sCondition;

 MysqlData data = queryRecord(sSql.str());

 long n = atol(data[0]["num"].c_str());

 return n;

}

size_t MysqlHelper::getSqlCount(const string &sCondition)
{
 ostringstream sSql;
 sSql << "select count(*) as num " << sCondition;

 MysqlData data = queryRecord(sSql.str());

 long n = atol(data[0]["num"].c_str());

 return n;
}

int MysqlHelper::getMaxValue(const string& sTableName, const string& sFieldName,const string &sCondition)
{
 ostringstream sSql;
 sSql << "select " << sFieldName << " as f from " << sTableName << " " << sCondition << " order by f desc limit 1";

 MysqlData data = queryRecord(sSql.str());

 int n = 0;

 if(data.size() == 0)
 {
 n = 0;
 }
 else
 {
 n = atol(data[0]["f"].c_str());
 }

 return n;
}

bool MysqlHelper::existRecord(const string& sql)
{
 return queryRecord(sql).size() > 0;
}

long MysqlHelper::lastInsertID()
{
 return mysql_insert_id(_pstMql);
}

size_t MysqlHelper::getAffectedRows()
{
 return mysql_affected_rows(_pstMql);
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////
MysqlHelper::MysqlRecord::MysqlRecord(const map &record):_record(record){}

const string& MysqlHelper::MysqlRecord::operator[](const string &s)
{
 map::const_iterator it = _record.find(s);
 if(it == _record.end())
 {
 throw MysqlHelper_Exception("field '" + s + "' not exists.");
 }
 return it->second;
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////

vector >& MysqlHelper::MysqlData::data()
{
 return _data;
}

size_t MysqlHelper::MysqlData::size()
{
 return _data.size();
}

MysqlHelper::MysqlRecord MysqlHelper::MysqlData::operator[](size_t i)
{
 return MysqlRecord(_data[i]);
}

}//end namespace

3.3使用demo

/****************************************************
*@brief:mysqlhelper demo
*@autor:lvlv
*@date:2016.06.12
*@MySQL version:MySQL Community Server 5.6.30 (GPL)
****************************************************/

#include 
#include 
#include 
using namespace std;

#include "mysqlHelper.h"
using namespace mysqlhelper;


int main(int argc,char* argv[]){

 //初始化mysql對(duì)象并建立連接
 MysqlHelper mysqlHelper;
 mysqlHelper.init("119.29.184.114","root","123456","StudentCourse");
 try{
 mysqlHelper.connect();
 }catch(MysqlHelper_Exception& excep){
 cout<

3.4makefile

##################################
# @brief:make scripts
# @date:2016.05.28
# @author:lvlv
##################################

#environment var
VPATH+=.

CC:=g++
FLAGS=-g -Wall -std=c++11
INC+=-I/usr/local/mysql/include
LIBDIR+=-L/usr/local/mysql/lib

CPPDIRS=.
CPPS=$(shell for dir in ${CPPDIRS};do echo $${dir}/*.cpp;done)

OBJDIR=obj
OBJS=$(patsubst %.cpp,${OBJDIR}/%.o,$(notdir ${CPPS}))

TARGET:=mysqlDemo.out

${TARGET}:${OBJS}
 ${CC} ${FLAGS} ${OBJS} -o $@ ${LIBDIR} -lmysqlclient

${OBJDIR}/%.o:./%.cpp
 ${CC} ${FLAGS} ${INC} -o $@ -c $<

.PHONY:clean
clean:
 rm -f ${TARGET} ${OBJDIR}/*

感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！

本文標(biāo)題：C++利用MySQLAPI連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解
文章鏈接：http://weahome.cn/article/gjohhd.html

真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

C++利用MySQLAPI連接和操作數(shù)據(jù)庫(kù)實(shí)例詳解

其他資訊

網(wǎng)站制作

企業(yè)服務(wù)

網(wǎng)站建設(shè)

服務(wù)器托管