MySQLInterface.h：

// MySQLInterface

// 功能描述：實現對MySQL訪問操作的封裝

#ifndef __MYSQL_INTERFACE_H__  
#define __MYSQL_INTERFACE_H__  

#include <string>  
#include <vector>  

#include <winsock.h> // 遠端訪問
#include "MySQL/include/mysql.h"

// 引入相關庫
#pragma comment(lib, "ws2_32.lib")  
#pragma comment(lib, "MySQL/lib/libmysql.lib")

#define ERROR_QUERY_FAIL -1 // 操作失敗


// 定義MySQL連線資訊
typedef struct
{
	char* server;
	char* user;
	char* password;
	char* database;
	int port;
}MySQLConInfo;

class MySQLInterface
{
public:
	MySQLInterface();
	virtual ~MySQLInterface();

	void SetMySQLConInfo(char* server, char* username, char* password, char* database, int port);// 設定連線資訊
	bool Open();  // 開啟連線
	void Close(); // 關閉連線

	bool Select(const std::string& Querystr, std::vector<std::vector<std::string> >& data);	     // 讀取資料
	bool Query(const std::string& Querystr);     // 其他操作
	int GetInsertID(const std::string& Querystr);// 插入並獲取插入的ID,針對自動遞增ID
	void ErrorIntoMySQL();		 // 錯誤訊息

public:
	int ErrorNum;				 // 錯誤代號  
	const char* ErrorInfo;       // 錯誤提示  

private:
	MySQLConInfo MysqlConInfo;	 // 連線資訊
	MYSQL MysqlInstance;		 // MySQL物件
	MYSQL_RES *Result;			 // 用於存放結果 
};

#endif  
 

MySQLInterface.cpp:

#include "stdafx.h"  
#include "MySQLInterface.h"  


MySQLInterface::MySQLInterface() :
ErrorNum(0), ErrorInfo("ok")
{
	mysql_library_init(0, NULL, NULL);
	mysql_init(&MysqlInstance);

	// 設定字符集，否則無法處理中文
	mysql_options(&MysqlInstance, MYSQL_SET_CHARSET_NAME, "gbk");
}

MySQLInterface::~MySQLInterface()
{
}

// 設定連線資訊
void MySQLInterface::SetMySQLConInfo(char* server, char* username, char* password, char* database, int port)
{
	MysqlConInfo.server = server;
	MysqlConInfo.user = username;
	MysqlConInfo.password = password;
	MysqlConInfo.database = database;
	MysqlConInfo.port = port;
}

// 開啟連線
bool MySQLInterface::Open()
{
	if (mysql_real_connect(&MysqlInstance, MysqlConInfo.server, MysqlConInfo.user,
		MysqlConInfo.password, MysqlConInfo.database, MysqlConInfo.port, 0, 0) != NULL)
	{
		return true;
	}
	else
	{
		ErrorIntoMySQL();
		return false;
	}
}

// 斷開連線
void MySQLInterface::Close()
{
	mysql_close(&MysqlInstance);
}

//讀取資料
bool MySQLInterface::Select(const std::string& Querystr, std::vector<std::vector<std::string> >& data)
{
	if (0 != mysql_query(&MysqlInstance, Querystr.c_str()))
	{
		ErrorIntoMySQL();
		return false;
	}

	Result = mysql_store_result(&MysqlInstance);

	// 行列數
	int row = mysql_num_rows(Result);
	int field = mysql_num_fields(Result);

	MYSQL_ROW line = NULL;
	line = mysql_fetch_row(Result);

	int j = 0;
	std::string temp;
	std::vector<std::vector<std::string> >().swap(data);
	while (NULL != line)
	{
		std::vector<std::string> linedata;
		for (int i = 0; i < field; i++)
		{
			if (line[i])
			{
				temp = line[i];
				linedata.push_back(temp);
			}
			else
			{
				temp = "";
				linedata.push_back(temp);
			}
		}
		line = mysql_fetch_row(Result);
		data.push_back(linedata);
	}
	return true;
}

// 其他操作
bool MySQLInterface::Query(const std::string& Querystr)
{
	if (0 == mysql_query(&MysqlInstance, Querystr.c_str()))
	{
		return true;
	}
	ErrorIntoMySQL();
	return false;
}

// 插入並獲取插入的ID,針對自動遞增ID
int MySQLInterface::GetInsertID(const std::string& Querystr)
{
	if (!Query(Querystr))
	{
		ErrorIntoMySQL();
		return ERROR_QUERY_FAIL;
	}
	// 獲取ID
	return mysql_insert_id(&MysqlInstance);
}

//錯誤資訊
void MySQLInterface::ErrorIntoMySQL()
{
	ErrorNum = mysql_errno(&MysqlInstance);
	ErrorInfo = mysql_error(&MysqlInstance);
}
 

Example

錯誤提示

MFC (CString)

Win32

         if(!m_MySQLInter.Open())

         {

                  std::cout<< m_MySQLInter.ErrorNum << " : " <<m_MySQLInter.ErrorInfo << std::endl;

                  return;

         }

型別轉換

Std::string to char*

CString to char*