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;
    
15. 
    
16.         _RecordsetPtr m_pRecordset;
    
17. 
    
18.         //_CommandPtr m_pCommand;
    
19. 
    
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.                                 //遍历读取
    
42. 
    
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.                                 }
    
52. 
    
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. }

复制代码