通过 ADO 更新和添加数据库记录

• 下载源代码 - 113.9 Kb

引言

这篇文章将带您进入数据库的神秘世界，探索OLE DB和ODBC的一些基本概念。我为什么写这篇文章？…… 仅仅是为了与程序员分享知识，同时，在我开发第一个集成数据库的C++应用程序时，我遇到了许多与数据库连接及其工作相关的难题。因此，我希望阅读完本文后，程序员能够对C++中的数据库风险有一个初步的认识和概念。您将在这里找到OLE DB和ODBC两个API的介绍以及一些代码片段。

背景

本文不需要任何特殊的背景知识，您只需要了解数据库概念，并熟悉VC++和MFC环境。如果您能进一步深入学习它们会更好。

https://codeproject.org.cn/database/connectionstrings.asp

https://codeproject.org.cn/database/oledbconsumer1.asp

使用代码

当您通读全文后，会发现它非常精妙且概念性强。我希望那时您能轻松理解代码片段及其用法。为了方便您，我附上了一些可用于操作数据库的代码和算法，以及本文的PPT格式。您可以下载并尽情享用。

VC++中访问数据库的技术

OLE DB & ODBC

什么是ADO？

ADO对象

连接对象

Error Object (错误对象)

命令对象

参数对象

Recordset Object (记录集对象)

Field Object (字段对象)

使用ADO ActiveX控件

导入ADO DLL

#define INITGUID 
#import "C:\Program Files\CommonFiles\System\ADO\msado15.dll"     rename_namespace("ADOCG")      
rename("EOF", "EndOfFile") 
   using namespace ADOCG; 
   #include "icrsint.h" 

连接数据库

创建数据库连接

Declare a Connection object pointer, _ConnectionPtr 

_ConnectionPtr pConn; pConn.CreateInstance(__uuidof(Connection)); 

pConn->Open(L"Provider=MSDASQL.1;DataSource=TYVCDB", L"", L"",adOpenUnspecified); 

执行命令并检索数据

_CommandPtr pCmd;
pCmd.CreateInstance(__uuidof(Command)); 
pCmd->ActiveConnection = pConn; 

pCmd->CommandText = "Select * from Addresses"; 

1)     _RecordsetPtr pRs; 
    pRs = pCmd->Execute(); 

2)    _RecordsetPtr pRs; pRs.CreateInstance(__uuidof(Recordset));
     pRs->PutRefSource(pCmd); 


// Create the variant NULL 
_variant_t vNull; 
vNull.vt = VT_ERROR;
vNull.scode = DISP_E_PARAMNOTFOUND;
// Open the recordset 
pRs->Open(vNull, vNull,    adOpenDynamic,adLockOptimistic,    adCmdUnknown); 

另一种方法可以用很少的代码完成前面所有的任务：

_RecordsetPtr pRs;
 pRs.CreateInstance(__uuidof(Recordset));
pRs->Open(_T("Provider=MSDASQL.1;Data Source=TYVCDB"), _T("select * from Addresses"),  
adOpenDynamic, adLockOptimistic, adCmdUnknown); 

导航Recordset

访问字段值

1)Retreive values into a variant and then convert them
    _variant_t vName; 
    CString strName; 
    vName = pRs-> GetCollect(_variant_t("Name"));
    vName.ChangeType(VT_BSTR); strName = vName.bstrVal; 

class CCustomRs : public CADORecordBinding { 
    BEGIN_ADO_BINDING(CCustomRs) 
     ADO_FIXED_LENGTH_ENTRY (1, adInteger, m_ID, IDStatus,     FALSE)
     ADO_VARIABLE_LENGTH_ENTRY2(2, adVarChar, m_Name, sizeof(m_Name), NameStatus, TRUE)  
ADO_FIXED_LENGTH_ENTRY(3, adDate, m_Birthdate, BirthdateStatus, TRUE) 
    END_ADO_BINDING() 
  public: 
        LONG m_ID; 
    ULONG IDStatus; 
        CHAR m_Name[20]; 
        ULONG NameStatus; 
        DATE m_Birthdate; 
        ULONG BirthdateStatus;  
  }; 

IADORecordBinding接口方法

if (FAILED(pRs->QueryInterface(__uuidof(IADORecordBinding), (LPVOID *)&Rs)))
    _com_issue_error(E_NOINTERFACE); Rs->BindToRecordset(&m_RecSet); 

宏

更新记录

CString strBlank = " ";
COleDateTime dtBlank;
m_RecSet.m_ID = 0; strcpy(m_RecSet.m_Name, (LPCTSTR)strBlank);
m_RecSet.m_dtBirthdate =  (DATE)dtBlank;
Rs->AddNew(&m_RecSet);