免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 程序设计 › C/C++ › 重新整理的Ado封装
最近访问板块 发新帖
查看: 954 | 回复: 0
打印 上一主题 下一主题

[C++] 重新整理的Ado封装 [复制链接]

framily

论坛徽章:
1
程序设计版块每日发帖之星 日期:2015-08-12 06:20:00
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2015-05-14 15:30 |只看该作者 |倒序浏览
  1. #pragma once
  2. #pragma warning (disable:4146)
  3. #import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("EOF","adoEOF")rename("BOF","adoBOF")
  4. class Ado
  5. {
  6.         _RecordsetPtr m_pRst;
  7.         _ConnectionPtr m_pConn;

  9.         CString m_szLastError;
  10. public:
  11.         void Release()
  12.         {
  13.                 m_pConn->Release();
  14.         }
  15.         BOOL GetFieldType(long nIndex, int &nType);
  16.         enum EType { DBT_ACCESS, DBT_SQL, DBT_ORACLE };
  17.         BOOL Connect(EType eType, LPCTSTR szDatabase, LPCTSTR szPass = NULL, LPCTSTR szUser = NULL, LPCTSTR szHost = NULL);//连接函数

  19.         int ExecSQL(LPCTSTR szSQL);
  20.         BOOL Select(LPCTSTR szSQL);

  22.         BOOL IsEOF();
  23.         BOOL MoveNext();
  24.         BOOL MoveFirst();
  25.         BOOL MoveLast();
  26.         BOOL GetFieldValue(LPCTSTR szField, COleDateTime &tValue);
  27.         BOOL GetFieldValue(LPCTSTR szField, double &fValue);
  28.         BOOL GetFieldValue(LPCTSTR szField, CString &sValue);
  29.         BOOL GetFieldValue(LPCTSTR szField, int &iValue);
  30.         int GetFieldMoney(LPCTSTR szField, double &fValue);
  31.         BOOL GetFieldByIndex(long nIndex, COleDateTime &tValue);
  32.         BOOL GetFieldByIndex(long nIndex, double &fValue);
  33.         BOOL GetFieldByIndex(long nIndex, CString &sValue);
  34.         BOOL GetFieldByIndex(long nIndex, int &iValue);
  35.         BOOL GetFieldByIndex(long nIndex, long &lValue);
  36.         BOOL GetFieldByIndex(long nIndex, DWORD &dwValue);
  37.         BOOL GetFieldByIndex(long nIndex, UINT &iValue);
  38.         BOOL GetFieldByIndex(long nIndex, char &cValue);
  39.         BOOL GetFieldByIndex(long nIndex, short &nValue);
  40.         BOOL GetFieldByIndex(long nIndex, BYTE &cbValue);
  41.         BOOL GetFieldByIndex(long nIndex, WORD &wValue);
  42.         BOOL GetFieldByIndex(long nIndex, TCHAR sValue[], int nSize);
  43.         int GetFieldCount();
  44.         BOOL GetFieldName(long nIndex, CString &szName);
  45.         int GetRecordCount();
  46.         CString GetLastError()
  47.         {
  48.                 CString str = m_szLastError;
  49.                 m_szLastError.Empty();
  50.                 return str;
  51.         }
  52.         class CProc
  53.         {
  54.                 CString m_szLastError;
  55.                 _CommandPtr m_pCmd;
  56.         public:
  57.                 LPCTSTR GetLastError() const
  58.                 {
  59.                         return m_szLastError;
  60.                 }
  61.                 int Exec();
  62.                 BOOL Create(_ConnectionPtr &pConn, LPCTSTR szProc);

  64.                 BOOL AddParam(LPCTSTR szVName, long lParam, ParameterDirectionEnum eDir = adParamInput);
  65.                 BOOL AddParam(LPCTSTR szVName, LPCTSTR szParam, ParameterDirectionEnum eDir = adParamInput);

  67.                 BOOL GetValue(LPCTSTR szVName, long &lParam);
  68.                 BOOL GetValue(LPCTSTR szVName, CString &lParam);

  70.                 void Release()
  71.                 {
  72.                         delete this;
  73.                 }
  74.                 CProc()
  75.                 {
  76.                 }

  78.         };
  79.         CProc* CreateProc(LPCTSTR szProc);
  80.         int ExecProc(CProc* pProc);

  82.         Ado();
  83.         virtual ~Ado();
  84. };



  88. #include "stdafx.h"
  89. #include "Ado.h"

  91. Ado::Ado()
  92. {
  93.         ::OleInitialize(NULL);
  94. }

  96. Ado::~Ado()
  97. {

  99. }

  101. BOOL Ado::Connect(EType eType, LPCTSTR szDatabase, LPCTSTR szPass, LPCTSTR szUser, LPCTSTR szHost)
  102. {
  103.         CString str;
  104.         switch (eType)
  105.         {
  106.         case DBT_ACCESS:
  107.         {
  108.                 str.Format(TEXT("Provider=MSDASQL.1;Persist Security Info=False;Data Source=MS Access Database;Initial Catalog=%s"), szDatabase);

  110.         }
  111.         break;
  112.         case DBT_SQL:
  113.         {
  114.                 str = TEXT("Driver=SQL Server;Server=");
  115.                 str += szHost;
  116.                 str += TEXT(";Database=");
  117.                 str += szDatabase;
  118.                 str += TEXT(";UID=");
  119.                 str += szUser;
  120.                 str += TEXT(";PWD=");
  121.                 str += szPass;
  122.         }

  124.         break;
  125.         case DBT_ORACLE:
  126.                 str = TEXT("Provider=OraOLEDB.Oracle.1;Persist Security Info=False;User ID=");
  127.                 str += szUser;
  128.                 str += TEXT(";Password=");
  129.                 str += szPass;
  130.                 str += TEXT(";Data Source=");
  131.                 str += szDatabase;
  132.                 break;
  133.         }

  135.         try
  136.         {
  137.                 m_pConn.CreateInstance(__uuidof(Connection));
  138.                 m_pConn->Open(_bstr_t(str), szUser, szPass, adModeUnknown);///连接数据库

  140.         }
  141.         catch (_com_error &e)
  142.         {
  143.                 m_szLastError = (LPCTSTR)e.Description();
  144.                 return FALSE;
  145.         }
  146.         return TRUE;

  148. }


  151. int Ado::ExecSQL(LPCTSTR szSql)
  152. {
  153.         _variant_t vRet;
  154.         try
  155.         {
  156.                 m_pConn->Execute(szSql, &vRet, adCmdText);
  157.         }
  158.         catch (_com_error &e)
  159.         {
  160.                 m_szLastError = (LPCTSTR)e.Description();
  161.                 return e.Error();
  162.         }

  164.         return (long)vRet;
  165. }
  166. BOOL Ado::IsEOF()
  167. {
  168.         try
  169.         {
  170.                 if (m_pRst->GetadoEOF())
  171.                         return TRUE;
  172.         }
  173.         catch (_com_error &e)
  174.         {
  175.                 m_szLastError = (LPCTSTR)e.Description();
  176.         }
  177.         return FALSE;
  178. }


  181. BOOL Ado::Select(LPCTSTR szSQL)
  182. {
  183.         try
  184.         {
  185.                 if (m_pRst)
  186.                         m_pRst->Close();
  187.                 m_pRst.CreateInstance(__uuidof(Recordset));
  188.                 m_pRst->Open(szSQL, m_pConn.GetInterfacePtr(), adOpenStatic, adLockReadOnly, adCmdText);
  189.         }
  190.         catch (_com_error &e)
  191.         {
  192.                 m_szLastError = (LPCTSTR)e.Description();
  193.                 return FALSE;
  194.         }

  196.         return TRUE;
  197. }
  198. int Ado::GetFieldCount()
  199. {
  200.         try
  201.         {
  202.                 return m_pRst->Fields->Count;
  203.         }
  204.         catch (_com_error &e)
  205.         {
  206.                 m_szLastError = (LPCTSTR)e.Description();
  207.                 return FALSE;
  208.         }
  209.         return TRUE;
  210. }

  212. BOOL Ado::GetFieldByIndex(long nIndex, TCHAR sValue[], int nSize)
  213. {
  214.         try
  215.         {
  216.                 _variant_t v = m_pRst->GetCollect(nIndex);
  217.                 if (v.vt == VT_NULL)
  218.                 {
  219.                         *sValue = 0;
  220.                         return TRUE;
  221.                 }
  222.                 CString str = v.bstrVal;
  223.                 LPCTSTR p = str;
  224.                 int i = 0;
  225.                 while (--nSize && (*sValue = *p) != 0)
  226.                 {
  227.                         sValue++;
  228.                         p++;
  229.                 }
  230.                 if (!nSize)
  231.                         *sValue = 0;

  233.         }
  234.         catch (_com_error &e)
  235.         {
  236.                 m_szLastError = (LPCTSTR)e.Description();
  237.                 return FALSE;
  238.         }

  240.         return TRUE;
  241. }
  242. BOOL Ado::GetFieldName(long nIndex, CString &szName)
  243. {
  244.         try
  245.         {
  246.                 szName = (LPCTSTR)m_pRst->Fields->Item[nIndex]->Name;
  247.         }
  248.         catch (_com_error &e)
  249.         {
  250.                 m_szLastError = (LPCTSTR)e.Description();
  251.                 return FALSE;
  252.         }
  253.         return TRUE;
  254. }
  255. BOOL Ado::GetFieldValue(LPCTSTR szField, int &iValue)
  256. {

  258.         try
  259.         {
  260.                 iValue = (long)m_pRst->GetCollect(szField);
  261.         }
  262.         catch (_com_error &e)
  263.         {
  264.                 m_szLastError = (LPCTSTR)e.Description();
  265.                 return FALSE;
  266.         }
  267.         return TRUE;
  268. }

  270. BOOL Ado::GetFieldByIndex(long nIndex, int &iValue)
  271. {
  272.         try
  273.         {
  274.                 _variant_t v = m_pRst->GetCollect(nIndex);
  275.                 iValue = (long)v;
  276.         }
  277.         catch (_com_error &e)
  278.         {
  279.                 m_szLastError = (LPCTSTR)e.Description();
  280.                 return FALSE;
  281.         }
  282.         return TRUE;
  283. }

  285. BOOL Ado::GetFieldByIndex(long nIndex, CString &szValue)
  286. {
  287.         try
  288.         {
  289.                 _variant_t v = m_pRst->GetCollect(nIndex);
  290.                 if (v.vt == VT_NULL)
  291.                         szValue = "";
  292.                 else
  293.                         szValue = v.bstrVal;
  294.         }
  295.         catch (_com_error &e)
  296.         {
  297.                 m_szLastError = (LPCTSTR)e.Description();
  298.                 return FALSE;
  299.         }
  300.         return TRUE;
  301. }

  303. BOOL Ado::GetFieldByIndex(long nIndex, COleDateTime &tValue)
  304. {
  305.         try
  306.         {
  307.                 _variant_t v = m_pRst->GetCollect(nIndex);
  308.                 if (v.vt == VT_NULL)
  309.                         tValue = 0.0;
  310.                 else
  311.                         tValue = v;
  312.                 return TRUE;
  313.         }
  314.         catch (_com_error &e)
  315.         {
  316.                 m_szLastError = (LPCTSTR)e.Description();
  317.                 return FALSE;
  318.         }
  319. }

  321. BOOL Ado::GetFieldByIndex(long nIndex, double &fValue)
  322. {
  323.         try
  324.         {
  325.                 _variant_t v = m_pRst->GetCollect(nIndex);
  326.                 if (v.vt == VT_NULL)
  327.                         fValue = 0.0;
  328.                 else
  329.                         fValue = v;
  330.                 return TRUE;
  331.         }
  332.         catch (_com_error &e)
  333.         {
  334.                 m_szLastError = (LPCTSTR)e.Description();
  335.                 return FALSE;
  336.         }

  338. }

  340. BOOL Ado::GetFieldByIndex(long nIndex, long &lValue)
  341. {
  342.         try
  343.         {
  344.                 _variant_t v = m_pRst->GetCollect(nIndex);
  345.                 if (v.vt == VT_NULL)
  346.                         lValue = 0;
  347.                 else
  348.                         lValue = v;
  349.                 return TRUE;
  350.         }
  351.         catch (_com_error &e)
  352.         {
  353.                 m_szLastError = (LPCTSTR)e.Description();
  354.                 return FALSE;
  355.         }

  357. }

  359. BOOL Ado::GetFieldByIndex(long nIndex, DWORD &dwValue)
  360. {
  361.         try
  362.         {
  363.                 _variant_t v = m_pRst->GetCollect(nIndex);
  364.                 if (v.vt == VT_NULL)
  365.                         dwValue = 0;
  366.                 else
  367.                         dwValue = v.lVal;
  368.                 return TRUE;
  369.         }
  370.         catch (_com_error &e)
  371.         {
  372.                 m_szLastError = (LPCTSTR)e.Description();
  373.                 return FALSE;
  374.         }

  376. }

  378. BOOL Ado::GetFieldByIndex(long nIndex, UINT &iValue)
  379. {
  380.         try
  381.         {
  382.                 _variant_t v = m_pRst->GetCollect(nIndex);
  383.                 if (v.vt == VT_NULL)
  384.                         iValue = 0;
  385.                 else
  386.                         iValue = v.lVal;
  387.                 return TRUE;
  388.         }
  389.         catch (_com_error &e)
  390.         {
  391.                 m_szLastError = (LPCTSTR)e.Description();
  392.                 return FALSE;
  393.         }

  395. }
  396. BOOL Ado::GetFieldByIndex(long nIndex, char &cValue)
  397. {
  398.         try
  399.         {
  400.                 _variant_t v = m_pRst->GetCollect(nIndex);
  401.                 if (v.vt == VT_NULL)
  402.                         cValue = 0;
  403.                 else
  404.                         cValue = v.bVal;
  405.                 return TRUE;
  406.         }
  407.         catch (_com_error &e)
  408.         {
  409.                 m_szLastError = (LPCTSTR)e.Description();
  410.                 return FALSE;
  411.         }

  413. }

  415. BOOL Ado::GetFieldByIndex(long nIndex, short &nValue)
  416. {
  417.         try
  418.         {
  419.                 _variant_t v = m_pRst->GetCollect(nIndex);
  420.                 if (v.vt == VT_NULL)
  421.                         nValue = 0;
  422.                 else
  423.                         nValue = v;
  424.                 return TRUE;
  425.         }
  426.         catch (_com_error &e)
  427.         {
  428.                 m_szLastError = (LPCTSTR)e.Description();
  429.                 return FALSE;
  430.         }

  432. }
  433. BOOL Ado::GetFieldByIndex(long nIndex, BYTE &cbValue)
  434. {
  435.         try
  436.         {
  437.                 _variant_t v = m_pRst->GetCollect(nIndex);
  438.                 if (v.vt == VT_NULL)
  439.                         cbValue = 0;
  440.                 else
  441.                         cbValue = v;
  442.                 return TRUE;
  443.         }
  444.         catch (_com_error &e)
  445.         {
  446.                 m_szLastError = (LPCTSTR)e.Description();
  447.                 return FALSE;
  448.         }
  449. }
  450. BOOL Ado::GetFieldByIndex(long nIndex, WORD &wValue)
  451. {
  452.         try
  453.         {
  454.                 _variant_t v = m_pRst->GetCollect(nIndex);
  455.                 if (v.vt == VT_NULL)
  456.                         wValue = 0;
  457.                 else
  458.                         wValue = v.iVal;
  459.                 return TRUE;
  460.         }
  461.         catch (_com_error &e)
  462.         {
  463.                 m_szLastError = (LPCTSTR)e.Description();
  464.                 return FALSE;
  465.         }

  467. }

  469. BOOL Ado::MoveFirst()
  470. {
  471.         try
  472.         {
  473.                 return m_pRst->MoveFirst() == S_OK;
  474.         }
  475.         catch (_com_error &e)
  476.         {
  477.                 m_szLastError = (LPCTSTR)e.Description();
  478.                 return FALSE;
  479.         }
  480. }
  481. BOOL Ado::MoveLast()
  482. {
  483.         try
  484.         {
  485.                 return m_pRst->MoveLast() == S_OK;
  486.         }
  487.         catch (_com_error &e)
  488.         {
  489.                 m_szLastError = (LPCTSTR)e.Description();
  490.                 return FALSE;
  491.         }
  492. }

  494. BOOL Ado::MoveNext()
  495. {
  496.         try
  497.         {
  498.                 return m_pRst->MoveNext() == S_OK;
  499.         }
  500.         catch (_com_error &e)
  501.         {
  502.                 m_szLastError = (LPCTSTR)e.Description();
  503.                 return FALSE;
  504.         }
  505. }

  507. BOOL Ado::GetFieldType(long nIndex, int &nType)
  508. {
  509.         try
  510.         {
  511.                 nType = m_pRst->Fields->Item[nIndex]->Type;
  512.         }
  513.         catch (_com_error &e)
  514.         {
  515.                 m_szLastError = (LPCTSTR)e.Description();
  516.                 return FALSE;
  517.         }
  518.         return TRUE;

  520. }

  522. BOOL Ado::GetFieldValue(LPCTSTR szField, CString &sValue)
  523. {
  524.         try
  525.         {
  526.                 sValue = m_pRst->GetCollect(szField).bstrVal;
  527.                 return TRUE;
  528.         }
  529.         catch (_com_error &e)
  530.         {
  531.                 m_szLastError = (LPCTSTR)e.Description();
  532.                 return FALSE;
  533.         }


  536. }
  537. BOOL Ado::GetFieldValue(LPCTSTR szField, COleDateTime &tValue)
  538. {
  539.         try
  540.         {
  541.                 tValue = (DATE)m_pRst->GetCollect(szField);
  542.                 return TRUE;
  543.         }
  544.         catch (_com_error &e)
  545.         {
  546.                 m_szLastError = (LPCTSTR)e.Description();
  547.                 return FALSE;
  548.         }
  549. }



  553. int Ado::GetRecordCount()
  554. {
  555.         try
  556.         {
  557.                 return m_pRst->GetRecordCount();
  558.         }
  559.         catch (_com_error &e)
  560.         {
  561.                 m_szLastError = (LPCTSTR)e.Description();
  562.                 return FALSE;
  563.         }
  564. }





  570. BOOL Ado::CProc::Create(_ConnectionPtr &pConn, LPCTSTR szProc)
  571. {
  572.         try
  573.         {
  574.                 m_pCmd.CreateInstance(__uuidof(Command));
  575.                 m_pCmd->ActiveConnection = pConn;
  576.                 m_pCmd->CommandType = adCmdStoredProc;
  577.                 m_pCmd->CommandText = _bstr_t(szProc);
  578.         }
  579.         catch (_com_error &e)
  580.         {
  581.                 m_szLastError = (LPCTSTR)e.Description();
  582.                 return FALSE;
  583.         }
  584.         return TRUE;
  585. }

  587. Ado::CProc* Ado::CreateProc(LPCTSTR szProc)
  588. {
  589.         if (m_pConn == NULL)return FALSE;
  590.         CProc* pProc = new CProc;
  591.         if (pProc->Create(m_pConn, szProc))
  592.                 return pProc;
  593.         delete pProc;
  594.         return NULL;
  595. }

  597. BOOL Ado::CProc::AddParam(LPCTSTR szVName, long lParam, ParameterDirectionEnum eDir)
  598. {
  599.         if (m_pCmd == NULL)
  600.                 return FALSE;
  601.         try
  602.         {
  603.                 _ParameterPtr pParam = m_pCmd->CreateParameter(szVName, adInteger, eDir, sizeof(long), lParam);
  604.                 m_pCmd->Parameters->Append(pParam);
  605.         }
  606.         catch (_com_error &e)
  607.         {
  608.                 m_szLastError = (LPCTSTR)e.Description();
  609.                 return FALSE;
  610.         }

  612.         return TRUE;
  613. }
  614. BOOL Ado::CProc::AddParam(LPCTSTR szVName, LPCTSTR szParam, ParameterDirectionEnum eDir)
  615. {
  616.         if (m_pCmd == NULL)
  617.                 return FALSE;
  618.         try
  619.         {
  620.                 _ParameterPtr pParam = m_pCmd->CreateParameter(_bstr_t(szVName), adVarChar, eDir, lstrlen(szParam) + 2, szParam);
  621.                 m_pCmd->Parameters->Append(pParam);
  622.         }
  623.         catch (_com_error &e)
  624.         {
  625.                 m_szLastError = (LPCTSTR)e.Description();
  626.                 return FALSE;
  627.         }

  629.         return TRUE;
  630. }

  632. int Ado::CProc::Exec()
  633. {
  634.         try
  635.         {
  636.                 m_pCmd->Execute(NULL, NULL, adCmdStoredProc);

  638.         }
  639.         catch (_com_error& e)
  640.         {
  641.                 m_szLastError = (LPCTSTR)e.Description();
  642.                 return e.Error();
  643.         }
  644.         return 0;
  645. }

  647. BOOL Ado::CProc::GetValue(LPCTSTR szVName, long &lParam)
  648. {
  649.         try
  650.         {
  651.                 _variant_t var = m_pCmd->Parameters->GetItem(_bstr_t(szVName))->GetValue();
  652.                 lParam = var;
  653.         }
  654.         catch (_com_error &e)
  655.         {
  656.                 m_szLastError = (LPCTSTR)e.Description();
  657.                 return FALSE;
  658.         }
  659.         return TRUE;
  660. }

  662. BOOL Ado::CProc::GetValue(LPCTSTR szVName, CString &szParam)
  663. {
  664.         try
  665.         {
  666.                 _bstr_t bstr = m_pCmd->Parameters->GetItem(_bstr_t(szVName))->GetValue();
  667.                 szParam = (LPCTSTR)bstr;
  668.         }
  669.         catch (_com_error &e)
  670.         {
  671.                 m_szLastError = (LPCTSTR)e.Description();
  672.                 return FALSE;
  673.         }
  674.         return TRUE;

  676. }

  678. int Ado::ExecProc(CProc* pProc)
  679. {
  680.         return 0;
  681. }
复制代码
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP