入口参数

       SQL：查询的SQL语句

       Msg:返回的消息，包括错误消息

       出口参数：

       int ：0表示成功；1表示失败

       */

       int UpdateData(char * SQL,char * Msg);

       /*

       主要功能：

       删除数据

       入口参数

       SQL：查询的SQL语句

       Msg:返回的消息，包括错误消息

       出口参数：

       int ：0表示成功；1表示失败

       */

       int DeleteData(char * SQL,char * Msg);

       /*

       主要功能：

       关闭数据库连接

       */

       void CloseMySQLConn();

};

第二个文件实现文件：VspdCTOMySQL.cpp

/****************************MYSQL IN C*******************************/

/*************************2007 -03 -07 *******************************/

/*************************李克喜**************************************/

#include "stdafx.h"

#include "VspdCTOMySQL.h"

VspdCToMySQL::VspdCToMySQL()

{

}

VspdCToMySQL::~VspdCToMySQL()

{

}

//初始化数据

int VspdCToMySQL::ConnMySQL(char *host,char * port ,char * Db,char * user,char* passwd,char * charset,char * Msg)

{

       if( mysql_init(&mysql) == NULL )

       {

              Msg = "inital mysql handle error";

              return 1;

       }    

       if (mysql_real_connect(&mysql,host,user,passwd,Db,0,NULL,0) == NULL)

       {

              Msg = "Failed to connect to database: Error";

              return 1;

       }    

       if(mysql_set_character_set(&mysql,"GBK") != 0)

       {

              Msg = "mysql_set_character_set Error";

              return 1;

       }

       return 0;

}

//查询数据

string VspdCToMySQL::SelectData(char * SQL,int Cnum,char * Msg)

{

       MYSQL_ROW m_row;

    MYSQL_RES *m_res;

    char sql[2048];

    sprintf(sql,SQL);

       int rnum = 0;

       char rg = 0x06;//行隔开

       char cg = {0x05};//字段隔开

       if(mysql_query(&mysql,sql) != 0)

       {

              Msg = "select ps_info Error";

              return "";

       }

       m_res = mysql_store_result(&mysql);

       if(m_res==NULL)

       {