最近由于事情比较多，疏于更新博客，对各位关注我的博友表示歉意。上午为一个客户需求，增加MYSQL类，并开源共享出来，希望大家喜欢。
同时欢迎大家转载，但请务必保留版权！




使用方法：
TMysql *mysql; mysql = new TMysql("localhost","mm","root","windows",3306,0);


头文件：TMysql.h
// TMysql.h: interface for the TMysql class. // ////////////////////////////////////////////////////////////////////// /******************************************************* *  Author:    huzhangyou 胡章优 *  Mail:    huzhangyou2002@gmail.com *  MSN:    huzhangyou2002@gmail.com *  Blog:    http://doserver.net *  Site:    http://jouhu.com *  QQ:      3803308 *  Create:    2008-09-16 *  Modify:    2008-09-18 *  Copyright:  吉大优狐科技开发公司 * ***********************************************************/ #if !defined(AFX_TMYSQL_H__04DDAF5E_8297_4B77_8003_E7402138FF52__INCLUDED_) #define AFX_TMYSQL_H__04DDAF5E_8297_4B77_8003_E7402138FF52__INCLUDED_ #if _MSC_VER > 1000 #pragma once #endif // _MSC_VER > 1000 //Means Define Mysql in windows //注意这里使用Windows设置 #define __LCC__ #include <mysql.h> #include <string> #include <vector> using namespace std; class TMysql   { public:   TMysql();   virtual ~TMysql(); public:   TMysql(const string & server,const string & db,const string & user,const string& pass,int port,unsigned long client_flag);   //Insert Update Delete Create   int UQuery(const string& sql);   //Select One   string OQuery(const string& sql);   //Select N   int TMysql::NQuery(const string& sql,vector<string> & fieldName,vector<enum_field_types> &fieldType, vector<vector<string> >& fieldData);   int Trans();   int Commit();   int Rollback();   int CreateDB(const string& db);   int DropDB(const string& db); public:   MYSQL* myData;//msyql 连接句柄   bool Connected; public:   /*主要功能:得到客户信息*/   string GClientInfo()  { return mysql_get_client_info() ; }   //--------------------------------------------------------------------------   /*主要功能:得到客户版本信息*/   int GClientVer() { return mysql_get_client_version(); }   //--------------------------------------------------------------------------   /*主要功能:得到主机信息*/   string GHostInfo()     { return mysql_get_host_info( myData ) ;}   //--------------------------------------------------------------------------   /*主要功能:得到<a href="http://www.server-development.cn/go.php/tags/服务器/" target="_blank" title="http://www.server-development.cn/go.php/tags/服务器/" class="mykeyword">服务器</a>信息*/   string GServerInfo() { return mysql_get_server_info( myData ) ; }   //--------------------------------------------------------------------------   /*主要功能:得到服务器版本信息*/   int  GServerVer() {return mysql_get_server_version(myData) ; }   //--------------------------------------------------------------------------   /*主要功能:得到 当前连接的默认字符集*/   string  GCharacterSet() {return mysql_character_set_name(myData) ; } public: }; /******************************************************* *  Author:    huzhangyou 胡章优 *  Mail:    huzhangyou2002@gmail.com *  MSN:    huzhangyou2002@gmail.com *  Blog:    http://doserver.net *  Site:    http://jouhu.com *  QQ:      3803308 *  Create:    2008-09-16 *  Modify:    2008-09-18 *  Copyright:  吉大优狐科技开发公司 * ***********************************************************/ #endif // !defined(AFX_TMYSQL_H__04DDAF5E_8297_4B77_8003_E7402138FF52__INCLUDED_)

