小7的大店铺【淘宝店】 游戏引擎剖析-全篇 公积金相关帖子汇总 魅族M8SDK学习系列不断更新中

[WinCE] ADO数据库编程(WinCE)[转]

[ 745 查看 / 0 回复 ]

返回列表
发新话题 回复该主题
5207
头像

  • 皇帝
  • 1983-12-1
  • 1529
  • 1998
  • 94
  • 3667.8 M
元老奖章人格奖章人才奖章劳动奖章勇士奖章雅月奖章烈日奖章水神奖章老马奖章荣誉奖章
2010-03-04 22:36 |只看楼主 发表者
t T
与C++中ADO数据库编程一样，WinCE中ADO数据库操作也需要_Connection和_Recordset指针，在此我们将其封装以求更方便，注：WinCE系统必须支持数据库的ADO操作。具体代码如下所示：
//VOConnection.h
  1. #if !defined(AFX_VOCONNECTION_H__EE2E886A_8A8A_4CC8_9A48_28681F64544B__INCLUDED_)
  2. #define AFX_VOCONNECTION_H__EE2E886A_8A8A_4CC8_9A48_28681F64544B__INCLUDED_
  3.                 #if _MSC_VER > 1000
  4. #pragma once
  5. #endif // _MSC_VER > 1000
  6.                 #include <COMDEF.H>
  7. #include <ADOCE30.H>
  8. #include "VOString.h"
  9.                 class CVOConnection 
  10. {
  11. public:
  12. CVOConnection(LPCTSTR pcszProvider = NULL);
  13. virtual ~CVOConnection();
  14.                 BOOL Execute(LPCTSTR pcszSQL);
  15. BOOL Initialize();
  16. LPCTSTR GetProvider() { return m_strProvider; }
  17.                 operator _Connection*() { return m_Conn; }
  18.                 void SetConnectDB(LPCTSTR lpszDBName);
  19. void ClearConnect();

  21. protected:
  22. CVOString m_strProvider;
  23. static TCHAR*  g_ProgID;
  24. static CLSID  g_ClsID;
  25. static BOOL  g_Init;
  26.                 _Connection*  m_Conn;
  27. };
  28.                 #endif // !defined(AFX_VOCONNECTION_H__EE2E886A_8A8A_4CC8_9A48_28681F64544B__INCLUDED_)

  30. //VOConnection.cpp
  31. #include "stdafx.h"
  32. #include <COMDEF.H>
  33. #include <ADOCE30.H>
  34. #include "VOConnection.h"
  35. #include "VORecordset.h"
  36.                 #ifdef _DEBUG
  37. #undef THIS_FILE
  38. static char THIS_FILE[]=__FILE__;
  39. #define new DEBUG_NEW
  40. #endif
  41.                 const IID IID__Connection = { 0x113033de, 0xf682, 0x11d2, { 0xbb, 0x62, 0x00, 0xc0, 0x4f, 0x68, 0x0a, 0xcc}};
  42.                 void __stdcall _com_issue_error(HRESULT m_hr)
  43. {
  44. TCHAR pcszError[1024];
  45.                 _stprintf(pcszError, TEXT("_com_issue_error(%ld)\n"), m_hr);
  46. OutputDebugString(pcszError);
  47. }
  48.                 BOOL CVOConnection::g_Init = FALSE;
  49. CLSID CVOConnection::g_ClsID;
  50. TCHAR* CVOConnection::g_ProgID = TEXT("ADOCE.Connection.3.0");
  51.                 //////////////////////////////////////////////////////////////////////
  52. // Construction/Destruction
  53. //////////////////////////////////////////////////////////////////////
  54.                 extern CVOConnection m_Conn;
  55.                 CVOConnection::CVOConnection(LPCTSTR pcszProvider) : m_Conn(NULL)
  56. {

  58. if(!g_Init)
  59.   Initialize();

  61. HRESULT hr;
  62.                 if(pcszProvider == NULL)
  63. {
  64. // pcszProvider = TEXT("cedb");
  65.                   hr = CoCreateInstance(g_ClsID, NULL, CLSCTX_INPROC_SERVER, IID__Connection, (LPVOID*) &m_Conn);
  66. //  hr = m_Conn->put_Provider((LPTSTR)pcszProvider);
  67.   hr = m_Conn->Open(TEXT("Disk\\tiger.mdb"),TEXT(""),TEXT(""),adOpenUnspecified);
  68. }
  69. else
  70. {
  71.   m_strProvider = pcszProvider;
  72.   m_Conn = NULL;
  73. }
  74. }
  75.                 CVOConnection::~CVOConnection()
  76. {
  77. if(m_Conn)
  78. {
  79.   m_Conn->Close();
  80.   m_Conn->Release();
  81. }
  82. }
  83.                 BOOL CVOConnection::Initialize()
  84. {
  85. if(FAILED(CoInitializeEx(NULL, COINIT_MULTITHREADED)))
  86.   return FALSE;

  88. HRESULT hr;
  89.                 hr = CLSIDFromProgID(g_ProgID, &g_ClsID);
  90.                 if(FAILED(hr))
  91.   return FALSE;
  92.                 return TRUE;
  93. }
  94.                 BOOL CVOConnection::Execute(LPCTSTR pcszSQL)
  95. {
  96. CVORecordset rs(*this);
  97.                 return rs.Open(pcszSQL, adOpenForwardOnly, adLockPessimistic);
  98. }
  99.                 void CVOConnection::SetConnectDB(LPCTSTR lpszDBName)
  100. {
  101. if( m_Conn )
  102. {
  103.   m_Conn->Close();
  104.   m_Conn->put_Provider((LPTSTR)(TEXT("cedb")));
  105.   m_Conn->Open((LPTSTR)lpszDBName,TEXT(""),TEXT(""),adOpenUnspecified);
  106.   m_strProvider = lpszDBName;
  107. }
  108. }
  109.                 void CVOConnection::ClearConnect()
  110. {
  111. if( m_Conn )
  112. {
  113.   m_Conn->Close();
  114.   m_Conn->put_Provider((LPTSTR)(TEXT("cedb")));
  115.   m_Conn->Open(TEXT(""),TEXT(""),TEXT(""),adOpenUnspecified);
  116.   m_strProvider = TEXT("");
  117. }
  118. }

  120. //VORecordset.h
  121. #if !defined(AFX_VORECORDSET_H__B81BD14E_98F0_42A7_A64F_3FA21F5A3E5D__INCLUDED_)
  122. #define AFX_VORECORDSET_H__B81BD14E_98F0_42A7_A64F_3FA21F5A3E5D__INCLUDED_
  123.                 #if _MSC_VER > 1000
  124. #pragma once
  125. #endif // _MSC_VER > 1000
  126.                 #include <COMDEF.H>
  127. #include <ADOCE30.H>
  128. #include "VOConnection.h"
  129.                
  130.                                
  131. class CVORecordset 
  132. {
  133.                 public:
  134. CVORecordset(CVOConnection& rConn);
  135. virtual ~CVORecordset();
  136.                 public:

  138. LPCTSTR GetFieldValueString(int iField);
  139. VARIANT GetFieldValue(int iField);
  140. LPCTSTR GetFieldName(int iField);
  141. Field* GetField(int iField);
  142. long GetFieldCount() { return m_FldCnt; }
  143.                 BOOL MoveNext();
  144. BOOL MoveFirst();
  145. BOOL IsEOF();
  146. BOOL IsBOF();
  147. BOOL Close();
  148. // BOOL Open(LPCTSTR);
  149. BOOL Open(LPCTSTR pcszSource, enum CursorTypeEnum CursorType, enum LockTypeEnum LockType);
  150. BOOL Initialize();
  151. BOOL IsOpen()  { return m_fIsOpen; }
  152. operator _Recordset*() { return m_rs; }
  153.                 protected:
  154. BOOL m_fIsOpen;
  155. CVOConnection&  m_rConn;
  156. _Recordset*  m_rs;
  157. Fields*    m_Fields;
  158. Field*    m_Field;
  159. long    m_FldCnt;
  160.                 static TCHAR*  g_ProgID;
  161. static CLSID  g_ClsID;
  162. static BOOL  g_Init;
  163. };
  164. #endif // !defined(AFX_VORECORDSET_H__B81BD14E_98F0_42A7_A64F_3FA21F5A3E5D__INCLUDED_)

  166. //VORecordset.cpp
  167. #include "stdafx.h"
  168. #include "VORecordset.h"
  169.                 #ifdef _DEBUG
  170. #undef THIS_FILE
  171. static char THIS_FILE[]=__FILE__;
  172. #define new DEBUG_NEW
  173. #endif
  174.                 const IID IID__Recordset = { 0x113033f6, 0xf682, 0x11d2, { 0xbb, 0x62, 0x00, 0xc0, 0x4f, 0x68, 0x0a, 0xcc}};
  175.                 //////////////////////////////////////////////////////////////////////
  176. // Construction/Destruction
  177. //////////////////////////////////////////////////////////////////////
  178.                 BOOL CVORecordset::g_Init = FALSE;
  179. CLSID CVORecordset::g_ClsID;
  180. TCHAR* CVORecordset::g_ProgID = TEXT("ADOCE.Recordset.3.0");
  181.                 CVORecordset::CVORecordset(CVOConnection& rConn) : m_rConn(rConn), m_rs(NULL)
  182. {
  183. if(!g_Init)
  184.   Initialize();
  185.                 HRESULT hr;
  186.                 hr = CoCreateInstance(g_ClsID, NULL, CLSCTX_INPROC_SERVER, IID__Recordset, (LPVOID*)&m_rs);
  187.                 VARIANT varConn;
  188.                 varConn.pdispVal = (_Connection*)m_rConn;
  189. varConn.vt = VT_DISPATCH;
  190. hr = m_rs->put_ActiveConnection(varConn);
  191. }
  192.                 CVORecordset::~CVORecordset()
  193. {
  194. Close();
  195. if(m_rs)
  196.   m_rs->Release();
  197. }
  198.                 BOOL CVORecordset::Initialize()
  199. {
  200. HRESULT hr;
  201.                 hr = CLSIDFromProgID( g_ProgID, &g_ClsID);
  202.                 return(!FAILED(hr));
  203. }
  204.                 BOOL CVORecordset::Open(LPCTSTR pcszSource, enum CursorTypeEnum CursorType, enum LockTypeEnum LockType)
  205. {
  206. if(!m_rs)
  207. {
  208.   TRACE(TEXT("CVORecordset::Open() RecordSet COM Object not initialized\n"));
  209.   return FALSE;
  210. }
  211.                 HRESULT hr;
  212. m_rs->Close();
  213. hr = m_rs->Open(_variant_t(pcszSource), _variant_t( TEXT("Disk\\tiger.mdb") ), CursorType, LockType, adCmdUnknown);
  214. m_fIsOpen = (!FAILED(hr));
  215.                 m_rs->get_Fields(&m_Fields);
  216. m_Fields->get_Count(&m_FldCnt);
  217.                 return m_fIsOpen;
  218. }
  219.                 BOOL CVORecordset::Close()
  220. {
  221. if(!m_rs)
  222. {
  223.   TRACE(TEXT("CVORecordset::Close() RecordSet COM Object not initialized\n"));
  224.   return FALSE;
  225. }
  226.                 m_rs->Close();
  227.                 m_fIsOpen = FALSE;
  228. return TRUE;
  229. }
  230.                 BOOL CVORecordset::IsBOF()
  231. {
  232. if(!m_rs)
  233. {
  234.   TRACE(TEXT("CVORecordset::BOF() RecordSet COM Object not initialized\n"));
  235.   return FALSE;
  236. }
  237.                 VARIANT_BOOL fValue;
  238. HRESULT  hr = m_rs->get_BOF(&fValue);
  239.                 return (fValue == VARIANT_TRUE);
  240. }
  241.                 BOOL CVORecordset::IsEOF()
  242. {
  243. if(!m_rs)
  244. {
  245.   TRACE(TEXT("CVORecordset::EOF() RecordSet COM Object not initialized\n"));
  246.   return FALSE;
  247. }
  248.                 VARIANT_BOOL fValue;
  249. HRESULT  hr = m_rs->get_EOF(&fValue);
  250.                 return (fValue == VARIANT_TRUE);
  251. }
  252.                 BOOL CVORecordset::MoveFirst()
  253. {
  254. if(!m_rs)
  255. {
  256.   TRACE(TEXT("CVORecordset::MoveFirst() RecordSet COM Object not initialized\n"));
  257.   return FALSE;
  258. }
  259.                 HRESULT hr = m_rs->MoveFirst();
  260.                 return (!FAILED(hr));
  261. }
  262.                 BOOL CVORecordset::MoveNext()
  263. {
  264. if(!m_rs)
  265. {
  266.   TRACE(TEXT("CVORecordset::MoveNext() RecordSet COM Object not initialized\n"));
  267.   return FALSE;
  268. }
  269.                 HRESULT hr = m_rs->MoveNext();
  270.                 return (!FAILED(hr));
  271. }
  272.                 Field* CVORecordset::GetField(int iField)
  273. {
  274. if(!m_rs)
  275. {
  276.   TRACE(TEXT("CVORecordset::GetField() RecordSet COM Object not initialized\n"));
  277.   return NULL;
  278. }
  279.                 HRESULT hr = m_Fields->get_Item(_variant_t((long)iField), &m_Field);
  280.                 if(FAILED(hr))
  281.   return NULL;
  282.                 return m_Field;
  283. }
  284.                 LPCTSTR CVORecordset::GetFieldName(int iField)
  285. {
  286. Field* pField = GetField(iField);
  287.                 if(!pField)
  288. {
  289.   TRACE(TEXT("CVORecordset::GetFieldName() Invalid Field Index\n"));
  290.   return NULL;
  291. }
  292.                 BSTR strFieldName;
  293.                 pField->get_Name(&strFieldName);
  294.                 return strFieldName;
  295. }
  296.                 VARIANT CVORecordset::GetFieldValue(int iField)
  297. {
  298. VARIANT value;
  299. HRESULT hr;
  300.                 VariantInit(&value);
  301.                 Field* pField = GetField(iField);
  302.                 if(!pField)
  303. {
  304.   TRACE(TEXT("CVORecordset::GetFieldValue() Invalid Field Index\n"));
  305.   return _variant_t((long)0);
  306. }
  307.                 pField = GetField(iField);
  308. hr = pField->get_Value(&value);
  309.                 return value;
  310. }
  311.                 LPCTSTR CVORecordset::GetFieldValueString(int iField)
  312. {
  313. VARIANT value = GetFieldValue(iField);
  314. VARIANT valueString;
  315.                 VariantInit(&valueString);
  316.                 if(value.vt == VT_BSTR)
  317.   valueString = value;
  318. else
  319.   VariantChangeType(&valueString, &value, 0, VT_BSTR);
  320.                 return valueString.bstrVal;
  321. }

  323. //VOString.h
  324. #if !defined(AFX_VOSTRING_H__91406803_1D87_4DA9_A5A0_499A88AC4E86__INCLUDED_)
  325. #define AFX_VOSTRING_H__91406803_1D87_4DA9_A5A0_499A88AC4E86__INCLUDED_
  326.                 #if _MSC_VER > 1000
  327. #pragma once
  328. #endif // _MSC_VER > 1000
  329.                 class CVOString 
  330. {
  331. public:
  332. CVOString(const CVOString& rSrc);
  333. CVOString(LPCTSTR pcszValue = TEXT(""));
  334. virtual ~CVOString();
  335. operator LPCTSTR() { return (LPCTSTR)m_pBuffer; }
  336. DWORD GetLength() { return m_dwLength; }
  337. const CVOString& operator =(LPCTSTR pcszValue);
  338. BOOL operator == (LPCTSTR pcszValue);
  339. const CVOString& operator += (LPCTSTR pcszAppend);
  340. protected:
  341. BOOL SetMinBufferSize(DWORD dwChars);
  342. DWORD m_dwLength;
  343. DWORD m_dwBufferSize;
  344. TCHAR* m_pBuffer;
  345. };
  346.                 #endif // !defined(AFX_VOSTRING_H__91406803_1D87_4DA9_A5A0_499A88AC4E86__INCLUDED_)

  348. //VOString.cpp
  349. //#include "stdafx.h"
  350. #include "VOString.h"
  351.                 //////////////////////////////////////////////////////////////////////
  352. // Construction/Destruction
  353. //////////////////////////////////////////////////////////////////////
  354.                 CVOString::CVOString(LPCTSTR pcszValue)
  355. {
  356. m_pBuffer = NULL;
  357. m_dwBufferSize = 0;
  358.                 *this = pcszValue;
  359. }
  360.                 // Copy Constructor
  361. CVOString::CVOString(const CVOString &rSrc)
  362. {
  363. m_pBuffer = NULL;
  364. m_dwBufferSize = 0;
  365.                 *this = rSrc.m_pBuffer;
  366. }
  367.                 CVOString::~CVOString()
  368. {
  369. if(m_pBuffer)
  370.   delete m_pBuffer;
  371. }
  372.                 const CVOString& CVOString::operator = (LPCTSTR pcszValue)
  373. {
  374.                 m_dwLength = _tcslen(pcszValue);
  375.                 SetMinBufferSize(m_dwLength);
  376. _tcscpy(m_pBuffer, pcszValue);
  377. return *this;
  378. }
  379.                 BOOL CVOString::operator == (LPCTSTR pcszValue)
  380. {
  381. return(_tcscmp(pcszValue, m_pBuffer) == 0);
  382. }
  383.                 const CVOString& CVOString::operator += (LPCTSTR pcszAppend)
  384. {
  385. SetMinBufferSize(GetLength() + _tcslen(pcszAppend));
  386.                 _tcscat(m_pBuffer, pcszAppend);
  387. return *this;
  388. }
  389.                 BOOL CVOString::SetMinBufferSize(DWORD dwChars)
  390. {
  391. if(m_dwBufferSize < dwChars + 1)
  392. {
  393.   TCHAR* pNewBuffer;
  394.   DWORD dwNewBufferSize = dwChars + 256;
  395.                   pNewBuffer = new TCHAR[dwNewBufferSize];
  396.                   if(m_pBuffer)
  397.   {
  398.   memmove(pNewBuffer, m_pBuffer, m_dwBufferSize);
  399.   delete m_pBuffer;
  400.   }
  401.                   m_pBuffer = pNewBuffer;
  402.   m_dwBufferSize = dwNewBufferSize;
  403. }
  404.                 return TRUE;
  405. }
复制代码
转：http://www.cppblog.com/tiger/archive/2009/05/02/17454.html
分享 转发
相信与不相信都是矛盾的.  5207宣!
欢迎您来到迷你论坛
TOP
返回列表
上一主题 | 下一主题