database.h

vc连接mysql的封装类

// Database.h: interface for the CDatabase class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_DATABASE_H__85975BFF_00D3_4423_BA37_8170CAECE08D__INCLUDED_)
#define AFX_DATABASE_H__85975BFF_00D3_4423_BA37_8170CAECE08D__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
#ifndef CMYSQL_H
#define CMYCQL_H#ifndef CMYSQL_H
#define CMYCQL_H

#include <winsock.h>
#include "mysql/mysql.h"
#include <sstream>
#include <string>

using std::string;
struct Data_Param    //数据库操作参数
{
    string db_name;    //数据库名
    string tab_name;    //表名
    string col_name;    //列名
    string select_exp;    //选择表达式
    string where_def;    //选择限定条件
    string insert_val;    //插入值
    string set_exp;    //更新数据库内容的表达式
};

struct Database_Param    //数据库参数
{
    string host;    //主机名
    string user;    //用户名
    string password;    //密码
    string db;    //数据库名
    unsigned int port;    //端口，一般为0
    const char* unix_socket;    //套接字，一般为NULL
    unsigned int client_flag;    //一般为0
    Database_Param(string host, string user, string password, string db, unsigned int port, const char* unix_socket, unsigned int client_flag)
    {
        this->host = host;
        this->user = user;
        this->password = password;
        this->db = db;
        this->port = port;
        this->unix_socket = unix_socket;
        this->client_flag = client_flag;
    }
};

class CMysql
{
public:
    string GetState();    //服务器状态
    string GetServerInfo();    //服务器信息
    int GetProtocolInfo();    //协议信息
    string GetHostInfo();    //主机信息
    string GetClientInfo();    //客户机信息
    string GetFieldName(int FieldNum);
    bool IsEnd();    //是否最后
    void SeekData(int offset);    //查找指定数据
    unsigned int GetFieldNum();        //得到字段数
    bool ConnectDB(Database_Param* p);    //连接数据库
    MYSQL_ROW GetRecord();    //得到结果（一个记录）
    my_ulonglong GetRowNum();    //得到记录数
    bool SelectDB(Data_Param* para);    //选择数据库
    bool UpdateRecord(Data_Param* para);    //更新记录
    bool SelectRecord(Data_Param* para);    //选择记录
    bool InsertRecord(Data_Param* para);    //插入记录
    bool DelRecord(Data_Param* para);        //删除记录
    bool SelectAll(Data_Param* para);        //选择所有记录
    string OutErrors();        //输出错误信息
    bool MysqlEx(MYSQL* mysql, string str); 
    CMysql();
    virtual ~CMysql();
private:
    bool FindSave(string str);    //查找并保存结果集
private:
    MYSQL mysql;    //数据库链接句柄
    MYSQL_FIELD* field;    //字段信息（结构体）
public:
    MYSQL_RES* query;    //结果集
    MYSQL_ROW row;    //记录集
};


#include <winsock.h>
#include "mysql/mysql.h"
#include <sstream>
#include <string>

using std::string;
struct Data_Param    //数据库操作参数
{
    string db_name;    //数据库名
    string tab_name;    //表名
    string col_name;    //列名
    string select_exp;    //选择表达式
    string where_def;    //选择限定条件
    string insert_val;    //插入值
    string set_exp;    //更新数据库内容的表达式
};

struct Database_Param    //数据库参数
{
    string host;    //主机名
    string user;    //用户名
    string password;    //密码
    string db;    //数据库名
    unsigned int port;    //端口，一般为0
    const char* unix_socket;    //套接字，一般为NULL
    unsigned int client_flag;    //一般为0
    Database_Param(string host, string user, string password, string db, unsigned int port, const char* unix_socket, unsigned int client_flag)
    {
        this->host = host;
        this->user = user;
        this->password = password;
        this->db = db;
        this->port = port;
        this->unix_socket = unix_socket;
        this->client_flag = client_flag;
    }
};

class CMysql
{
public:
    string GetState();    //服务器状态
    string GetServerInfo();    //服务器信息
    int GetProtocolInfo();    //协议信息
    string GetHostInfo();    //主机信息
    string GetClientInfo();    //客户机信息
    string GetFieldName(int FieldNum);
    bool IsEnd();    //是否最后
    void SeekData(int offset);    //查找指定数据
    unsigned int GetFieldNum();        //得到字段数
    bool ConnectDB(Database_Param* p);    //连接数据库
    MYSQL_ROW GetRecord();    //得到结果（一个记录）
    my_ulonglong GetRowNum();    //得到记录数
    bool SelectDB(Data_Param* para);    //选择数据库
    bool UpdateRecord(Data_Param* para);    //更新记录
    bool SelectRecord(Data_Param* para);    //选择记录
    bool InsertRecord(Data_Param* para);    //插入记录
    bool DelRecord(Data_Param* para);        //删除记录
    bool SelectAll(Data_Param* para);        //选择所有记录
    string OutErrors();        //输出错误信息
    bool MysqlEx(MYSQL* mysql, string str); 
    CMysql();
    virtual ~CMysql();
private:
    bool FindSave(string str);    //查找并保存结果集
private:
    MYSQL mysql;    //数据库链接句柄
    MYSQL_FIELD* field;    //字段信息（结构体）
public:
    MYSQL_RES* query;    //结果集
    MYSQL_ROW row;    //记录集
};




#endif // !defined(AFX_DATABASE_H__85975BFF_00D3_4423_BA37_8170CAECE08D__INCLUDED_)