工控编程吧

标题: 上位机MFC如何使用ADO在数据库中访问记录 [打印本页]
作者: qq263946146    时间: 2019-8-9 11:55
标题: 上位机MFC如何使用ADO在数据库中访问记录
和前面例程一样，也是初始化COM库，加载ODA库。        if (!SUCCEEDED(CoInitialize(NULL)))
        {
                ::AfxMessageBox(_T("Failed to initialize COM!"));
                return FALSE;
        }


#import "c:\program files\common files\system\ado\msado15.dll"\
                no_namespace\
                rename("EOF", "adoEOF")

添加自定义数据库变量与函数
  1. _ConnectionPtr m_pConnection;
  2.         _RecordsetPtr m_pRecordset;
  3.         BOOL OpenDatabase(LPCTSTR lpszConnect, long nOptions=adConnectUnspecified);
  4.         BOOL CloseDatabase();
  5.         BOOL OpenRecordset(LPCTSTR lpszSource, long nCursorType=adOpenDynamic,
  6.                           long nLockType=adLockOptimistic, long nOptions=adCmdText);
  7.         BOOL CloseRecordset();
复制代码


  2. BOOL CGkbc8Dlg::OpenDatabase(LPCTSTR lpszConnect, long nOptions)
  3. {
  4.         ASSERT(m_pConnection != NULL);
  5.         ASSERT(lpszConnect != NULL);
  6.         ASSERT(AfxIsValidString(lpszConnect));
  7.        
  8.         //打开数据库连接
  9.         try
  10.         {
  11.                 return SUCCEEDED(m_pConnection->Open(_bstr_t(lpszConnect),
  12.                         _T(""), _T(""), nOptions));
  13.         }
  14.         catch (_com_error& e)
  15.         {
  16.                 TRACE(_T("%s\n"), e.ErrorMessage());
  17.                 return FALSE;
  18.         }
  19. }

  21. BOOL CGkbc8Dlg::CloseDatabase()
  22. {
  23.         ASSERT(m_pConnection != NULL);

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

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

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

  68. BOOL CGkbc8Dlg::CloseRecordset()
  69. {
  70.         ASSERT(m_pRecordset != NULL);

  72.         //关闭记录集
  73.         try
  74.         {
  75.                 if (m_pRecordset->State & adStateOpen)
  76.                 {
  77.                         return SUCCEEDED(m_pRecordset->Close());
  78.                 }
  79.                 else
  80.                 {
  81.                         return TRUE;
  82.                 }
  83.         }
  84.         catch (_com_error e)
  85.         {
  86.                 TRACE(_T("%s\n"), e.ErrorMessage());
  87.                 return FALSE;
  88.         }
  89. }
复制代码
再添加控件，一并初始化数据库与控件
  1. if (!SUCCEEDED(m_pConnection.CreateInstance(__uuidof(Connection))))
  2.         {
  3.                 m_pConnection = NULL;
  4.                 TRACE(_T("Database CreateInstance failed"));
  5.         }

  7.         if (!SUCCEEDED(m_pRecordset.CreateInstance(__uuidof(Recordset))))
  8.         {
  9.                 m_pRecordset = NULL;
  10.                 TRACE(_T("Recordset CreateInstance Failed!"));
  11.         }

  13.         //打开数据库
  14.         CString strConnect = _T("Provider=Microsoft.Jet.OLEDB.4.0;Data Source= Demo.mdb");
  15.         if (!OpenDatabase(strConnect))
  16.         {
  17.                 AfxMessageBox(_T("数据库打开失败。"));
  18.                 return false;
  19.         }

  21.         //打开记录集
  22.         CString strSource = _T("SELECT * FROM DemoTable");
  23.         if (!OpenRecordset(strSource))
  24.         {
  25.                 AfxMessageBox(_T("记录集打开失败。"));
  26.                 return false;
  27.         }

  29.         //初始化ListCtrl
  30.         CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST);
  31.         pListCtrl->SetExtendedStyle(LVS_EX_FULLROWSELECT | LVS_EX_GRIDLINES);
  32.         pListCtrl->InsertColumn(1, _T("序号"), LVCFMT_CENTER, 80);
  33.         pListCtrl->InsertColumn(2, _T("姓名"), LVCFMT_CENTER, 100);
  34.         pListCtrl->InsertColumn(3, _T("年龄"), LVCFMT_CENTER, 100);
复制代码


(, 下载次数: 2)