TMysql.cpp
// TMysql.cpp: implementation of the TMysql class. // ////////////////////////////////////////////////////////////////////// /******************************************************* *  Author:    huzhangyou 胡章优 *  Mail:    huzhangyou2002@gmail.com *  MSN:    huzhangyou2002@gmail.com *  Blog:    http://doserver.net *  Site:    http://jouhu.com *  QQ:      3803308 *  Create:    2008-09-16 *  Modify:    2008-09-18 *  Copyright:  吉大优狐科技开发公司 * ***********************************************************/ #pragma comment(lib,"libmysql.lib") #pragma comment(lib,"mysqlclient.lib") #pragma comment(lib,"mysys.lib") #include "stdafx.h" #include "TMysql.h" ////////////////////////////////////////////////////////////////////// // Construction/Destruction ////////////////////////////////////////////////////////////////////// TMysql::TMysql() {   Connected = false; } TMysql::~TMysql() {   if(Connected)     if(myData)       mysql_close( myData ); } /**************************************************** *****************************************************   主要功能:连接数据库   参数说明:   1 host 主机ip地址或者时主机名称   2 user 用户名   3 passwd 密码   4 db 欲连接的数据库名称   5 port 端口号   6 uinx 嵌套字   7 client_flag 客户连接参数   返回值: 0成功 -1 失败 ***************************************************** *****************************************************/ TMysql::TMysql(const string & server,const string & db,const string & user,const string& pass,int port,unsigned long client_flag) {   //   Connected = false;   //mysql_init(myData) 很重要   if((myData =mysql_init((MYSQL*)0)) && mysql_real_connect( myData, server.c_str(), user.c_str(), pass.c_str(), db.c_str(),port , NULL, client_flag ) )   {     if ( mysql_select_db( myData, db.c_str () ) < 0 ) //选择制定的数据库失败     {       mysql_close( myData ) ;     }else{       string tmp = "SET NAMES UTF8";       UQuery(tmp);       Connected = true;     }   }   else   {     mysql_close( myData ) ;//初始化mysql结构失败   }    } int TMysql::UQuery(const string& sql) {   if(Connected){     if(!mysql_real_query(myData,sql.c_str(),(unsigned long)sql.length()))     {       return (int)mysql_affected_rows(myData) ;//得到受影响的行数     }     else           {       return -1;     }//执行查询失败   }else{     return -2;   } }    string TMysql::OQuery(const string& sql) {   if(Connected){     MYSQL_RES * res ;     MYSQL_ROW row ;     if(!mysql_real_query( myData, sql.c_str (),(unsigned long)sql.length () ) )     {          res = mysql_store_result( myData ) ;//保存查询结果       row = mysql_fetch_row( res ) ;       mysql_free_result( res ) ;       return ((row[0]==NULL)||(!strlen(row[0])))?"-1":row[0];            }     else           {       return "-1";     }//执行查询失败   }else   {     return "-2";   } } // vector<vector<string> >& fieldData存储数据 比较浪费资源 但是是一种折中处理方法 int TMysql::NQuery(const string& sql,vector<string> & fieldName,vector<enum_field_types> &fieldType, vector<vector<string> >& fieldData) {   //   if(Connected)   {     int count,j;     if (!mysql_real_query( myData, sql.c_str () ,(unsigned long)sql.length ()) )//执行查询     {       //       MYSQL_RES * res ;       MYSQL_ROW row ;       MYSQL_FIELD * fd ;       res  = mysql_store_result( myData ) ;//保存查询结果       count = (int) mysql_num_rows( res ) ; //得到记录数量       j = mysql_num_fields( res ) ;//得到字段数量              for(int _i = 0 ; _i < j ; _i ++ ){         fd = mysql_fetch_field(res );         fieldName.push_back(fd->name);         fieldType.push_back(fd->type);       }       while ( row = mysql_fetch_row(res ))       {         vector<string> rowVec;         for(int _j = 0; _j < j ; _j ++)         {           //           rowVec.push_back(row[_j]);         }         fieldData.push_back(rowVec);       }       mysql_free_result( res ) ;       return count;     }else{       return -1;     }   }else   {     return -2;   } } int TMysql::CreateDB(const string& db){   //   if(Connected){     string temp ;     temp="CREATE DATABASE ";     temp+=db;     if(!mysql_real_query( myData,temp.c_str () ,(unsigned long)temp.length ()) )       return 0;     else           {       return -1;     }//执行查询失败   }else{     return -2;   } } int TMysql::DropDB(const string& db){   //   if(Connected){     string temp ;     temp="DROP DATABASE ";     temp+=db;     if(!mysql_real_query( myData,temp.c_str () ,(unsigned long)temp.length ()) )       return 0;     else           {       return -1;     }//执行查询失败   }else{     return -2;   } } int TMysql::Trans() {   if(Connected){     if(!mysql_real_query( myData, "START TRANSACTION" ,(unsigned long)strlen("START TRANSACTION")))     {       return 0;     }     else           {       return -1;     }//执行查询失败   }else{     return -2;   } } int TMysql::Commit() {   if(Connected){     if(!mysql_real_query( myData, "COMMIT",(unsigned long)strlen("COMMIT") ) )     {       return 0;     }     else           {       return -1;     }//执行查询失败   }else{     return -2;   } } int TMysql::Rollback() {   if(Connected){     if(!mysql_real_query( myData, "ROLLBACK",(unsigned long)strlen("ROLLBACK") ) )       return 0;     else           {       return -1;     }//执行查询失败   }else{     return -2;   } } /******************************************************* *  Author:    huzhangyou 胡章优 *  Mail:    huzhangyou2002@gmail.com *  MSN:    huzhangyou2002@gmail.com *  Blog:    http://doserver.net *  Site:    http://jouhu.com *  QQ:      3803308 *  Create:    2008-09-16 *  Modify:    2008-09-18 *  Copyright:  吉大优狐科技开发公司 * ***********************************************************/