vc mysql连接与查询类.h

VC连接Mysql的类

#ifndef _Mysql_select_H
#define _Mysql_select_H
#include <windows.h>
#include <string.h>
#include "mysql.h"//良好的编程习惯最后引入mysql.h！
//#include "CDate.h"
#include <iostream>
using std::cout;
using std::endl;

class Select
{
private:
	MYSQL *conn;
public:
	char * data;
	Select():data("0")
	{
		conn = mysql_init((MYSQL*) 0);  
		if(conn!=NULL && mysql_real_connect(conn,"127.0.0.1","root","7112585","tushuguanli",3306,NULL,0))
		{
			mysql_query(conn,"set names 'gb2312'");
			if(!mysql_select_db(conn,"tushuguanli"))
			{
				cout<<"初始化成功！"<<endl;
				conn ->reconnect = 1;
			}
			else
				cout<<"初始化失败！"<<endl;
		}
	}
	
	Select(char * ip,char * id,char * pwd,char * db,int port)
	{
		conn = mysql_init((MYSQL*) 0);  
		if(conn!=NULL && mysql_real_connect(conn,ip,id,pwd,db,port,NULL,0))
		{
			mysql_query(conn,"set names 'gb2312'");
			if(!mysql_select_db(conn,db))
			{
				cout<<"初始化成功！"<<endl;
				conn ->reconnect = 1;
			}
			else
				cout<<"初始化失败！"<<endl;
		}
	}
	~Select()
	{
		mysql_close(conn);
	}
	///////////////////////////////////////////////
	void  Demand(const char * condition)
	{
		mysql_query(conn,condition);
		MYSQL_RES * recordSet = mysql_store_result(conn); 
		long j = mysql_num_fields(recordSet);
		MYSQL_ROW row;
		char *dd,*ee;
		int i=0;
		data=new char[10];
		strcpy(data,"");
		while( row = mysql_fetch_row(recordSet)) 
		{ 
			dd=new char[200];
			strcpy(dd,"");
			for(int l=0 ; l< j;l++) 
			{ 
				if(row[l]==NULL || !strlen(row[l])){}
				else 
				{
					strcat(dd,row[l]);	
					strcat(dd,"|");
				}
			} 
			i=strlen(data)+1;
			ee=data;
			data=NULL;
			data=new char[strlen(dd)+i+1];
			strcpy(data,ee);
			strcat(data,dd);
			strcat(data,"@");
			delete dd;
			delete ee;
		}
	}
	int Run(const char *str)
	{
		try
		{
			if(!mysql_query(conn,str))
				return 1;
			else
				return 2;
		}
		catch (...)
		{
			return 0;
		}
	}
	void Print()
	{
		cout<<data<<endl;
	}
};

#endif