_connection.cpp

酒店管理系统的毕业设计,用VC编的,功能有限

// _Connection.cpp: implementation of the C_Connection class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "HotelManageSys.h"
#include "_Connection.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

C_Connection::C_Connection()
{

}

C_Connection::~C_Connection()
{

}

BOOL C_Connection::open(CString DSN)
{
	try
	{
		database.Open(DSN,FALSE,FALSE,_T("ODBC;"),TRUE);
        rs = new CRecordset(&database);
	}catch(CDBException*   e)   
	{   
		AfxMessageBox("数据库操作失败!!!!");   
		delete e;  
		return FALSE;   
	} 
	return TRUE;
}

void C_Connection::close()
{
	if(rs!=NULL)
	{
		delete rs;
		rs = NULL;
	}
	if(database.IsOpen())
	{
		database.Close();
	}
}

BOOL C_Connection::ExcuteSql(CString sql) 
{
	try
	{
	//	CRecordset rc(&database);
		if(rs->IsOpen())
			rs->Close();
	 	rs->Open(CRecordset::forwardOnly, sql) ;
     //  database.ExecuteSQL(sql);
	}catch(CDBException*   e)  
	{
		AfxMessageBox("数据库操作失败!!!!");   
		delete e;
		return FALSE; 
	}catch(CMemoryException*   e)  
	{
		AfxMessageBox("数据库操作失败!!!!");   
		delete e;
		return FALSE; 
	}
	return TRUE;
}

BOOL C_Connection::WriteSql(CString sql)
{
	try
	{
       database.ExecuteSQL(sql);
	}catch(CDBException*   e)  
	{
		AfxMessageBox("数据库操作失败!!!!");   
		delete e;
		return FALSE; 
	}catch(CMemoryException*   e)  
	{
		AfxMessageBox("数据库操作失败!!!!");   
		delete e;
		return FALSE; 
	}
	return TRUE ;
}