1、概述：
为了把繁琐的操作简化成简单的类，设计了2个类用来封装了mysql的常用操作，以便使用者可以方便地使用。

2、组成

1）数据库操作类CDatabaseConnect

2）SQL对象类CSqlStatement

3、类的头文件代码

#include <winsock.h>

#include "mysql.h"

#include <string>

using namespace std;

//MYSQL的返回码类型

#define MYSQL_OK
0

#define MYSQL_FALSE
!(MYSQL_OK)

#define MYSQL_ERROR
1

//SQL的SQL语句类型

#define MYSQL_SQL_TYPE_INSERT
0

#define MYSQL_SQL_TYPE_QUERY
1

//字符串的大小

#define MYSQL_CHAR_SIZE
0xFF+1

#define MYSQL_STRING_SIZE
0xFF+1

#define MYSQL_VARCHAR_SIZE
0xFFFF+1

#define MYSQL_VAR_STRING_SIZE
0xFFFF+1

#define MYSQL_MEDIUMBLOB_SIZE
0xFFFFFF+1

#define MYSQL_LONGBLOB_SIZE
0xFFFFFFFF+1

//日志入口函数指针

typedef void(*PAddLogFunc)(const char *pszData);

//数据库连接参数

typedef struct tagSTConnectParam

{


char szUser[64+1];
//用户名称


char szPasswd[64+1];
//用户密码


char szHost[64+1];
//主机名称


char szDbName[64+1];
//数据库名称


char *pszSocket;
//socket


unsigned int nPort;
//端口号


unsigned long ucClientFlag;
//客户端标识

}STConnectParam, *PSTConnectParam;

//SQL预处理对象

class CSqlStatement

{

public:


CSqlStatement();


CSqlStatement(MYSQL* pDb);


virtual ~CSqlStatement();

private:


friend class CDatabaseConnect;


CSqlStatement(MYSQL* pDb, const char *pszSqlStatement);

public:

    //行数


int GetRowCount(void);

    //列数


int GetColumnCount(void);


//nPosIndex started by zero


//列名称


const char *GetColumnName(int nPosIndex);

    //列ID


int GetColumnIndex(const char *pszColumnName);


//获取整型


int GetColumnValueInt(int nPosIndex);

    //获取短字符串


const char *GetColumnValueVarChar(int nPosIndex);

    //获取长字符串


const char *GetColumnValueString(int nPosIndex);

    //获取字符串


const char *GetColumnValueBlob(int nPosIndex, int *pnLen);

    //获取浮点型


double GetColumnValueDouble(int nPosIndex);

    //绑定整型


bool BindInt(int nPosIndex, const int &nValue);

    //绑定短字符串


bool BindChar(int nPosIndex, const char *pszValue);

    //绑定长字符串


bool BindString(int nPosIndex, const char *pszValue);

    //绑定字符串


bool BindBlob(int nPosIndex, const char *pszValue, int nBlobBytes);


//获取浮点型


bool BindDouble(int nPosIndex, const double &fValue);


//运行


bool Execute(void);

    //下一行


bool NextRow(void);

    //复位


bool Reset(void);

    //写日志


int WriteDbLog(const char *pszMsg);

    //设置SQL预处理对象


int SetSqlStatement(const char *pszSqlStatement);

private:

    //初始化数据


bool InitData(void);

    //释放数据


void FreeData(void);

private:

    //日志函数接口


PAddLogFunc pAddLog;


MYSQL_STMT *m_pStmt;


MYSQL* m_pDb;


MYSQL_RES *m_pPrepareMetaResult;


MYSQL_BIND *m_pBind;


unsigned long *m_plStringLen;


my_bool *m_pbArray;


int *m_pnDataArray;


double *m_pfDataArray;


char **m_pszDataArray;


string m_strSql;


string m_strErrMsg;


int m_nRowCount;


int m_nColumnCount;


int m_nSqlType;


int m_nBindParamFlag;

};

typedef CSqlStatement *PCSqlStatement;

//数据库连接

class CDatabaseConnect

{

public:


CDatabaseConnect();


virtual ~CDatabaseConnect();


//打开


bool Open(PSTConnectParam pstParam);

        //关闭


bool Close(void);

        //获取MySQL对象指针


MYSQL *GetMySQL(void);

        //获取指定表名称的记录个数


int  GetTableRecordCount(const char *pszTabelName);

        //写日志


int WriteDbLog(const char *pszMsg);

        //运行SQL语句


bool DirectStatement(const char *pszSqlStatement);

        //产生SQL预处理对象


CSqlStatement* SetSqlStatement(const char *pszSqlStatement);

        //释放SQL对象


void ReleaseStatement(void);

        //获取指定SQL语句的查询记录个数


int GetRecordCount(const char *szSql);


//事务


bool BeginTransaction(void);


bool CommitTransaction(void);


bool RollbackTransaction(void);

public:


MYSQL * m_pDb;

private:


PAddLogFunc pAddLog;


CSqlStatement *m_pSqlStatement;


string m_strDbName;


string m_strSql;


string m_strErrMsg;

};