mysql.cpp

一个简单的mysql c api的c++ wrapper库代码

#include "StdAfx.h"
#include ".\mysql.h"

CMySQL::CMySQL(void)
{
	myData = NULL;
}

CMySQL::~CMySQL(void)
{

}

BOOL CMySQL::OpenConnection(char* host , char *username , char *password )
{
	if(myData)
		CloseConection();

	myData=mysql_init((MYSQL*) 0);
	if(!mysql_real_connect(myData,host,username,password,NULL,MYSQL_PORT,NULL,0))
		return FALSE;

	return TRUE;
}

CString CMySQL::GetMySqlError()
{
	return mysql_error(myData);
}


BOOL CMySQL::CreateDataBase(char* name)
{
	if (myData)
	{
		if (mysql_create_db( myData, name ) > -1 ) 
		{
		  return TRUE;
		}		
	}

	return FALSE;

}

BOOL CMySQL::DropDataBase(char* nume)
{
	if (myData)
	{
		if (mysql_drop_db( myData, nume ) > -1 ) 
		{
		  return TRUE;
		}		
	}

	return FALSE;
	
}

BOOL CMySQL::SelectDatabase(char* dbf)
{
	if (myData)
	{
		if ( mysql_select_db( myData, dbf ) > -1 ) 
		{
		  return TRUE;
		}		
	}

	return FALSE;

}

BOOL CMySQL::DoQuery(char*szSQL)
{
	if(!myData)
		return FALSE;

	if (mysql_query(myData,szSQL)) 
	{
		return FALSE;
	}

	return TRUE;
}

MYSQL_RES * CMySQL::GetQueryResult()
{
	MYSQL_RES *result;
	result = mysql_store_result(myData);
	return result;
}

void CMySQL::FreeQueryResult(MYSQL_RES *result)
{
	mysql_free_result(result);
	result = NULL;
}

long CMySQL::GetQueryRowsNumber(MYSQL_RES *result)
{
	return mysql_num_rows(result);
}

MYSQL_ROW CMySQL::MySQLFatchResult(MYSQL_RES *result)
{
	return mysql_fetch_row(result);
}


void CMySQL::CloseConection()
{
	mysql_close(myData);	
	myData = NULL;
}