C++ 读取MDB数据库

admin

1. /// <summary>
2. /// 读取MDB
3. /// </summary>
4. /// <param name="mdbMpPath">MDB路径</param>
5. /// <param name="strSql">sql语句</param>
6. /// <param name="zddz"></param>
7. void CMyPalette1ChildDlg::ReadMDB(const CString& mdbMpPath, const CString& strSql, std::map<CString, CString>& zddz)
8. {
9.         if (!AfxOleInit())//这就是初始化COM库
10.         {
11.                 AfxMessageBox(L"OLE初始化出错!");
12.                 return;
13.         }
14.         _ConnectionPtr m_pConnection;
16.         _RecordsetPtr m_pRecordset;
18.         //_CommandPtr m_pCommand;
20.         CString strSQL; //配置初始连接串
21.         strSQL = "Provider=Microsoft.ACE.OLEDB.12.0;Data Source=";
22.         strSQL += mdbMpPath;
23.         strSQL += ";";
24.         HRESULT hr;
25.         try
26.         {
27.                 hr = m_pConnection.CreateInstance("ADODB.Connection");///创建Connection对象
28.                 if (SUCCEEDED(hr))
29.                 {
30.                         hr = m_pConnection->Open((_bstr_t)strSQL, "", "", adModeUnknown);///连接数据库
31.                         ///上面一句中连接字串中的Provider是针对ACCESS2000环境的，对于ACCESS97,需要改为:Provider=Microsoft.Jet.OLEDB.3.51; }
32.                         m_pRecordset.CreateInstance("ADODB.Recordset");
33.                         try
34.                         {
35.                                 //打开数据库
36.                                 m_pRecordset->Open((_bstr_t)strSql,
37.                                         m_pConnection.GetInterfacePtr(),//或使用_variant_t((IDispatch*)theApp.m_pConnection,true),，但需要extern声明theApp;
38.                                         adOpenDynamic,
39.                                         adLockOptimistic,
40.                                         adCmdText);
41.                                 //遍历读取
43.                                 while (!m_pRecordset->adoEOF)//adoEOF判断数据库指针是否已经到结果集末尾；BOF判断是否在第一条记录前面
44.                                 {
45.                                         auto key = m_pRecordset->GetCollect("类型");
46.                                         //这里已经读到当前记录的ID，需要进行非空等判断，非空之后就可以处理，比如添加到列表框等。
47.                                         auto value = m_pRecordset->GetCollect("值");
48.                                         zddz[key] = value;
49.                                         //....
50.                                         m_pRecordset->MoveNext();
51.                                 }
53.                                 m_pRecordset->Close();//关闭记录集
54.                                 //m_pRecordset->Release();
55.                         }
56.                         catch (_com_error error)
57.                         {
58.                                 if (m_pRecordset->State) {
59.                                         m_pRecordset->Close();//关闭记录集
60.                                         //m_pRecordset->Release();
61.                                 }
62.                                 CString errorMessage;
63.                                 errorMessage.Format(L"%s", (LPTSTR)error.Description());
64.                                 AfxMessageBox(errorMessage);
65.                                 return;
66.                         }
67.                         if (m_pConnection->State)//如果连接有效
68.                         {
69.                                 m_pConnection->Close();
70.                                 //m_pConnection->Release();
71.                         }
72.                 }
73.         }
74.         catch (_com_error e)///捕捉异常
75.         {
76.                 if (m_pRecordset->State) {
77.                         m_pRecordset->Close();//关闭记录集
78.                         //m_pRecordset->Release();
79.                 }
80.                 if (m_pConnection->State)//如果连接有效
81.                 {
82.                         m_pConnection->Close();
83.                         //m_pConnection->Release();
84.                 }
85.                 CString errormessage;
86.                 errormessage.Format(L"连接数据库失败!\r\n错误:%s!", e.ErrorMessage());
87.                 AfxMessageBox(errormessage);///显示错误信息
88.         }
89. }

复制代码