当前位置:Gxlcms > mysql > [VC]ADO访问本地数据库应用

[VC]ADO访问本地数据库应用

时间:2021-07-01 10:21:17 帮助过:48人阅读

1、初始化 if(!AfxOleInit()){AfxMessageBox(_T(COM库初始化失败!));return FALSE;} 初始化方法二: CoInitialize() CoUninitialize() 2、导入msado15.dll(我是放在stdafx.h下) #import msado15.dllno_namespace rename(EOF,ADOEOF),rename(BOF,ADOBOF) 3

1、初始化

	if(!AfxOleInit())
	{
		AfxMessageBox(_T("COM库初始化失败!"));
		return FALSE;
	}

初始化方法二:

CoInitialize()
CoUninitialize()

2、导入msado15.dll(我是放在stdafx.h下)

#import "msado15.dll"no_namespace rename("EOF","ADOEOF"),rename("BOF","ADOBOF")


3、变量申明

	_ConnectionPtr m_pConnection;	//
	_RecordsetPtr m_pRecordset;

	CString m_strMdbName;	//数据库名称
	CString m_strMdbPath;//数据库所在路径
	CString m_strSQL;//sql语句

	CXmlDialog m_xmlDlg;//执行select语句时,将记录集保存

4、连接数据库

void CMyAdoDlg::OnBnClickedLink()
{
	// TODO: 在此添加控件通知处理程序代码
	if(m_strMdbName.IsEmpty())
	{
		AfxMessageBox(_T("请选择数据库!"));
		return;
	}


	//if(m_pConnection->GetState()) //error:如果对象都没创建,不可以GetState
	if(m_pConnection != NULL)
	{
		if(m_pConnection->GetState())
			AfxMessageBox(_T("数据库已连接!"));
		else
			AfxMessageBox(_T("数据连接对象已创建,但未成功连接数据库!"));
		return ;
	}

	try{
		
		HRESULT hr;
		//hr = m_pConnection.CreateInstance("ADODB.Connection");	//ok
		hr = m_pConnection.CreateInstance(__uuidof(Connection));
		if(SUCCEEDED(hr))
		{
			CString strConnection = _T("Provider='Microsoft.Jet.OLEDB.4.0';Data Source='");
			strConnection += m_strMdbPath;
			strConnection += "'";
			_bstr_t bstrConnection = (LPTSTR)(LPCTSTR)strConnection;
			m_pConnection->ConnectionTimeout = 10;	//设置连接时间
			m_pConnection->Open(bstrConnection,"","",adModeUnknown);
			
			AfxMessageBox(_T("连接数据库成功!"));
		}
	}
	catch(_com_error& e)
	{
		AfxMessageBox(e.Description());
	}
	
	
}


备注:
1、m_pConnection.CreateInstance(__uuidof(Connection));为什么用.操作符,而不是->。虽然m_pConnection是指针,但CreateInstance是指针本身的函数,而不是指针所指向的对象的函数。
2、m_pConnection != null 不代表连接了数据库


5、断开数据库

void CMyAdoDlg::OnBnClickedDisconnect()
{
	// TODO: 在此添加控件通知处理程序代码
	if(m_pConnection == NULL)
	{
		AfxMessageBox(_T("未创建数据库对象实例!"));
		return;
	}
	else if(!m_pConnection->GetState())
	{
		AfxMessageBox(_T("已创建数据库对象实例,但未连接数据库!"));
		return;
	}
	
	try{
		m_pConnection->Close();

		/*m_pConnection->Release();*/
		m_pConnection = NULL;	//上面的release不调用,因为重载的operator=会调用Release:
		/*
			template<> _com_ptr_t& operator=(Interface* pInterface) throw()
			{
			if (m_pInterface != pInterface) {
			Interface* pOldInterface = m_pInterface;

			m_pInterface = pInterface;

			_AddRef();

			if (pOldInterface != NULL) {
			pOldInterface->Release();
			}
			}

			return *this;
			}
		*/
		AfxMessageBox(_T("成功断开数据库!"));
	}
	catch(_com_error& e)
	{
		AfxMessageBox(e.Description());
	}
}

备注:
1、
/*m_pConnection->Release();*/
m_pConnection = NULL;
让这两条语句同事调用,调试的时候,老是产生中断,原因是重载了=,重载函数中有调用Release()



6、SQL语句执行

