数据库ODBC

1> 设置数据源，控制面板----管理工具------用户SDN----添加----添加所用的驱动-----数据源

名-----数据库选择-------找到设置好的数据库文件。例如：Access.mdb

ADO数据库：

ADO对象包括：连接对象Connection Object、命令对象Command Object、记录集对象 RecordSet Object、字段对象Field Object、记录对象Record Object、错误对象Error Object、参数对象Parameter Object、属性对象Property Object、流对象Stream Object 其中连接对象、命令对象、记录集对象是最重要的

ADO的引入：

需要在StdAfx.h文件的末尾加入下面的语句：#import “C:\\program files\\common files\\system\\ado\\msado15.dll” no_namespace rename(“EOF”,”adoEOF”)

同时在编译时系统会生成msado15.tlh,ado15.tli两个C++头文件来定义数据库

数据库连接： 定义连接对象

_ConnectionPtr m_pConnection; _RecordSetPtr m_pRecordset _CommandPtr m_pCommand

实例化:m_pConnection.CreateInstance(_uuidof(Connection)); M_pRecordSet.CreateInstance(_uuidof(Recordset)); M_pCommand.CreateInstance(ADODB.COMMAND); 连接数据库：try { _bstr_t strConnect = “driver = {SQL Server};Server = 127.0.0.1;DATABASE = workerdb;UID = Jack;PWD = Jack”; M_pConnection ->Open(strConnect,””,””,-1); } Catch(_com_error e) { MessageBox(NULL,e.ErrorMessage(),”Error”,MB_OK); }

查询记录：

可以通过Open方法来进行记录的查询，函数原型如下 HRESULT Recordset15::Open() Try { Cstring strSql = “select * from worder_information”; BSTR bstrSQL = strSql.AllocSysString(); M_pRecordset –>Open(bstrSQL,(Idispatch *)m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);

Int nID;

Cstring strName; Int nPay;

Int nIndex = 0; //遍历记录

While(!m_pRecordset ->adoEOF) { nIndex ++; _variant_t varValue; varValue = m_pRecordset ->Fields ->GetItem(“wordID”)->Value; if(varValue.vt != VT_NULL) { nID = varValue.iVal; } varValue = m_pRecordset ->GetCollect(“worder_name”); if(varValue.vt != VT_NULL) { strName = (char *)_bstr_t(varValue); } varValue = m_pRecordset ->Fields ->GetItem(“worder_pay”)->GetValue(); if(varValue.vt != VT_NULL) { nPay = varValue.iVal; }

Cstring strResult;

strResult.Format(“The record %d values:%d,%s,%d!”,i,nID,strName,nPay); AfxMessageBox(strResult); //移动到下一条记录

M_pRecordset->MoveNext; }

//读取完后，关闭记录集 M_pRecordset ->Close(); }

Catch(_com_error e) { MessageBox(NULL,e.ErrorMessage(),”Error”,MB_OK); }

添加记录：

1> 使用Connection Object的Execute方法 2> 使用Command Object的Executefangfa

3> 记录集提供的AddNew方法 Try {

Cstring strSql = “select * from worker_information”; BSTR bstrSQL = strSql.AllocSysString(); M_pRecordset -> Open(bstrSQL,(Idispatch *)m_pConnection,adOpenDynamic,adLockPessimistic,adCmdText);

//添加记录

M_pRecordset ->AddNew();

M_pRecordset ->Fields ->GetItem(“worker_ID”) ->Value = 3;

M_pRecordset ->Fields ->GetItem(“worder_Name”) ->Value = _bstr_t(“Hello”); M_pRecordset ->Fields ->GetItem(“worder_Pay”) ->Value = 2300;

//更新数据

M_pRecordset ->Update();

M_pRecordset ->Close(); }

Catch( _com_error e) { AfxMessageBox(e.ErrorMessage()); }

修改记录：

还是用第三种方法，但不需要AddNew() Try {

Cstring strSql = “select * from worker_information where worker_ID = 3”; BSTR bstrSQL = strSql.AllocSysString(); M_pRecordset -> Open(bstrSQL,(Idispatch *)m_pConnection,adOpenDynamic,adLockPessimistic,adCmdText); //修改

If(!m_pRecordset ->adEOF) { M_pRecordset ->Fields ->GetItem(“worker_ID”) ->Value = 3;

M_pRecordset ->Fields ->GetItem(“worder_Name”) ->Value = _bstr_t(“方格”); M_pRecordset ->Fields ->GetItem(“worder_Pay”) ->Value = 2500; //更新数据

M_pRecordset ->Update(); }

M_pRecordset ->Close(); }

Catch( _com_error e) { AfxMessageBox(e.ErrorMessage()); }

删除记录： Try {

_variant_t vNULL;

vNULL.vt = VT_ERROR; //定义为无参数

vNULL.scode = DISP_E_PARAMNOTFOUND;

//下面这条语句很关键，建立连接成功后将m_pConnection赋值给ActiveConnection M_pCommand->ActiveConnection = m_pConnection; //命令串

M_pCommand ->CommandText = “delete worder_information where worker_ID = 3”; //执行命令

M_pRecordset = m_pCommand - > Execute(&vNULL,&vNULL,adCmdText); }

Catch( _com_error e) { AfxMessageBox(e.ErrorMessage()); }