C++实现对MySQL访问操作的封装类

MySQLInterface.h:

// MySQLInterface
// 功能描述：实现对MySQL访问操作的封装

#ifndef __MYSQL_INTERFACE_H__  
#define __MYSQL_INTERFACE_H__  

#include <string>  
#include <vector>  

#include <winsock.h> // 远程访问
#include "include/include/mysql.h"

// 引入相关库
#pragma comment(lib, "ws2_32.lib")  
#pragma comment(lib, "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

使用示例：

#include <iostream>
using namespace std;

#include "MySQLInterface.h"  

int _tmain(int argc, _TCHAR* argv[])
{
	MySQLInterface MySQLInterface;
	MySQLInterface.SetMySQLConInfo("localhost", "root", "123456", "world", 337);
	if (!MySQLInterface.Open())
	{
		std::cout << MySQLInterface.ErrorNum << " : " << MySQLInterface.ErrorInfo << std::endl;
	}

	// 读取数据
	std::vector<std::vector<std::string> > data;
	std::string sqlstr = "SELECT `ID`,`Name`,`CountryCode`,`District` FROM `world`.`city` LIMIT 10";
	MySQLInterface.Select(sqlstr, data);

	// 显示数据
	for (unsigned int i = 0; i < data.size(); ++i)
	{
		for (unsigned int j = 0; j < data[0].size(); ++j)
		{
			cout << data[i][j] << "\t\t";
		}
		cout << endl;
	}

	// 其他操作
	sqlstr = "CREATE TABLE IF NOT EXISTS `new_paper` (";
	sqlstr += " `NewID` int(11) NOT NULL AUTO_INCREMENT,";
	sqlstr += " `NewCaption` varchar(40) NOT NULL,";
	sqlstr += " `NewContent` text,";
	sqlstr += " `NewTime` datetime DEFAULT NULL,";
	sqlstr += " PRIMARY KEY(`NewID`)";
	sqlstr += " ) ENGINE = InnoDB DEFAULT CHARSET = utf8";

	if (!MySQLInterface.Query(sqlstr))
	{
		std::cout << MySQLInterface.ErrorNum << " : " << MySQLInterface.ErrorInfo << std::endl;
	}

	MySQLInterface.Close();

	system("pause");
	return 0;
}