VC++之数据库技术之用ADO连接Oracle数据库.pdf
VC+之数据库技术之用ADO 连接 Oracle 数据库2011-02-02 20:34 转载自xiaoxing2099最终编辑xiaoxing2099一、创建对话框应用程序二、编辑对话框资源控件 ID 及标题连接 ORACLE 数据库IDC_QUERY 查询三、添加变量、函数1、添加变量/BQuery.h:main header file for the BQUERY application class CBQueryApp:public CWinApp.public:_ConnectionPtr m_pConnection;/BQueryDlg.h:header file class CBQueryDlg:public CDialog.public:CListCtrl m_ListCtrl;_RecordsetPtr m_pRecordset;a、添加消息响应函数b、添加函数四、添加代码1、于“stdafx.h”文件内添加输入语句/stdafx.h:include file for standard system include files,#include /MFC support for Windows Common Controls#endif/_AFX_NO_AFXCMN_SUPPORT#import C:Program FilesCommon FilesSystemADOmsado15.dll no_namespace rename(EOF,adoEOF)2、于“Resource.h”文件内添加资源“IDC_LIST_DB”#define IDC_QUERY 1000#define IDC_LIST_DB 1001 3、于“BQueryDlg.h”文件内添加外部变量/BQueryDlg.h:header file./CBQueryDlg dialog extern CBQueryApp theApp;class CBQueryDlg:public CDialog 4、添加函数代码a、于“BQuery.cpp”文件内添加BOOL CBQueryApp:InitInstance()/初始化 AfxEnableControlContainer();AfxOleInit();/初始化 COM 库/*连接数据库*/HRESULT hr;try hr=m_pConnection.CreateInstance(ADODB.Connection);if(SUCCEEDED(hr)hr=m_pConnection-Open(Provider=MSDAORA.1;Password=bank;User ID=bank;Data Source=users;Persist Security Info=True,NULL);catch(_com_error e)/捕捉异常 CString errormessage;errormessage.Format(连接数据库失败!rn 错误信息:%s,e.ErrorMessage();errormessage=请加入 Oracle 文件;AfxMessageBox(errormessage);/显示错误信息return FALSE;#ifdef _AFXDLL Enable3dControls();/Call this when using MFC in a shared DLL#else Enable3dControlsStatic();/Call this when linking to MFC statically#endif CBQueryDlg dlg;m_pMainWnd=&dlg;int nResponse=dlg.DoModal();if(nResponse=IDOK)else if(nResponse=IDCANCEL)return FALSE;int CBQueryApp:ExitInstance()/关闭数据库/TODO:Add your specialized code here and/or call the base class if(m_pConnection-State)m_pConnection-Close();return CWinApp:ExitInstance();b、于“BQueryDlg.cpp”文件内添加BOOL CBQueryDlg:OnInitDialog()/初始化 CDialog:OnInitDialog();ASSERT(IDM_ABOUTBOX&0 xFFF0)=IDM_ABOUTBOX);ASSERT(IDM_ABOUTBOX AppendMenu(MF_SEPARATOR);pSysMenu-AppendMenu(MF_STRING,IDM_ABOUTBOX,strAboutMenu);SetIcon(m_hIcon,TRUE);/Set big icon SetIcon(m_hIcon,FALSE);/Set small icon/TODO:Add extra initialization here CRect rect;GetClientRect(&rect);CRect rectQuery;GetDlgItem(IDC_QUERY)-GetWindowRect(&rectQuery);ScreenToClient(&rectQuery);rect.left+=10;rect.top+=10;rect.right-=10;rect.bottom=rectQuery.top-10;BOOL bl=m_ListCtrl.Create(WS_BORDER|WS_VISIBLE|LVS_REPORT,rect,this,IDC_LIST_DB);m_ListCtrl.SetExtendedStyle(LVS_EX_FULLROWSELECT);m_ListCtrl.InsertColumn(0,学号,LVCFMT_LEFT,50);m_ListCtrl.InsertColumn(1,姓名,LVCFMT_LEFT,50);int n=m_ListCtrl.InsertItem(0,1);m_ListCtrl.SetItemText(n,1,张三);n=m_ListCtrl.InsertItem(1,2);m_ListCtrl.SetItemText(n,1,李四);return TRUE;/return TRUE unless you set the focus to a control void CBQueryDlg:OnQuery()/TODO:Add your control notification handler code here CString strSQL=;int nFieldsCount=0;long i=0;CString strFieldName=;m_pRecordset.CreateInstance(ADODB.Recordset);/创建 Recordset 实例strSQL=SELECT TNO,TN,SEX,AGE,PROF,DEPT FROM T WHERE AGE30;try m_pRecordset-Open(_variant_t)strSQL,(IDispatch*)theApp.m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);/打开记录集 catch(_com_error*e)AfxMessageBox(e-ErrorMessage();/弹出错误对话框 try nFieldsCount=m_pRecordset-GetFields()-Count;/得到字段数 catch(_com_error*e)AfxMessageBox(e-ErrorMessage();/弹出错误对话框/清空列表控件int nListColCount=0;nListColCount=m_ListCtrl.GetHeaderCtrl()-GetItemCount();m_ListCtrl.DeleteAllItems();for(i=nListColCount-1;i=0;i-)m_ListCtrl.DeleteColumn(i);/添加新的字段，字段名为读取表中的各字段名for(i=0;iGetFields()-GetItem(_variant_t(i)-Name);m_ListCtrl.InsertColumn(i,strFieldName,LVCFMT_LEFT,50,50);_variant_t var;CString strItemValue;/当前记录当前字段的值int nItem=0;/当前插入记录的行数long nFirstCol=0;/第一列的索引，为0 int nIndex=0;/标记当前记录索引，从0 开始while(!m_pRecordset-adoEOF)/得到当前记录第一个字段的值var=m_pRecordset-GetCollect(_variant_t(nFirstCol);if(var.vt!=VT_NULL)/类型转换，将_variant_t 转换为 CString strItemValue=LPCTSTR(_bstr_t(var);/插入记录并填入第一个字段的值nItem=m_ListCtrl.InsertItem(nIndex,strItemValue);/循环一下，读取数据库中当前记录的值并填入列表控件for(i=1;iGetCollect(_variant_t(i);if(var.vt!=VT_NULL)strItemValue=LPCTSTR(_bstr_t(var);m_ListCtrl.SetItemText(nItem,i,strItemValue);m_pRecordset-MoveNext();/转入数据库下一记录nIndex+;/当前记录索引加1 /防止闪烁m_ListCtrl.ShowWindow(SW_HIDE);for(i=0;iOpen 函数声明HRESULT Connectiong15:Open(_bstr ConnectiongString,_bstr_t UserID,_bstr_t Password,long Optiongs)ConnectiongString：连接字符串。UserID：用户名。Password：登录密码。Optiongs：连接选项，用于指定Connectiong 对象对数据更新的许可权。Optiongs 可以是：adModeunknown；默认，没设置当前许可权adModeRead：只读。adModeWrite：只写。adModeReadWrite：可读写。adModeShareDenyRead：阻止其他connectiong 对象以读权限打开连接。adModeShareDenyWrite：阻止其他connectiong 对象以写权限打开连接。adModeShareExclusive：阻止其他connectiong 对象打开连接。adModeShareDenyNone：允许其他程序或对象以任何权限建立连接功能，设置静态控件功能。功能：建立于数据库服务器的连接
