工控编程吧

标题: 上位机MFC如何使用ADO打开和关闭记录集 [打印本页]
作者: qq263946146    时间: 2019-8-9 11:06
标题: 上位机MFC如何使用ADO打开和关闭记录集
首先是引入ADO动态库
#import "c:\program files\common files\system\ado\msado15.dll"\
                no_namespace\
                rename("EOF", "adoEOF")

然后是定义智能指针变量与函数
_ConnectionPtr m_pConnection;
        _RecordsetPtr m_pRecordset;
BOOL OpenDatabase(LPCTSTR lpszConnect, long nOptions=adConnectUnspecified);
BOOL CloseDatabase();
        BOOL OpenRecordset(LPCTSTR lpszSource, long nCursorType=adOpenDynamic,
                long nLockType=adLockOptimistic, long nOptions=adCmdText);
        BOOL CloseRecordset();

再初始化变量
        if (!SUCCEEDED(m_pConnection.CreateInstance(__uuidof(Connection))))
        {
                m_pConnection = NULL;
                TRACE(_T("Database CreateInstance failed"));
        }
        if (!SUCCEEDED(m_pRecordset.CreateInstance(__uuidof(Recordset))))
        {
                m_pRecordset = NULL;
                TRACE(_T("Recordset CreateInstance Failed!"));
        }
        //打开数据库
        CString strConnect = _T("Provider=Microsoft.Jet.OLEDB.4.0;Data Source= Demo.mdb");
        if (!OpenDatabase(strConnect))
        {
                AfxMessageBox(_T("数据库打开失败。"));
        }

这样就可以使用按钮调用我们定义的函数了。

  2. void CGkbc8Dlg::OnButton1()
  3. {
  4.         if (m_pRecordset->State & adStateOpen)
  5.         {
  6.                 AfxMessageBox(_T("记录集已经打开。"));
  7.                 return;
  8.         }

  10.         CString strSource = _T("SELECT * FROM DemoTable");
  11.         if (OpenRecordset(strSource))
  12.         {
  13.                 AfxMessageBox(_T("记录集打开成功。"));
  14.         }
  15.         else
  16.         {
  17.                 AfxMessageBox(_T("记录集打开失败。"));
  18.         }
  19. }

  21. void CGkbc8Dlg::OnButton2()
  22. {
  23.         if (!(m_pRecordset->State & adStateOpen))
  24.         {
  25.                 AfxMessageBox(_T("记录集未打开。"));
  26.                 return;
  27.         }

  29.         if (CloseRecordset())
  30.         {
  31.                 AfxMessageBox(_T("记录集关闭成功。"));
  32.         }
  33.         else
  34.         {
  35.                 AfxMessageBox(_T("记录集关闭失败。"));
  36.         }
  37. }
复制代码
下面是我们自定义的4个函数
  1. BOOL CGkbc8Dlg::OpenDatabase(LPCTSTR lpszConnect, long nOptions)
  2. {
  3.         ASSERT(m_pConnection != NULL);
  4.         ASSERT(lpszConnect != NULL);
  5.         ASSERT(AfxIsValidString(lpszConnect));
  6.        
  7.         //打开数据库连接
  8.         try
  9.         {
  10.                 return SUCCEEDED(m_pConnection->Open(_bstr_t(lpszConnect),
  11.                         _T(""), _T(""), nOptions));
  12.         }
  13.         catch (_com_error& e)
  14.         {
  15.                 TRACE(_T("%s\n"), e.ErrorMessage());
  16.                 return FALSE;
  17.         }
  18. }
  19. BOOL CGkbc8Dlg::CloseDatabase()
  20. {
  21.         ASSERT(m_pConnection != NULL);

  23.         //关闭数据库连接
  24.         try
  25.         {
  26.                 if (m_pConnection->State & adStateOpen)
  27.                 {
  28.                         return SUCCEEDED(m_pConnection->Close());
  29.                 }
  30.                 else
  31.                 {
  32.                         return TRUE;
  33.                 }
  34.         }
  35.         catch (_com_error& e)
  36.         {
  37.                 TRACE(_T("%s\n"), e.ErrorMessage());
  38.                 return FALSE;
  39.         }
  40. }

  42. BOOL CGkbc8Dlg::OpenRecordset(LPCTSTR lpszSource, long nCursorType,
  43.                                                          long nLockType, long nOptions)
  44. {
  45.         ASSERT(m_pConnection != NULL);
  46.         ASSERT(m_pRecordset != NULL);
  47.         ASSERT(lpszSource != NULL);
  48.         ASSERT(AfxIsValidString(lpszSource));

  50.         //打开记录集
  51.         try
  52.         {
  53.                 return (SUCCEEDED(m_pRecordset->Open(_variant_t(lpszSource),
  54.                                                                                 m_pConnection.GetInterfacePtr(),
  55.                                                                                 (CursorTypeEnum)nCursorType,
  56.                                                                                 (LockTypeEnum)nLockType,
  57.                                                                                 nOptions)));
  58.         }
  59.         catch(_com_error e)
  60.         {
  61.                 TRACE(_T("%s\n"), e.ErrorMessage());
  62.                 return FALSE;
  63.         }
  64. }

  66. BOOL CGkbc8Dlg::CloseRecordset()
  67. {
  68.         ASSERT(m_pRecordset != NULL);

  70.         //关闭记录集
  71.         try
  72.         {
  73.                 if (m_pRecordset->State & adStateOpen)
  74.                 {
  75.                         return SUCCEEDED(m_pRecordset->Close());
  76.                 }
  77.                 else
  78.                 {
  79.                         return TRUE;
  80.                 }
  81.         }
  82.         catch (_com_error e)
  83.         {
  84.                 TRACE(_T("%s\n"), e.ErrorMessage());
  85.                 return FALSE;
  86.         }
  87. }
复制代码
最重要的，记得初始化COM库。
  1. if (!SUCCEEDED(CoInitialize(NULL)))
  2.         {
  3.                 ::AfxMessageBox(_T("Failed to initialize COM!"));
  4.                 return FALSE;
  5.         }
复制代码


这里分享一个例程
(, 下载次数: 0)