/*
	SQL:
			create table employee (
			name nvarchar(20),
			sex text(1),
			age int
			);



			drop table employee;


		insert into employee values ('xinlang','男',24);
		insert into employee values ('ximei','女',25);

	select * from employee;
*/
void CMyAdoDlg::OnBnClickedExcute()
{
	// TODO: 在此添加控件通知处理程序代码
	UpdateData();
	if(m_strSQL.IsEmpty())
	{
		AfxMessageBox(_T("请填写SQL语句!"));
		return;
	}
	
	if(m_pConnection == NULL || !m_pConnection->GetState())
	{
		AfxMessageBox(_T("请连接数据库!"));
		return;
	}
	
	if(m_pRecordset != NULL)
	{
		if(m_pRecordset->GetState())
			m_pRecordset->Close();
		/*m_pRecordset->Release();*/
		m_pRecordset = NULL;
	}

	try{
		HRESULT hr;
		hr = m_pRecordset.CreateInstance("adodb.recordset");

		if(SUCCEEDED(hr))
		{
			m_pRecordset->Open(_bstr_t(m_strSQL),_variant_t((IDispatch*)m_pConnection),adOpenDynamic,adLockOptimistic,adCmdText);
				

			//如果SQL语句执行的是insert into、delete等不返回记录集的操作,那么m_pRecordset执行完open后是关闭的,
			//此时再用m_pRecordset执行操作,将会提示“对象关闭时,不允许操作!”,如果m_pRecordset执行的是select,
			//执行完后m_pRecordset未关闭,因此可以再执行save操作
	
			//m_strSQL.MakeUpper();
			//if(-1 != m_strSQL.Find(_T("SELECT")))
			if(m_pRecordset->GetState())
			{
				_variant_t vtSave;
				_bstr_t bstr;
				
				 CString strSaveFilePath = GetSavefilePath();
				SavefileHandle(strSaveFilePath);
				m_xmlDlg.SetXmlFilePath(strSaveFilePath);

				bstr = strSaveFilePath;
				vtSave.vt = VT_BSTR;
				vtSave.bstrVal  = bstr.copy();
				
//  				//void PutCollect (const _variant_t & Index,const _variant_t & pvar );
// 				m_pRecordset->PutCollect("name",_bstr_t("asani"));	//备注:用来修改当前记录的信息
// 				m_pRecordset->PutCollect("sex",_bstr_t("中"));

// 				//m_pRecordset->MoveLast();
// 				m_pRecordset->PutCollect("name",_bstr_t("nihao"));	//备注:用来修改当前记录的信息
// 				m_pRecordset->PutCollect("age",_bstr_t("100"));

				//inline HRESULT _Recordset::Save ( const _variant_t & Destination, enum PersistFormatEnum PersistFormat )
				m_pRecordset->Save(vtSave,adPersistXML);	//将所取的信息保存至vtSave

				int state = m_pRecordset->GetState();
				while(!m_pRecordset->ADOEOF)
				{
					_variant_t vr;
					//vr.vt = VT_LPSTR;//error 不能赋值,赋值则出错
					//_variant_t GetCollect (const _variant_t & Index );
					//vr = m_pRecordset->GetCollect("name");	//ok
					//vr = m_pRecordset->GetCollect("sex");		//ok
					vr = m_pRecordset->GetCollect("age");
					m_pRecordset->MoveNext();
				}
			}
			else
			{
				AfxMessageBox(_T("执行SQL成功!"));
			}		
		}
	}
	catch(_com_error& e)
	{
		AfxMessageBox(e.Description());
	}

}
7、保存文件的处理(保存为XML)
//获取保存文件的路径
CString CMyAdoDlg::GetSavefilePath()
{
	CString strSaveFile;
	if(!m_strMdbPath.IsEmpty())
	{
		strSaveFile = m_strMdbPath;
		strSaveFile = strSaveFile.Left(1 + strSaveFile.ReverseFind('\\'));
		strSaveFile += DEFAULT_SAVE_XML_NAME;
	}

	return strSaveFile;
	
}

//保存文件的处理
BOOL CMyAdoDlg::SavefileHandle(CString& strSaveFilePath)
{
	if(PathFileExists(strSaveFilePath))
	{
		CString strNewFile = strSaveFilePath;
		strNewFile += _T(".bak");
		if(PathFileExists(strNewFile))
			DeleteFile(strNewFile);
		CFile::Rename(strSaveFilePath,strNewFile);
	}

	return TRUE;
}

#define DEFAULT_MDB_NAME _T("shujuku.mdb")
#define DEFAULT_SAVE_XML_NAME _T("SaveData.xml")

人气教程排行