connection.cpp

来自「天之炼狱1服务器端源文件游戏服务端不完整」· C++ 代码 · 共 210 行

//////////////////////////////////////////////////////////////////////
//
// File Name	: Connection.cpp
// Written by	: [e-mail]
// Description	: 目池记 努贰胶 备泅
//
//////////////////////////////////////////////////////////////////////

// include files
#include "Connection.h"
#include "Statement.h"

//////////////////////////////////////////////////////////////////////
//
// constructor
//
// 单捞磐 海捞胶客 楷搬窍绊, 单捞磐海捞胶甫 急琶茄促.
// 抗寇甫 带瘤绰 何盒篮 荐沥秦具 茄促.
//
//////////////////////////////////////////////////////////////////////

Connection::Connection ()
	throw ( Error )
: m_bConnected(false), m_bBusy(false)
{
	__BEGIN_TRY

	m_Mutex.setName("Connection");

	// MYSQL 按眉甫 檬扁拳茄促.
	if ( mysql_init(&m_Mysql) == NULL ) {
		throw Error( mysql_error(&m_Mysql) );
	}

	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
//
// *CAUTION*
//
// connect()甫 龋免且 锭 port 甫 疙矫窍瘤 臼阑 版快, 叼弃飘蔼牢 0 捞 荤侩登哥
// 捞锭 MYSQL狼 叼弃飘 器飘啊 荤侩等促. 弊犯瘤父, 焊救阑 困秦辑 MYSQL阑 促弗
// 器飘俊促啊 剁况出具 且 巴捞促. 蝶扼辑, 器飘甫 瘤沥且 鞘夸啊 乐促.
//
//////////////////////////////////////////////////////////////////////

Connection::Connection ( string host , string db , string user , string password , uint port )
	throw ( SQLConnectException , Error )
: m_bConnected(false), m_Host(host), m_Port(port), m_Database(db), m_User(user), m_Password(password)
{
	__BEGIN_TRY

	m_Mutex.setName("Connection");
		
	// MYSQL 按眉甫 檬扁拳茄促.
	if ( mysql_init(&m_Mysql) == NULL )
		throw Error( mysql_error(&m_Mysql) );

	// 官肺 楷搬阑 矫档茄促.
	connect( m_Host , m_Database , m_User , m_Password , m_Port );
	
	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
//
//	destructor
//
//////////////////////////////////////////////////////////////////////

Connection::~Connection() 
	throw ( Error )
{
	__BEGIN_TRY
		
	// 楷搬登绢 乐阑 版快, 楷搬阑 谗绰促.
    if ( m_bConnected ) {
		close();
    }
	
	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
//
// connect()	
//
// Connection 按眉啊 积己瞪 锭, 绢叼俊 楷搬且 瘤 舅瘤 给且 版快
// 老窜 default constructor 甫 荤侩秦辑 按眉甫 积己茄 促澜, 
// 楷搬且 锭 蔼阑 罐酒辑 郴何 单捞磐糕滚甸阑 檬扁拳茄 饶 楷搬茄促. 
//
// *CAUTION*
//
// connect()甫 龋免且 锭 port 甫 疙矫窍瘤 臼阑 版快, 叼弃飘蔼牢 0 捞 荤侩登哥
// 捞锭 MYSQL 狼 叼弃飘 器飘啊 荤侩等促. 弊犯瘤父, 焊救阑 困秦辑 MYSQL阑 促弗
// 器飘俊促啊 剁况出具 且 巴捞促.
//
// 叼弃飘 颇扼固磐甫 荤侩秦具 窍扁 锭巩俊, 器飘 颇扼固磐啊 盖 第肺 艾促.. *_*;
//
// ex> Connection conn;
//     conn.connect( "vampire.ewestsoft.com" , "bbs" , "bbsuser" , "bbspassword" );
//
//////////////////////////////////////////////////////////////////////

void Connection::connect ( string host , string db , string user , string password , uint port )
	throw ( SQLConnectException )
{
	__BEGIN_TRY

	m_Host = host;
	m_Port = port;
	m_Database = db;
	m_User = user;
	m_Password = password;

	connect();

	__END_CATCH
}
	
//////////////////////////////////////////////////////////////////////
//
// connect()	
//
// 积己磊俊辑 流立  沥焊甫 涝仿罐阑 版快, 官肺 捞 皋筋靛甫 龋免秦辑
// 楷搬阑 矫档茄促.
//
//////////////////////////////////////////////////////////////////////

void Connection::connect ()
	throw ( SQLConnectException )
{
	__BEGIN_TRY
		
	// 楷搬阑 窍妨备 窍绰单 捞固 楷搬捞 登绢乐促搁 俊矾促.
	if ( m_bConnected ) 
	{
		// 捞凡 版快, 楷搬篮 摧酒 林绊 抗寇甫 带廉具 且 巴捞促.
		close();

		throw SQLConnectException("Already Connected"); 
	}

	//--------------------------------------------------
	// 俊矾啊 积扁绰瘤 眉农秦具 窃...
	//--------------------------------------------------
	m_bConnected = ( mysql_real_connect( &m_Mysql, m_Host.c_str(), m_User.c_str(), m_Password.c_str(), m_Database.c_str(), m_Port , 0, 0 ) != NULL );
	//cout << "Connection Calls~~~" << endl;
	
	// 楷搬惑怕啊 酒聪扼搁 俊矾促.
	if( ! m_bConnected ) 
	{
		throw SQLConnectException( mysql_error(&m_Mysql) );
	}
	
	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
//	
//	close()
//
//	楷搬阑 谗绰促.
//
//////////////////////////////////////////////////////////////////////

void Connection::close () 
	throw ( SQLConnectException , Error )
{
	__BEGIN_TRY
		
    if( ! m_bConnected ) 
	{
		throw SQLConnectException("Not Connected");
    }
	
	// void 捞骨肺 公矫.. - -;
    mysql_close( &m_Mysql );

	m_bConnected = false;
	
	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
//	
//	createStatement
//
//	货肺款 Statement 按眉甫 父甸绢 弊 按眉狼 器牢磐甫 府畔茄促.
//
//////////////////////////////////////////////////////////////////////

Statement * Connection::createStatement ()
	throw ()
{
	__BEGIN_TRY
		
	// 货肺款 Statement 按眉甫 父电促.
	Statement * pStatement = new Statement();
	
	// 父电 按眉狼 目池记 蔼阑 捞 目池记 按眉肺 窍绊..
	pStatement->setConnection(this);
	
	// 府畔茄促.
	return pStatement;
	
	__END_CATCH
}