开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > 查看源码
AdoRecordSet.cpp
资源名称：ado封装类.rar　[点击查看]
上传用户：xutong0099
上传日期：2009-03-19
资源大小：29k
文件大小：87k
源码类别：

数据库系统

开发平台：

Visual C++

AdoRecordSet.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "AdoRecordSet.h"
  3. #include <math.h>
  4. #include <io.h>
  6. #ifdef _DEBUG
  7. #undef THIS_FILE
  8. static char THIS_FILE[]=__FILE__;
  9. #define new DEBUG_NEW
  10. #endif
  12. /*########################################################################
  13.  ------------------------------------------------
  14. CAdoRecordSet class 构造/析构函数
  15.  ------------------------------------------------
  16.   ########################################################################*/
  18. CAdoRecordSet::CAdoRecordSet()
  19. {
  20. m_pConnection = NULL;
  21. m_SearchDirection = adSearchForward;
  22. m_pRecordset.CreateInstance("ADODB.Recordset");
  23. #ifdef _DEBUG
  24. if (m_pRecordset == NULL)
  25. {
  26. AfxMessageBox("RecordSet 对象创建失败! 请确认是否初始化了COM环境.");
  27. }
  28. #endif
  29. ASSERT(m_pRecordset != NULL);
  30. }
  32. CAdoRecordSet::CAdoRecordSet(CAdoConnection *pConnection)
  33. {
  34. m_SearchDirection = adSearchForward;
  35. m_pConnection = pConnection;
  36. ASSERT(m_pConnection != NULL);
  37. m_pRecordset.CreateInstance("ADODB.Recordset");
  38. #ifdef _DEBUG
  39. if (m_pRecordset == NULL)
  40. {
  41. AfxMessageBox("RecordSet 对象创建失败! 请确认是否初始化了COM环境.");
  42. }
  43. #endif
  44. ASSERT(m_pRecordset != NULL);
  45. }
  47. CAdoRecordSet::~CAdoRecordSet()
  48. {
  49. Release();
  50. }
  52. /*========================================================================
  53. Params:
  54. - strSQL: SQL语句, 表名, 存储过程调用或持久 Recordset 文件名.
  55. - CursorType:   可选. CursorTypeEnum 值, 确定打开 Recordset 时应该
  56. 使用的游标类型. 可为下列常量之一.
  57. [常量] [说明] 
  58. -----------------------------------------------
  59. adOpenForwardOnly 打开仅向前类型游标. 
  60. adOpenKeyset 打开键集类型游标. 
  61. adOpenDynamic 打开动态类型游标. 
  62. adOpenStatic 打开静态类型游标. 
  63. -----------------------------------------------
  64. - LockType:     可选, 确定打开 Recordset 时应该使用的锁定类型(并发)
  65. 的 LockTypeEnum 值, 可为下列常量之一.
  66. [常量] [说明] 
  67. -----------------------------------------------
  68. adLockReadOnly 只读 - 不能改变数据. 
  69. adLockPessimistic 保守式锁定 - 通常通过在编辑时立即锁定数据源的记录. 
  70. adLockOptimistic 开放式锁定 - 只在调用 Update 方法时才锁定记录. 
  71. adLockBatchOptimistic 开放式批更新 - 用于批更新模式(与立即更新模式
  72. 相对). 
  73. -----------------------------------------------
  74. - lOption 可选. 长整型值, 用于指示 strSQL 参数的类型. 可为下
  75. 列常量之一.
  76. [常量] [说明] 
  77. -------------------------------------------------
  78. adCmdText 指示strSQL为命令文本, 即普通的SQL语句. 
  79. adCmdTable 指示ADO生成SQL查询返回以 strSQL 命名的表中的
  80. 所有行. 
  81. adCmdTableDirect 指示所作的更改在strSQL中命名的表中返回所有行. 
  82. adCmdStoredProc 指示strSQL为存储过程. 
  83. adCmdUnknown 指示strSQL参数中的命令类型为未知. 
  84. adCmdFile 指示应从在strSQL中命名的文件中恢复保留(保存的)
  85. Recordset. 
  86. adAsyncExecute 指示应异步执行strSQL. 
  87. adAsyncFetch 指示在提取 Initial Fetch Size 属性中指定的初始
  88. 数量后, 应该异步提取所有剩余的行. 如果所需的行尚未
  89. 提取, 主要的线程将被堵塞直到行重新可用. 
  90. adAsyncFetchNonBlocking 指示主要线程在提取期间从未堵塞. 如果所请求
  91. 的行尚未提取, 当前行自动移到文件末尾. 
  92. ==========================================================================*/
  93. BOOL CAdoRecordSet::Open(LPCTSTR strSQL, long lOption, CursorTypeEnum CursorType, LockTypeEnum LockType)
  94. {
  95. ASSERT(m_pConnection != NULL);
  96. ASSERT(m_pRecordset != NULL);
  97. ASSERT(AfxIsValidString(strSQL));
  99. if(strcmp(strSQL, _T("")) != 0)
  100. {
  101. m_strSQL = strSQL;
  102. }
  103. if (m_pConnection == NULL || m_pRecordset == NULL)
  104. {
  105. return FALSE;
  106. }
  108. if (m_strSQL.IsEmpty())
  109. {
  110. ASSERT(FALSE);
  111. return FALSE;
  112. }
  114. try
  115. {
  116. if (IsOpen()) Close();
  117. return SUCCEEDED(m_pRecordset->Open(_variant_t(LPCTSTR(m_strSQL)), 
  118. _variant_t((IDispatch*)m_pConnection->GetConnection(), true),
  119. CursorType, LockType, lOption));
  120. }
  121. catch (_com_error e)
  122. {
  123. TRACE(_T("Warning: 打开记录集发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  124. TRACE(_T("%srn"), GetLastError());
  125. return FALSE;
  126. }
  127. }
  129. /*========================================================================
  130. Name: 通过重新执行对象所基于的查询, 更新 Recordset 对象中的数据.
  131.     ----------------------------------------------------------
  132. Params: Options   可选. 指示影响该操作选项的位屏蔽. 如果该参数设置
  133. 为 adAsyncExecute, 则该操作将异步执行并在它结束时产生 
  134. RecordsetChangeComplete 事件
  135.     ----------------------------------------------------------
  136. Remarks: 通过重新发出原始命令并再次检索数据, 可使用 Requery 方法刷新
  137. 来自数据源的 Recordset 对象的全部内容. 调用该方法等于相继调用 Close 和 
  138. Open 方法. 如果正在编辑当前记录或者添加新记录将产生错误.
  139. ==========================================================================*/
  140. BOOL CAdoRecordSet::Requery(long Options)
  141. {
  142. ASSERT(m_pRecordset != NULL);
  143. try
  144. {
  145. if (m_pRecordset != NULL) 
  146. {
  147. return (m_pRecordset->Requery(Options) == S_OK);
  148. }
  149. }
  150. catch (_com_error e)
  151. {
  152. TRACE(_T("Warning: Requery 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  153. return FALSE;
  154. } 
  155. return FALSE; 
  156. }
  158. /*========================================================================
  159. Name: 从基本数据库刷新当前 Recordset 对象中的数据.
  160.     ----------------------------------------------------------
  161. Params: AffectRecords:   可选, AffectEnum 值, 决定 Resync 方法所影
  162. 响的记录数目, 可以为下列常量之一.
  163. [常量] [说明]
  164. ------------------------------------
  165. adAffectCurrent 只刷新当前记录. 
  166. adAffectGroup 刷新满足当前 Filter 属性设置的记录.只有将 Filter
  167. 属性设置为有效预定义常量之一才能使用该选项. 
  168. adAffectAll 默认值.刷新 Recordset 对象中的所有记录, 包括由
  169. 于当前 Filter 属性设置而隐藏的记录. 
  170. adAffectAllChapters 刷新所有子集记录. 
  172. ResyncValues:   可选, ResyncEnum 值. 指定是否覆盖基本值. 可为下列
  173. 常量之一.
  174. [常量] [说明] 
  175. ------------------------------------
  176. adResyncAllValues 默认值. 覆盖数据, 取消挂起的更新. 
  177. adResyncUnderlyingValues 不覆盖数据, 不取消挂起的更新. 
  178.     ----------------------------------------------------------
  179. Remarks: 使用 Resync 方法将当前 Recordset 中的记录与基本的数据库重新
  180. 同步. 这在使用静态或仅向前的游标但希望看到基本数据库中的改动时十分有用.
  181. 如果将 CursorLocation 属性设置为 adUseClient, 则 Resync 仅对非只读的 
  182. Recordset 对象可用.
  183. 与 Requery 方法不同, Resync 方法不重新执行 Recordset 对象的基本的命令, 
  184. 基本的数据库中的新记录将不可见.
  185. ==========================================================================*/
  186. BOOL CAdoRecordSet::Resync(AffectEnum AffectRecords, ResyncEnum ResyncValues)
  187. {
  188. ASSERT(m_pRecordset != NULL);
  189. try
  190. {
  191. if (m_pRecordset != NULL) 
  192. {
  193. return (m_pRecordset->Resync(AffectRecords, ResyncValues) == S_OK);
  194. }
  195. }
  196. catch (_com_error e)
  197. {
  198. TRACE(_T("Warning: Resync 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  199. return FALSE;
  200. } 
  201. return FALSE; 
  202. }
  204. /*========================================================================
  205. Name: 将 Recordset 保存在持久性文件中.
  206.     ----------------------------------------------------------
  207. Params:
  208. [strFileName]:   可选. 文件的完整路径名, 用于保存 Recordset.
  209. [PersistFormat]:   可选. PersistFormatEnum 值, 指定保存 Recordset 所使
  210. 用的格式. 可以是如下的某个常量: 
  211. [常量] [说明] 
  212. ------------------------------
  213. adPersistADTG 使用专用的"Advanced Data Tablegram"格式保存. 
  214. adPersistXML (默认)使用 XML 格式保存. 
  215.     ----------------------------------------------------------
  216. Remarks: 只能对打开的 Recordset 调用 Save 方法. 随后使用 Load 方法可
  217. 以从文件中恢复 Recordset. 如果 Filter 属性影响 Recordset, 将只保存经过
  218. 筛选的行.
  219. 在第一次保存 Recordset 时指定 FileName. 如果随后调用 Save 时, 应忽
  220. 略 FileName, 否则将产生运行时错误. 如果随后使用新的 FileName 调用 Save, 
  221. 那么 Recordset 将保存到新的文件中, 但新文件和原始文件都是打开的.
  222. ==========================================================================*/
  223. BOOL CAdoRecordSet::Save(LPCTSTR strFileName, PersistFormatEnum PersistFormat)
  224. {
  225. ASSERT(m_pRecordset != NULL);
  226. ASSERT(IsOpen());
  228. if (m_strFileName == strFileName)
  229. {
  230. strFileName = NULL;
  231. }
  232. else if(_taccess(strFileName, 0) != -1)
  233. {
  234. DeleteFile(strFileName);
  235. m_strFileName = strFileName;
  236. }
  237. else
  238. {
  239. m_strFileName = strFileName;
  240. }
  242. try
  243. {
  244. if (m_pRecordset != NULL) 
  245. {
  246. return (m_pRecordset->Save(_bstr_t(strFileName), PersistFormat) == S_OK);
  247. }
  248. }
  249. catch (_com_error e)
  250. {
  251. TRACE(_T("Warning: Save 发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  252. return FALSE;
  253. } 
  254. return FALSE;
  255. }
  257. BOOL CAdoRecordSet::Load(LPCTSTR strFileName)
  258. {
  259. if (IsOpen()) Close();
  261. try
  262. {
  263. return (m_pRecordset->Open(strFileName, "Provider=MSPersist;", adOpenForwardOnly, adLockOptimistic, adCmdFile) == S_OK);
  264. }
  265. catch (_com_error &e)
  266. {
  267. TRACE(_T("Warning: Load 发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  268. return FALSE;
  269. }
  270. }
  272. /*========================================================================
  273. Name: 取消执行挂起的异步 Execute 或 Open 方法的调用.
  274. -----------------------------------------------------
  275. Remarks: 使用 Cancel 方法终止执行异步 Execute 或 Open 方法调用(即通
  276. 过 adAsyncConnect、adAsyncExecute 或 adAsyncFetch 参数调用的方法).
  277. 如果在试图终止的方法中没有使用 adAsyncExecute, 则 Cancel 将返回运行
  278. 时错误.
  279. ==========================================================================*/
  280. BOOL CAdoRecordSet::Cancel()
  281. {
  282. ASSERT(m_pRecordset != NULL);
  283. try
  284. {
  285. return m_pRecordset->Cancel();
  286. }
  287. catch (_com_error e)
  288. {
  289. TRACE(_T("Warning: Cancel发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  290. return FALSE;
  291. } 
  292. return FALSE;
  293. }
  295. /*========================================================================
  296. Name: 关闭打开的对象及任何相关对象.
  297. -----------------------------------------------------
  298. Remarks: 使用 Close 方法可关闭 Recordset 对象以便释放所有关联的系统
  299. 资源. 关闭对象并非将它从内存中删除, 可以更改它的属性设置并且在此后
  300. 再次打开. 要将对象从内存中完全删除, 可将对象变量设置为 NULL.
  301. 如果正在立即更新模式下进行编辑, 调用Close方法将产生错误,应首先
  302. 调用 Update 或 CancelUpdat 方法. 如果在批更新期间关闭 Recordset 对
  303. 象, 则自上次 UpdateBatch 调用以来所做的修改将全部丢失.
  304. 如果使用 Clone 方法创建已打开的 Recordset 对象的副本, 关闭原始
  305. Recordset或其副本将不影响任何其他副本.
  306. ==========================================================================*/
  307. void CAdoRecordSet::Close()
  308. {
  309. try
  310. {
  311. if (m_pRecordset != NULL && m_pRecordset->State != adStateClosed)
  312. {
  313. if (GetEditMode() == adEditNone) CancelUpdate();
  314. m_pRecordset->Close();
  315. }
  316. }
  317. catch (const _com_error& e)
  318. {
  319. TRACE(_T("Warning: 关闭记录集发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  320. }
  321. }
  323. /*========================================================================
  324. Name: 关闭连接并释放对象.
  325. -----------------------------------------------------
  326. Remarks: 关闭连接并释放CAdoRecordSet对象, 这样基本上从内容中完全清除了
  327. CAdoRecordSet对象.
  328. ==========================================================================*/
  329. void CAdoRecordSet::Release()
  330. {
  331. if (IsOpen()) Close();
  332. m_pRecordset.Release();
  333. m_pRecordset = NULL;
  334. }
  337. /*########################################################################
  338.   ------------------------------------------------
  339.    记录集更新操作
  340.   ------------------------------------------------
  341.   ########################################################################*/
  343. /*========================================================================
  344. Remarks: 开始添加新的纪录. 
  345. ==========================================================================*/
  346. BOOL CAdoRecordSet::AddNew()
  347. {
  348. ASSERT(m_pRecordset != NULL);
  349. try
  350. {
  351. if (m_pRecordset != NULL) 
  352. {
  353. if (m_pRecordset->AddNew() == S_OK)
  354. {
  355. return TRUE;
  356. }
  357. }
  358. }
  359. catch (_com_error e)
  360. {
  361. TRACE(_T("Warning: AddNew 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  362. return FALSE;
  363. } 
  364. return FALSE;
  365. }
  367. /*========================================================================
  368. Remarks: 在调用 AddNew 等方法后, 调用此方法完成更新或修改.
  369. ==========================================================================*/
  370. BOOL CAdoRecordSet::Update()
  371. {
  372. ASSERT(m_pRecordset != NULL);
  373. try
  374. {
  375. if (m_pRecordset != NULL) 
  376. {
  377. if (m_pRecordset->Update() == S_OK)
  378. {
  379. return TRUE;
  380. }
  381. }
  382. }
  383. catch (_com_error e)
  384. {
  385. TRACE(_T("Warning: Update 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  386. }
  388. CancelUpdate();
  389. return FALSE;
  390. }
  392. /*========================================================================
  393. Name: 将所有挂起的批更新写入磁盘.
  394.     ----------------------------------------------------------
  395. Params: AffectRecords   可选, AffectEnum 值. 决定 UpdateBatch 方法
  396. 所影响的记录数目.可以为如下常量之一.
  397. [常量] [说明] 
  398. ------------------------------------
  399. adAffectCurrent 只写入当前记录的挂起更改. 
  400. adAffectGroup 写入满足当前 Filter 属性设置的记录所发生的挂起
  401. 更改. 必须将 Filter 属性设置为某个有效的预定义常量才能使用该选项. 
  402. adAffectAll (默认值). 写入 Recordset 对象中所有记录的挂起
  403. 更改, 包括由于当前 Filter 属性设置而隐藏的任何记录. 
  404. adAffectAllChapters 写入所有子集的挂起更改. 
  405.     ----------------------------------------------------------
  406. Remarks: 按批更新模式修改 Recordset 对象时, 使用 UpdateBatch 方法可
  407. 将 Recordset 对象中的所有更改传递到基本数据库.
  408. 如果 Recordset 对象支持批更新, 那么可以将一个或多个记录的多重更改缓存在
  409. 本地, 然后再调用 UpdateBatch 方法. 如果在调用 UpdateBatch 方法时正在编
  410. 辑当前记录或者添加新的记录, 那么在将批更新传送到提供者之前, ADO 将自动
  411. 调用 Update 方法保存对当前记录的所有挂起更改.
  412.    只能对键集或静态游标使用批更新.
  413. ==========================================================================*/
  414. BOOL CAdoRecordSet::UpdateBatch(AffectEnum AffectRecords)
  415. {
  416. ASSERT(m_pRecordset != NULL);
  417. try
  418. {
  419. if (m_pRecordset != NULL) 
  420. {
  421. return (m_pRecordset->UpdateBatch(AffectRecords) == S_OK);
  422. }
  423. }
  424. catch (_com_error e)
  425. {
  426. TRACE(_T("Warning: UpdateBatch 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  427. return FALSE;
  428. } 
  429. return FALSE; 
  430. }
  432. /*========================================================================
  433. Name: 取消在调用 Update 方法前对当前记录或新记录所作的任何更改.
  434. -----------------------------------------------------
  435. Remarks: 使用 CancelUpdate 方法可取消对当前记录所作的任何更改或放弃
  436. 新添加的记录. 在调用 Update 方法后将无法撤消对当前记录或新记录所做的更
  437. 改, 除非更改是可以用 RollbackTrans 方法回卷的事务的一部分, 或者是可以
  438. 用 CancelBatch 方法取消的批更新的一部分.
  439. 如果在调用 CancelUpdate 方法时添加新记录, 则调用 AddNew 之前的当前
  440. 记录将再次成为当前记录.
  441. 如果尚未更改当前记录或添加新记录, 调用 CancelUpdate 方法将产生错误.
  442. ==========================================================================*/
  443. BOOL CAdoRecordSet::CancelUpdate()
  444. {
  445. ASSERT(m_pRecordset != NULL);
  446. try
  447. {
  448. if (m_pRecordset != NULL) 
  449. {
  450. if (GetEditMode() == adEditNone || m_pRecordset->CancelUpdate() == S_OK)
  451. {
  452. return TRUE;
  453. }
  454. }
  455. }
  456. catch (_com_error e)
  457. {
  458. TRACE(_T("Warning: CancelUpdate 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  459. return FALSE;
  460. } 
  461. return FALSE;
  462. }
  464. /*========================================================================
  465. Name: 取消挂起的批更新.
  466. -----------------------------------------------------
  467. Params: AffectRecords   可选的 AffectEnum 值, 决定CancelBatch 方法
  468. 所影响记录的数目, 可为下列常量之一: 
  469. [常量] [说明] 
  470. -------------------------------------------------
  471. AdAffectCurrent 仅取消当前记录的挂起更新. 
  472. AdAffectGroup 对满足当前 Filter 属性设置的记录取消挂起更新.
  473. 使用该选项时,必须将 Filter 属性设置为合法的预
  474. 定义常量之一. 
  475. AdAffectAll 默认值.取消 Recordset 对象中所有记录的挂起更
  476. 新,包括由当前 Filter 属性设置所隐藏的任何记录. 
  477. ==========================================================================*/
  478. BOOL CAdoRecordSet::CancelBatch(AffectEnum AffectRecords)
  479. {
  480. ASSERT(m_pRecordset != NULL);
  481. try
  482. {
  483. if (m_pRecordset != NULL) 
  484. {
  485. return (m_pRecordset->CancelBatch(AffectRecords) == S_OK);
  486. }
  487. }
  488. catch (_com_error e)
  489. {
  490. TRACE(_T("Warning: CancelBatch 发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  491. return FALSE;
  492. } 
  493. return FALSE;
  494. }
  496. /*========================================================================
  497. Params:  AffectRecords:  AffectEnum 值, 确定 Delete 方法所影响的记
  498. 录数目, 该值可以是下列常量之一.
  499. [常量] [说明 ]
  500. -------------------------------------------------
  501. AdAffectCurrent 默认. 仅删除当前记录. 
  502. AdAffectGroup 删除满足当前 Filter 属性设置的记录. 要使用该选
  503. 项, 必须将 Filter 属性设置为有效的预定义常量之一. 
  504. adAffectAll 删除所有记录. 
  505. adAffectAllChapters 删除所有子集记录. 
  506. ==========================================================================*/
  507. BOOL CAdoRecordSet::Delete(AffectEnum AffectRecords)
  508. {
  509. ASSERT(m_pRecordset != NULL);
  510. try
  511. {
  512. if (m_pRecordset != NULL) 
  513. {
  514. return (m_pRecordset->Delete(AffectRecords) == S_OK);
  515. }
  516. }
  517. catch (_com_error e)
  518. {
  519. TRACE(_T("Warning: Delete发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  520. return FALSE;
  521. } 
  522. return FALSE;
  523. }
  525. /*########################################################################
  526.   ------------------------------------------------
  527. 记录集导航操作
  528.   ------------------------------------------------
  529.   ########################################################################*/
  531. /*========================================================================
  532. Name: 将当前记录位置移动到 Recordse 中的第一个记录.
  533. ==========================================================================*/
  534. BOOL CAdoRecordSet::MoveFirst()
  535. {
  536. ASSERT(m_pRecordset != NULL);
  537. try
  538. {
  539. if (m_pRecordset != NULL) 
  540. {
  541. return SUCCEEDED(m_pRecordset->MoveFirst());
  542. }
  543. }
  544. catch (_com_error e)
  545. {
  546. TRACE(_T("Warning: MoveFirst 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  547. return FALSE;
  548. } 
  549. return FALSE;
  550. }
  552. /*========================================================================
  553. Name: 将当前记录位置移动到 Recordset 中的最后一个记录.
  554. -----------------------------------------------------
  555. Remarks: Recordset 对象必须支持书签或向后光标移动; 否则调用该方法将
  556. 产生错误.
  557. ==========================================================================*/
  558. BOOL CAdoRecordSet::MoveLast()
  559. {
  560. ASSERT(m_pRecordset != NULL);
  561. try
  562. {
  563. if (m_pRecordset != NULL) 
  564. {
  565. return SUCCEEDED(m_pRecordset->MoveLast());
  566. }
  567. }
  568. catch (_com_error e)
  569. {
  570. TRACE(_T("Warning: MoveLast 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  571. return FALSE;
  572. } 
  573. return FALSE;
  574. }
  576. /*========================================================================
  577. Name: 将当前记录位置向后移动一个记录(向记录集的顶部).
  578. -----------------------------------------------------
  579. Remarks: Recordset 对象必须支持书签或向后游标移动; 否则方法调用将产
  580. 生错误.如果首记录是当前记录并且调用 MovePrevious 方法, 则 ADO 将当前记
  581. 录设置在 Recordset (BOF为True) 的首记录之前. 而BOF属性为 True 时向后移
  582. 动将产生错误. 如果 Recordse 对象不支持书签或向后游标移动, 则 MovePrevious 
  583. 方法将产生错误.
  584. ==========================================================================*/
  585. BOOL CAdoRecordSet::MovePrevious()
  586. {
  587. ASSERT(m_pRecordset != NULL);
  588. try
  589. {
  590. if (m_pRecordset != NULL) 
  591. {
  592. return SUCCEEDED(m_pRecordset->MovePrevious());
  593. }
  594. }
  595. catch (_com_error e)
  596. {
  597. TRACE(_T("Warning: MovePrevious 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  598. return FALSE;
  599. }
  600. return FALSE;
  601. }
  603. /*========================================================================
  604. Name: 将当前记录向前移动一个记录(向 Recordset 的底部).
  605. -----------------------------------------------------
  606. Remarks: 如果最后一个记录是当前记录并且调用 MoveNext 方法, 则 ADO 将
  607. 当前记录设置到 Recordset (EOF为 True)的尾记录之后. 当 EOF 属性已经为 
  608. True 时试图向前移动将产生错误.
  609. ==========================================================================*/
  610. BOOL CAdoRecordSet::MoveNext()
  611. {
  612. ASSERT(m_pRecordset != NULL);
  613. try
  614. {
  615. if (m_pRecordset != NULL) 
  616. {
  617. return SUCCEEDED(m_pRecordset->MoveNext());
  618. }
  619. }
  620. catch (_com_error e)
  621. {
  622. TRACE(_T("Warning: MoveNext 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  623. return FALSE;
  624. }
  625. return FALSE;
  626. }
  628. /*========================================================================
  629. Name: 移动 Recordset 对象中当前记录的位置.
  630.     ----------------------------------------------------------
  631. Params:
  632. - lRecords    带符号长整型表达式, 指定当前记录位置移动的记录数.
  633. - Start    可选, 字符串或变体型, 用于计算书签. 也可为下列 
  634. BookmarkEnum 值之一: 
  635. [常量] [说明] 
  636. --------------------------------
  637. adBookmarkCurrent 默认. 从当前记录开始. 
  638. adBookmarkFirst 从首记录开始. 
  639. adBookmarkLast 从尾记录开始. 
  640. ==========================================================================*/
  641. BOOL CAdoRecordSet::Move(long lRecords, _variant_t Start)
  642. {
  643. ASSERT(m_pRecordset != NULL);
  644. try
  645. {
  646. if (m_pRecordset != NULL) 
  647. {
  648. return SUCCEEDED(m_pRecordset->Move(lRecords, _variant_t(Start)));
  649. }
  650. }
  651. catch (_com_error e)
  652. {
  653. TRACE(_T("Warning: Move 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  654. return FALSE;
  655. } 
  656. return FALSE;
  657. }
  659. /*########################################################################
  660.   ------------------------------------------------
  661.   记录集属性
  662.   ------------------------------------------------
  663.   ########################################################################*/
  665. /*========================================================================
  666. Name: 取得记录集对象的状态(是打开状态还是关闭状态). 对异步方式执
  667. 行的 Recordset 对象, 则说明当前的对象状态是连接、执行还是获取状态.
  668. -----------------------------------------------------
  669. returns: 返回下列常量之一的长整型值.
  670. [常量] [说明] 
  671. ----------------------------------
  672. adStateClosed 指示对象是关闭的. 
  673. adStateOpen 指示对象是打开的. 
  674. adStateConnecting 指示 Recordset 对象正在连接. 
  675. adStateExecuting 指示 Recordset 对象正在执行命令. 
  676. adStateFetching 指示 Recordset 对象的行正在被读取. 
  677. -----------------------------------------------------
  678. Remarks:  可以随时使用 State 属性确定指定对象的当前状态. 该属性是只
  679. 读的. Recordset 对象的 State 属性可以是组合值. 例如: 如果正在执行语句,
  680. 该属性将是 adStateOpen 和 adStateExecuting 的组合值.
  681. ==========================================================================*/
  682. long CAdoRecordSet::GetState()
  683. {
  684. ASSERT(m_pRecordset != NULL);
  685. try
  686. {
  687. return m_pRecordset->GetState();
  688. }
  689. catch (_com_error e)
  690. {
  691. TRACE(_T("Warning: GetState 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  692. return -1;
  693. } 
  694. return -1;
  695. }
  697. BOOL CAdoRecordSet::IsOpen()
  698. {
  699. try
  700. {
  701. return (m_pRecordset != NULL && (GetState() & adStateOpen));
  702. }
  703. catch (_com_error e)
  704. {
  705. TRACE(_T("Warning: IsOpen方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  706. return FALSE;
  707. } 
  708. return FALSE;
  709. }
  711. /*========================================================================
  712. Name: 指示有关批更新或其他大量操作的当前记录的状态.
  713. -----------------------------------------------------
  714. returns: 返回下列一个或多个 RecordStatusEnum 值之和.
  715. [常量] [说明]
  716. -------------------------------------------------
  717. adRecOK 成功地更新记录. 
  718. adRecNew 记录是新建的. 
  719. adRecModified 记录被修改. 
  720. adRecDeleted 记录被删除. 
  721. adRecUnmodified 记录没有修改. 
  722. adRecInvalid 由于书签无效, 记录没有保存. 
  723. adRecMultipleChanges 由于影响多个记录, 因此记录未被保存. 
  724. adRecPendingChanges 由于记录引用挂起的插入, 因此未被保存. 
  725. adRecCanceled 由于操作被取消, 未保存记录. 
  726. adRecCantRelease 由于现有记录锁定, 没有保存新记录. 
  727. adRecConcurrencyViolation 由于开放式并发在使用中, 记录未被保存. 
  728. adRecIntegrityViolation 由于用户违反完整性约束, 记录未被保存. 
  729. adRecMaxChangesExceeded 由于存在过多挂起更改, 记录未被保存. 
  730. adRecObjectOpen 由于与打开的储存对象冲突, 记录未被保存. 
  731. adRecOutOfMemory 由于计算机内存不足, 记录未被保存. 
  732. adRecPermissionDenied 由于用户没有足够的权限, 记录未被保存. 
  733. adRecSchemaViolation 由于记录违反基本数据库的结构, 因此未被保存. 
  734. adRecDBDeleted 记录已经从数据源中删除. 
  735. -----------------------------------------------------
  736. Remarks: 使用 Status 属性查看在批更新中被修改的记录有哪些更改被挂起.
  737. 也可使用 Status 属性查看大量操作时失败记录的状态. 例如, 调用 Recordset
  738. 对象的 Resync、UpdateBatch 或 CancelBatch 方法, 或者设置 Recordset 对象
  739. 的 Filter 属性为书签数组. 使用该属性, 可检查指定记录为何失败并将问题解
  740. 决.
  741. ==========================================================================*/
  742. long CAdoRecordSet::GetStatus()
  743. {
  744. ASSERT(m_pRecordset != NULL);
  745. try
  746. {
  747. return m_pRecordset->GetStatus();
  748. }
  749. catch (_com_error e)
  750. {
  751. TRACE(_T("Warning: GetStatus 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  752. return -1;
  753. } 
  754. return -1;
  755. }
  757. /*========================================================================
  758. Name: 获取当前记录集中记录数目
  759. ==========================================================================*/
  760. long CAdoRecordSet::GetRecordCount()
  761. {
  762. ASSERT(m_pRecordset != NULL);
  763. try
  764. {
  765. long count = m_pRecordset->GetRecordCount();
  767. // 如果ado不支持此属性，则手工计算记录数目 --------
  768. if (count < 0)
  769. {
  770. long pos = GetAbsolutePosition();
  771. MoveFirst();
  772. count = 0;
  773. while (!IsEOF()) 
  774. {
  775. count++;
  776. MoveNext();
  777. }
  778. SetAbsolutePosition(pos);
  779. }
  780. return count;
  781. }
  782. catch (_com_error e)
  783. {
  784. TRACE(_T("Warning: GetRecordCount 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  785. return -1;
  786. } 
  787. }
  789. /*========================================================================
  790. Name: 获取当前记录集中字段数目
  791. ==========================================================================*/
  792. long CAdoRecordSet::GetFieldsCount()
  793. {
  794. ASSERT(m_pRecordset != NULL);
  795. try
  796. {
  797. return GetFields()->Count;
  798. }
  799. catch(_com_error e)
  800. {
  801. TRACE(_T("Warning: GetFieldsCount 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  802. return -1;
  803. } 
  804. }
  805. /*========================================================================
  806. Name: 指示通过查询返回 Recordset 的记录的最大数目. 
  807. ==========================================================================*/
  808. long CAdoRecordSet::GetMaxRecordCount()
  809. {
  810. ASSERT(m_pRecordset != NULL);
  812. try
  813. {
  814. return m_pRecordset->GetMaxRecords();
  815. }
  816. catch (_com_error e)
  817. {
  818. TRACE(_T("Warning: GetMaxRecordCount 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  819. return -1;
  820. }
  821. }
  822. BOOL CAdoRecordSet::SetMaxRecordCount(long count)
  823. {
  824. ASSERT(m_pRecordset != NULL);
  826. try
  827. {
  828. m_pRecordset->PutMaxRecords(count);
  829. return TRUE;
  830. }
  831. catch (_com_error e)
  832. {
  833. TRACE(_T("Warning: GetMaxRecordCount 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  834. return FALSE;
  835. }
  836. }
  838. /*========================================================================
  839. Name: 指针是否在在记录集头
  840. ==========================================================================*/
  841. BOOL CAdoRecordSet::IsBOF()
  842. {
  843. ASSERT(m_pRecordset != NULL);
  844. try
  845. {
  846. return m_pRecordset->adoBOF;
  847. }
  848. catch(_com_error e)
  849. {
  850. TRACE(_T("Warning: IsBOF 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  851. return FALSE;
  852. } 
  853. return FALSE;
  854. }
  856. /*========================================================================
  857. Name: 指针是否在在记录集尾
  858. ==========================================================================*/
  859. BOOL CAdoRecordSet::IsEOF()
  860. {
  861. ASSERT(m_pRecordset != NULL);
  862. try
  863. {
  864. return m_pRecordset->adoEOF;
  865. }
  866. catch (_com_error e)
  867. {
  868. TRACE(_T("Warning: IsEOF 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  869. return FALSE;
  870. }
  871. }
  873. EditModeEnum CAdoRecordSet::GetEditMode()
  874. {
  875. ASSERT(m_pRecordset != NULL);
  876. try
  877. {
  878. if (m_pRecordset != NULL) 
  879. {
  880. return m_pRecordset->GetEditMode();
  881. }
  882. }
  883. catch (_com_error e)
  884. {
  885. TRACE(_T("Warning: UpdateBatch 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  886. return adEditNone;
  887. } 
  888. return adEditNone; 
  889. }
  891. long CAdoRecordSet::GetPageCount()
  892. {
  893. ASSERT(m_pRecordset != NULL);
  895. try
  896. {
  897. return m_pRecordset->GetPageCount();
  898. }
  899. catch (_com_error &e)
  900. {
  901. TRACE(_T("Warning: GetPageCount 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  902. return -1;
  903. }
  904. }
  906. BOOL CAdoRecordSet::SetCacheSize(const long &lCacheSize)
  907. {
  908. ASSERT(m_pRecordset != NULL);
  909. try
  910. {
  911. if (m_pRecordset != NULL && !(GetState() & adStateExecuting))
  912. {
  913. m_pRecordset->PutCacheSize(lCacheSize);
  914. }
  915. }
  916. catch (const _com_error& e)
  917. {
  918. TRACE(_T("Warning: SetCacheSize方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  919. return FALSE;
  920. }
  921. return TRUE;
  922. }
  924. long CAdoRecordSet::GetPageSize()
  925. {
  926. ASSERT(m_pRecordset != NULL);
  928. try
  929. {
  930. return m_pRecordset->GetPageSize();
  931. }
  932. catch (_com_error &e)
  933. {
  934. TRACE(_T("Warning: GetPageCount 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  935. return -1;
  936. }
  937. }
  939. /*========================================================================
  940. name: 指定当前记录所在的页.
  941.     ----------------------------------------------------------
  942. returns: 置或返回从 1 到 Recordset 对象 (PageCount) 所含页数的长整型
  943. 值，或者返回以下常量. 
  944. [常量] [说明]
  945. ---------------------------------
  946. adPosUnknown Recordset 为空，当前位置未知，或者提供者不支持 AbsolutePage 属性.  
  947. adPosBOF 当前记录指针位于 BOF(即 BOF 属性为 True).  
  948. adPosEOF 当前记录指针位于 EOF(即 EOF 属性为 True).  
  949. ==========================================================================*/
  950. BOOL CAdoRecordSet::SetAbsolutePage(int nPage)
  951. {
  952. ASSERT(m_pRecordset != NULL);
  954. try
  955. {
  956. m_pRecordset->PutAbsolutePage((enum PositionEnum)nPage);
  957. return TRUE;
  958. }
  959. catch(_com_error &e)
  960. {
  961. TRACE(_T("Warning: SetAbsolutePage 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  962. return FALSE;
  963. }
  964. }
  966. long CAdoRecordSet::GetAbsolutePage()
  967. {
  968. ASSERT(m_pRecordset != NULL);
  970. try
  971. {
  972. return m_pRecordset->GetAbsolutePage();
  973. }
  974. catch(_com_error &e)
  975. {
  976. TRACE(_T("Warning: GetAbsolutePage 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  977. return -1;
  978. }
  979. }
  981. /*========================================================================
  982. name: 指定 Recordset 对象当前记录的序号位置. 
  983.     ----------------------------------------------------------
  984. returns: 设置或返回从 1 到 Recordset 对象 (PageCount) 所含页数的长整
  985. 型值，或者返回以下常量. 
  986. [常量] [说明]
  987. ---------------------------------
  988. adPosUnknown Recordset 为空，当前位置未知，或者提供者不支持 AbsolutePage 属性.  
  989. adPosBOF 当前记录指针位于 BOF(即 BOF 属性为 True).  
  990. adPosEOF 当前记录指针位于 EOF(即 EOF 属性为 True).  
  991.     ----------------------------------------------------------
  992. Remarks: 使用 AbsolutePosition 属性可根据其在 Recordset 中的序号
  993. 位置移动到记录，或确定当前记录的序号位置. 提供者必须支持该属性的相应功
  994. 能才能使用该属性. 
  995. 同 AbsolutePage 属性一样，AbsolutePosition 从 1 开始，并在当前记录
  996. 为 Recordset 中的第一个记录时等于 1. 从 RecordCount 属性可获得 Recordset 
  997. 对象的总记录数. 
  998. 设置 AbsolutePosition 属性时，即使该属性指向位于当前缓存中的记录，
  999. ADO 也将使用以指定的记录开始的新记录组重新加载缓存. CacheSize 属性决定
  1000. 该记录组的大小. 
  1001. 注意   不能将 AbsolutePosition 属性作为替代的记录编号使用. 删除前面
  1002. 的记录时，给定记录的当前位置将发生改变. 如果 Recordset 对象被重新查询或
  1003. 重新打开，则无法保证给定记录有相同的 AbsolutePosition. 书签仍然是保持和
  1004. 返回给定位置的推荐方式，并且在所有类型的 Recordset 对象的定位时是唯一的
  1005. 方式. 
  1006. ==========================================================================*/
  1007. BOOL CAdoRecordSet::SetAbsolutePosition(int nPosition)
  1008. {
  1009. ASSERT(m_pRecordset != NULL);
  1011. try
  1012. {
  1013. m_pRecordset->PutAbsolutePosition((enum PositionEnum)nPosition);
  1014. return TRUE;
  1015. }
  1016. catch(_com_error &e)
  1017. {
  1018. TRACE(_T("Warning: SetAbsolutePosition 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1019. return FALSE;
  1020. }
  1021. }
  1023. long CAdoRecordSet::GetAbsolutePosition()
  1024. {
  1025. ASSERT(m_pRecordset != NULL);
  1027. try
  1028. {
  1029. return m_pRecordset->GetAbsolutePosition();
  1030. }
  1031. catch(_com_error &e)
  1032. {
  1033. TRACE(_T("Warning: GetAbsolutePosition 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1034. return -1;
  1035. }
  1036. }
  1038. BOOL CAdoRecordSet::SetCursorLocation(CursorLocationEnum CursorLocation)
  1039. {
  1040. ASSERT(m_pRecordset != NULL);
  1041. try
  1042. {
  1043. m_pRecordset->PutCursorLocation(CursorLocation);
  1044. return TRUE;
  1045. }
  1046. catch (_com_error e)
  1047. {
  1048. TRACE(_T("Warning: PutCursorLocation 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1049. return FALSE;
  1050. }
  1051. }
  1053. CursorLocationEnum CAdoRecordSet::GetCursorLocation()
  1054. {
  1055. ASSERT(m_pRecordset != NULL);
  1056. try
  1057. {
  1058. return m_pRecordset->GetCursorLocation();
  1059. }
  1060. catch (_com_error e)
  1061. {
  1062. TRACE(_T("Warning: GetCursorLocation 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1063. return adUseNone;
  1064. }
  1065. }
  1067. BOOL CAdoRecordSet::SetCursorType(CursorTypeEnum CursorType)
  1068. {
  1069. ASSERT(m_pRecordset != NULL);
  1070. try
  1071. {
  1072. m_pRecordset->PutCursorType(CursorType);
  1073. return TRUE;
  1074. }
  1075. catch (_com_error e)
  1076. {
  1077. TRACE(_T("Warning: SetCursorType 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1078. return FALSE;
  1079. }
  1080. }
  1082. CursorTypeEnum CAdoRecordSet::GetCursorType()
  1083. {
  1084. ASSERT(m_pRecordset != NULL);
  1085. try
  1086. {
  1087. return m_pRecordset->GetCursorType();
  1088. }
  1089. catch (_com_error e)
  1090. {
  1091. TRACE(_T("Warning: GetCursorType 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1092. return adOpenUnspecified;
  1093. }
  1094. }
  1096. /*========================================================================
  1097. Remarks: Recordset 对象包括 Field 对象组成的 Fields 集合. 每个Field
  1098.  对象对应 Recordset 集中的一列.
  1099. ==========================================================================*/
  1100. FieldsPtr CAdoRecordSet::GetFields()
  1101. {
  1102. ASSERT(m_pRecordset != NULL);
  1103. try
  1104. {
  1105. return m_pRecordset->GetFields();
  1106. }
  1107. catch (_com_error e)
  1108. {
  1109. TRACE(_T("Warning: GetFields 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1110. return NULL;
  1111. } 
  1112. return NULL;
  1113. }
  1115. /*========================================================================
  1116. Remarks: 取得指定列字段的字段名.
  1117. ==========================================================================*/
  1118. CString CAdoRecordSet::GetFieldName(long lIndex)
  1119. {
  1120. ASSERT(m_pRecordset != NULL);
  1121. CString strFieldName;
  1122. try
  1123. {
  1124. strFieldName = LPCTSTR(m_pRecordset->Fields->GetItem(_variant_t(lIndex))->GetName());
  1125. }
  1126. catch (_com_error e)
  1127. {
  1128. TRACE(_T("Warning: GetFieldName 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1129. }
  1130. return strFieldName;
  1131. }
  1133. /*========================================================================
  1134. name: 取得 Field 对象一项或多项属性.
  1135.     ----------------------------------------------------------
  1136. returns: 对于 Field 对象, Attributes 属性为只读, 其值可能为以下任意
  1137. 一个或多个 FieldAttributeEnum 值的和.
  1138.   [常量] [说明] 
  1139.   -------------------------------------------
  1140.   adFldMayDefer 指示字段被延迟, 即不从拥有整个记录的数据源检索
  1141. 字段值, 仅在显式访问这些字段时才进行检索. 
  1142.   adFldUpdatable 指示可以写入该字段. 
  1143.   adFldUnknownUpdatable 指示提供者无法确定是否可以写入该字段. 
  1144.   adFldFixed 指示该字段包含定长数据. 
  1145.   adFldIsNullable 指示该字段接受 Null 值. 
  1146.   adFldMayBeNull 指示可以从该字段读取 Null 值. 
  1147.   adFldLong 指示该字段为长二进制字段. 并指示可以使用 AppendChunk 
  1148. 和 GetChunk 方法. 
  1149.   adFldRowID 指示字段包含持久的行标识符, 该标识符无法被写入
  1150. 并且除了对行进行标识(如记录号、唯一标识符等)外不
  1151. 存在有意义的值. 
  1152.   adFldRowVersion 指示该字段包含用来跟踪更新的某种时间或日期标记. 
  1153.   adFldCacheDeferred 指示提供者缓存了字段值, 并已完成随后对缓存的读取. 
  1154. ==========================================================================*/
  1155. long CAdoRecordSet::GetFieldAttributes(long lIndex)
  1156. {
  1157. ASSERT(m_pRecordset != NULL);
  1158. try
  1159. {
  1160. return m_pRecordset->Fields->GetItem(_variant_t(lIndex))->GetAttributes();
  1161. }
  1162. catch (_com_error e)
  1163. {
  1164. TRACE(_T("Warning: GetFieldAttributes 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1165. return -1;
  1166. }
  1167. }
  1169. long CAdoRecordSet::GetFieldAttributes(LPCTSTR lpszFieldName)
  1170. {
  1171. ASSERT(m_pRecordset != NULL);
  1172. try
  1173. {
  1174. return m_pRecordset->Fields->GetItem(_variant_t(lpszFieldName))->GetAttributes();
  1175. }
  1176. catch (_com_error e)
  1177. {
  1178. TRACE(_T("Warning: GetFieldAttributes 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1179. return -1;
  1180. }
  1181. }
  1183. /*========================================================================
  1184. Name: 指示 Field 对象所定义的长度.
  1185.     ----------------------------------------------------------
  1186. returns: 返回某个字段定义的长度(按字节数)的长整型值.
  1187.     ----------------------------------------------------------
  1188. Remarks: 使用 DefinedSize 属性可确定 Field 对象的数据容量.
  1189. ==========================================================================*/
  1190. long CAdoRecordSet::GetFieldDefineSize(long lIndex)
  1191. {
  1192. ASSERT(m_pRecordset != NULL);
  1193. try
  1194. {
  1195. return m_pRecordset->Fields->GetItem(_variant_t(lIndex))->DefinedSize;
  1196. }
  1197. catch (_com_error e)
  1198. {
  1199. TRACE(_T("Warning: GetDefineSize 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1200. return -1;
  1201. }
  1202. }
  1204. long CAdoRecordSet::GetFieldDefineSize(LPCTSTR lpszFieldName)
  1205. {
  1206. ASSERT(m_pRecordset != NULL);
  1207. try
  1208. {
  1209. return m_pRecordset->Fields->GetItem(_variant_t(lpszFieldName))->DefinedSize;
  1210. }
  1211. catch (_com_error e)
  1212. {
  1213. TRACE(_T("Warning: GetDefineSize 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1214. return -1;
  1215. }
  1216. }
  1218. /*========================================================================
  1219. Name: 取得字段的值的实际长度.
  1220.     ----------------------------------------------------------
  1221. returns: 返回长整型值.某些提供者允许设置该属性以便为 BLOB 数据预留
  1222. 空间, 在此情况下默认值为 0.
  1223.     ----------------------------------------------------------
  1224. Remarks: 使用 ActualSize 属性可返回 Field 对象值的实际长度.对于所有
  1225. 字段,ActualSize 属性为只读.如果 ADO 无法确定 Field 对象值的实
  1226. 际长度, ActualSize 属性将返回 adUnknown.
  1227. 如以下范例所示, ActualSize 和  DefinedSize 属性有所不同: 
  1228. adVarChar 声明类型且最大长度为 50 个字符的 Field 对象将返回为 
  1229. 50 的 DefinedSize 属性值, 但是返回的 ActualSize 属性值是当前记
  1230. 录的字段中存储的数据的长度.
  1231. ==========================================================================*/
  1232. long CAdoRecordSet::GetFieldActualSize(long lIndex)
  1233. {
  1234. ASSERT(m_pRecordset != NULL);
  1235. try
  1236. {
  1237. return m_pRecordset->Fields->GetItem(_variant_t(lIndex))->ActualSize;
  1238. }
  1239. catch (_com_error e)
  1240. {
  1241. TRACE(_T("Warning: GetFieldActualSize 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1242. return -1;
  1243. }
  1244. }
  1246. long CAdoRecordSet::GetFieldActualSize(LPCTSTR lpszFieldName)
  1247. {
  1248. ASSERT(m_pRecordset != NULL);
  1249. try
  1250. {
  1251. return m_pRecordset->Fields->GetItem(_variant_t(lpszFieldName))->ActualSize;
  1252. }
  1253. catch (_com_error e)
  1254. {
  1255. TRACE(_T("Warning: GetFieldActualSize 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1256. return -1;
  1257. }
  1258. }
  1260. /*========================================================================
  1261. returns: 返回下列值之一. 相应的 OLE DB 类型标识符在下表的说明栏的括
  1262. 号中给出.
  1263.   [常量] [说明] 
  1264.   ---------------------------------------------------------
  1265.   adArray 与其他类型一起加入逻辑 OR 以指示该数据是那种类型的
  1266. 安全数组 (DBTYPE_ARRAY). 
  1267.   adBigInt 8 字节带符号的整数 (DBTYPE_I8). 
  1268.   adBinary 二进制值 (DBTYPE_BYTES). 
  1269.   adBoolean 布尔型值 (DBTYPE_BOOL). 
  1270.   adByRef 与其他类型一起加入逻辑 OR 以指示该数据是其他类型数
  1271. 据的指针 (DBTYPE_BYREF). 
  1272.   adBSTR 以空结尾的字符串 (Unicode) (DBTYPE_BSTR). 
  1273.   adChar 字符串值 (DBTYPE_STR). 
  1274.   adCurrency 货币值 (DBTYPE_CY).货币数字的小数点位置固定、小数
  1275. 点右侧有四位数字.该值保存为 8 字节范围为10,000 的带符
  1276. 号整型值. 
  1277.   adDate 日期值 (DBTYPE_DATE).日期按双精度型数值来保存, 数
  1278. 字全部表示从 1899 年 12 月 30 开始的日期数.小数部分是
  1279. 一天当中的片段时间. 
  1280.   adDBDate 日期值 (yyyymmdd) (DBTYPE_DBDATE). 
  1281.   adDBTime 时间值 (hhmmss) (DBTYPE_DBTIME). 
  1282.   adDBTimeStamp 时间戳 (yyyymmddhhmmss 加 10 亿分之一的小数)(DBTYPE_DBTIMESTAMP). 
  1283.   adDecimal 具有固定精度和范围的精确数字值 (DBTYPE_DECIMAL). 
  1284.   adDouble 双精度浮点值 (DBTYPE_R8). 
  1285.   adEmpty 未指定值 (DBTYPE_EMPTY). 
  1286.   adError 32 - 位错误代码 (DBTYPE_ERROR). 
  1287.   adGUID 全局唯一的标识符 (GUID) (DBTYPE_GUID). 
  1288.   adIDispatch OLE 对象上 Idispatch 接口的指针 (DBTYPE_IDISPATCH). 
  1289.   adInteger 4 字节的带符号整型 (DBTYPE_I4). 
  1290.   adIUnknown OLE 对象上 IUnknown 接口的指针 (DBTYPE_IUNKNOWN).
  1291.   adLongVarBinary 长二进制值. 
  1292.   adLongVarChar 长字符串值. 
  1293.   adLongVarWChar 以空结尾的长字符串值. 
  1294.   adNumeric 具有固定精度和范围的精确数字值 (DBTYPE_NUMERIC). 
  1295.   adSingle 单精度浮点值 (DBTYPE_R4). 
  1296.   adSmallInt 2 字节带符号整型 (DBTYPE_I2). 
  1297.   adTinyInt 1 字节带符号整型 (DBTYPE_I1). 
  1298.   adUnsignedBigInt 8 字节不带符号整型 (DBTYPE_UI8). 
  1299.   adUnsignedInt 4 字节不带符号整型 (DBTYPE_UI4). 
  1300.   adUnsignedSmallInt 2 字节不带符号整型 (DBTYPE_UI2). 
  1301.   adUnsignedTinyInt 1 字节不带符号整型 (DBTYPE_UI1). 
  1302.   adUserDefined 用户定义的变量 (DBTYPE_UDT). 
  1303.   adVarBinary 二进制值. 
  1304.   adVarChar 字符串值. 
  1305.   adVariant 自动变体型 (DBTYPE_VARIANT). 
  1306.   adVector 与其他类型一起加入逻辑 OR 中, 指示数据是 DBVECTOR 
  1307. 结构(由 OLE DB 定义).该结构含有元素的计数和其他类型 
  1308. (DBTYPE_VECTOR) 数据的指针. 
  1309.   adVarWChar 以空结尾的 Unicode 字符串. 
  1310.   adWChar 以空结尾的 Unicode 字符串 (DBTYPE_WSTR). 
  1311.     ----------------------------------------------------------
  1312. Remarks: 返回指定字段的数据类型.
  1313. ==========================================================================*/
  1314. DataTypeEnum CAdoRecordSet::GetFieldType(long lIndex)
  1315. {
  1316. ASSERT(m_pRecordset != NULL);
  1317. try 
  1318. {
  1319. return m_pRecordset->Fields->GetItem(_variant_t(lIndex))->GetType();
  1320. }
  1321. catch (_com_error e)
  1322. {
  1323. TRACE(_T("Warning: GetField 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1324. return adEmpty;
  1325. }
  1326. }
  1328. DataTypeEnum CAdoRecordSet::GetFieldType(LPCTSTR lpszFieldName)
  1329. {
  1330. ASSERT(m_pRecordset != NULL);
  1331. try 
  1332. {
  1333. return m_pRecordset->Fields->GetItem(_variant_t(lpszFieldName))->GetType();
  1334. }
  1335. catch (_com_error e)
  1336. {
  1337. TRACE(_T("Warning: GetField发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1338. return adEmpty;
  1339. }
  1340. }
  1342. BOOL CAdoRecordSet::IsFieldNull(LPCTSTR lpFieldName)
  1343. {
  1344. try
  1345. {
  1346. _variant_t vt = m_pRecordset->Fields->GetItem(lpFieldName)->Value;
  1347. return (vt.vt == VT_NULL);
  1348. }
  1349. catch (_com_error e)
  1350. {
  1351. TRACE(_T("Warning: IsFieldNull 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1352. return FALSE;
  1353. }
  1354. }
  1356. BOOL CAdoRecordSet::IsFieldNull(long index)
  1357. {
  1358. try
  1359. {
  1360. _variant_t vt = m_pRecordset->Fields->GetItem(_variant_t(index))->Value;
  1361. return (vt.vt == VT_NULL);
  1362. }
  1363. catch (_com_error e)
  1364. {
  1365. TRACE(_T("Warning: IsFieldNull 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1366. return FALSE;
  1367. }
  1368. }
  1370. /*========================================================================
  1371. Name: 取得指定列的字段对象的指针.
  1372. ==========================================================================*/
  1373. FieldPtr CAdoRecordSet::GetField(long lIndex)
  1374. {
  1375. try
  1376. {
  1377. return GetFields()->GetItem(_variant_t(lIndex));
  1378. }
  1379. catch (_com_error e)
  1380. {
  1381. TRACE(_T("Warning: GetField发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1382. return NULL;
  1383. }
  1384. }
  1386. FieldPtr CAdoRecordSet::GetField(LPCTSTR lpszFieldName)
  1387. {
  1388. try
  1389. {
  1390. return GetFields()->GetItem(_variant_t(lpszFieldName));
  1391. }
  1392. catch (_com_error e)
  1393. {
  1394. TRACE(_T("Warning: GetField发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1395. return NULL;
  1396. }
  1397. }
  1399. /*########################################################################
  1400.   ------------------------------------------------
  1401.   设置字段的值
  1402.   ------------------------------------------------
  1403.   ########################################################################*/
  1404. BOOL CAdoRecordSet::PutCollect(long index, const _variant_t &value)
  1405. {
  1406. ASSERT(m_pRecordset != NULL);
  1407. ASSERT(index < GetFieldsCount());
  1408. try
  1409. {
  1410. if (m_pRecordset != NULL) 
  1411. {
  1412. m_pRecordset->PutCollect(_variant_t(index), value);
  1413. return TRUE;
  1414. }
  1415. }
  1416. catch (_com_error e)
  1417. {
  1418. TRACE(_T("Warning: PutCollect 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1419. return FALSE;
  1420. } 
  1421. return FALSE;
  1422. }
  1424. BOOL CAdoRecordSet::PutCollect(LPCSTR strFieldName, const _variant_t &value)
  1425. {
  1426. ASSERT(m_pRecordset != NULL);
  1427. try
  1428. {
  1429. if (m_pRecordset != NULL) 
  1430. {
  1431. m_pRecordset->put_Collect(_variant_t(strFieldName), value);
  1432. return TRUE;
  1433. }
  1434. }
  1435. catch (_com_error e)
  1436. {
  1437. return FALSE;
  1438. TRACE(_T("Warning: PutCollect 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1439. } 
  1440. return FALSE;
  1441. }
  1443. BOOL CAdoRecordSet::PutCollect(long index, const bool &value)
  1444. {
  1445. ASSERT(m_pRecordset != NULL);
  1446. #ifdef _DEBUG
  1447. if (GetFieldType(index) != adBoolean)
  1448. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1449. #endif
  1451. return PutCollect(index, _variant_t(value));
  1452. }
  1454. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const bool &value)
  1455. {
  1456. ASSERT(m_pRecordset != NULL);
  1457. #ifdef _DEBUG
  1458. if (GetFieldType(strFieldName) != adBoolean)
  1459. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1460. #endif
  1462. return PutCollect(strFieldName, _variant_t(value));
  1463. }
  1465. BOOL CAdoRecordSet::PutCollect(long index, const BYTE &value)
  1466. {
  1467. ASSERT(m_pRecordset != NULL);
  1468. #ifdef _DEBUG
  1469. if (GetFieldType(index) != adUnsignedTinyInt)
  1470. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1471. #endif
  1473. return PutCollect(index, _variant_t(value));
  1474. }
  1476. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const BYTE &value)
  1477. {
  1478. ASSERT(m_pRecordset != NULL);
  1479. #ifdef _DEBUG
  1480. if (GetFieldType(strFieldName) != adUnsignedTinyInt)
  1481. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1482. #endif
  1484. return PutCollect(strFieldName, _variant_t(value));
  1485. }
  1487. BOOL CAdoRecordSet::PutCollect(long index, const short &value)
  1488. {
  1489. ASSERT(m_pRecordset != NULL);
  1490. #ifdef _DEBUG
  1491. if (GetFieldType(index) != adSmallInt)
  1492. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1493. #endif
  1495. return PutCollect(index, _variant_t(value));
  1496. }
  1498. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const short &value)
  1499. {
  1500. ASSERT(m_pRecordset != NULL);
  1501. #ifdef _DEBUG
  1502. if (GetFieldType(strFieldName) != adSmallInt)
  1503. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1504. #endif
  1506. return PutCollect(strFieldName, _variant_t(value));
  1507. }
  1509. BOOL CAdoRecordSet::PutCollect(long index, const int &value)
  1510. {
  1511. ASSERT(m_pRecordset != NULL);
  1512. #ifdef _DEBUG
  1513. if (GetFieldType(index) != adInteger)
  1514. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1515. #endif
  1517. return PutCollect(index, _variant_t(long(value)));
  1518. }
  1520. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const int &value)
  1521. {
  1522. ASSERT(m_pRecordset != NULL);
  1524. #ifdef _DEBUG
  1525. if (GetFieldType(strFieldName) != adInteger)
  1526. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1527. #endif
  1529. return PutCollect(strFieldName, _variant_t(long(value)));
  1530. }
  1532. BOOL CAdoRecordSet::PutCollect(long index, const long &value)
  1533. {
  1534. ASSERT(m_pRecordset != NULL);
  1535. #ifdef _DEBUG
  1536. if (GetFieldType(index) != adBigInt)
  1537. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1538. #endif
  1540. return PutCollect(index, _variant_t(value));
  1541. }
  1543. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const long &value)
  1544. {
  1545. ASSERT(m_pRecordset != NULL);
  1546. #ifdef _DEBUG
  1547. if (GetFieldType(strFieldName) != adBigInt)
  1548. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1549. #endif
  1551. return PutCollect(strFieldName, _variant_t(value));
  1552. }
  1554. BOOL CAdoRecordSet::PutCollect(long index, const DWORD &value)
  1555. {
  1556. ASSERT(m_pRecordset != NULL);
  1557. #ifdef _DEBUG
  1558. if (GetFieldType(index) != adUnsignedBigInt)
  1559. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1560. #endif
  1562. _variant_t vt;
  1563. vt.vt = VT_UI4;
  1564. vt.ulVal = value;
  1565. return PutCollect(index, vt);
  1566. }
  1568. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const DWORD &value)
  1569. {
  1570. ASSERT(m_pRecordset != NULL);
  1571. #ifdef _DEBUG
  1572. if (GetFieldType(strFieldName) != adUnsignedBigInt)
  1573. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1574. #endif
  1576. _variant_t vt;
  1577. vt.vt = VT_UI4;
  1578. vt.ulVal = value;
  1579. return PutCollect(strFieldName, vt);
  1580. }
  1582. BOOL CAdoRecordSet::PutCollect(long index, const float &value)
  1583. {
  1584. ASSERT(m_pRecordset != NULL);
  1585. #ifdef _DEBUG
  1586. if (GetFieldType(index) != adSingle)
  1587. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1588. #endif
  1590. return PutCollect(index, _variant_t(value));
  1591. }
  1593. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const float &value)
  1594. {
  1595. ASSERT(m_pRecordset != NULL);
  1596. #ifdef _DEBUG
  1597. if (GetFieldType(strFieldName) != adSingle)
  1598. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1599. #endif
  1601. return PutCollect(strFieldName, _variant_t(value));
  1602. }
  1604. BOOL CAdoRecordSet::PutCollect(long index, const double &value)
  1605. {
  1606. ASSERT(m_pRecordset != NULL);
  1607. #ifdef _DEBUG
  1608. if (GetFieldType(index) != adDouble)
  1609. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1610. #endif
  1612. return PutCollect(index, _variant_t(value));
  1613. }
  1615. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const double &value)
  1616. {
  1617. ASSERT(m_pRecordset != NULL);
  1618. #ifdef _DEBUG
  1619. if (GetFieldType(strFieldName) != adDouble)
  1620. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1621. #endif
  1623. return PutCollect(strFieldName, _variant_t(value));
  1624. }
  1626. BOOL CAdoRecordSet::PutCollect(long index, const COleDateTime &value)
  1627. {
  1628. ASSERT(m_pRecordset != NULL);
  1629. #ifdef _DEBUG
  1630. if (   GetFieldType(index) != adDate
  1631. && GetFieldType(index) != adDBDate
  1632. && GetFieldType(index) != adDBTime
  1633. && GetFieldType(index) != adDBTimeStamp)
  1634. {
  1635. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1636. }
  1637. #endif
  1639. _variant_t vt;
  1640. vt.vt = VT_DATE;
  1641. vt.date = value;
  1642. return PutCollect(index, vt);
  1643. }
  1645. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const COleDateTime &value)
  1646. {
  1647. ASSERT(m_pRecordset != NULL);
  1648. #ifdef _DEBUG
  1649. if (   GetFieldType(strFieldName) != adDate
  1650. && GetFieldType(strFieldName) != adDBDate
  1651. && GetFieldType(strFieldName) != adDBTime
  1652. && GetFieldType(strFieldName) != adDBTimeStamp)
  1653. {
  1654. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1655. }
  1656. #endif
  1658. _variant_t vt;
  1659. vt.vt = VT_DATE;
  1660. vt.date = value;
  1661. return PutCollect(strFieldName, vt);
  1662. }
  1664. BOOL CAdoRecordSet::PutCollect(long index, const COleCurrency &value)
  1665. {
  1666. ASSERT(m_pRecordset != NULL);
  1667. #ifdef _DEBUG
  1668. if (GetFieldType(index) != adCurrency)
  1669. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1670. #endif
  1672. if (value.m_status == COleCurrency::invalid) return FALSE;
  1674. _variant_t vt;
  1675. vt.vt = VT_CY;
  1676. vt.cyVal = value.m_cur;
  1677. return PutCollect(index, vt);
  1678. }
  1680. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const COleCurrency &value)
  1681. {
  1682. ASSERT(m_pRecordset != NULL);
  1683. #ifdef _DEBUG
  1684. if (GetFieldType(strFieldName) != adCurrency)
  1685. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1686. #endif
  1688. if (value.m_status == COleCurrency::invalid) return FALSE;
  1690. _variant_t vt;
  1691. vt.vt = VT_CY;
  1692. vt.cyVal = value.m_cur;
  1693. return PutCollect(strFieldName, vt);
  1694. }
  1696. BOOL CAdoRecordSet::PutCollect(long index, const CString &value)
  1697. {
  1698. ASSERT(m_pRecordset != NULL);
  1699. #ifdef _DEBUG
  1700. if (! (GetFieldType(index) == adVarChar
  1701. || GetFieldType(index) == adChar
  1702. || GetFieldType(index) == adLongVarChar
  1703. || GetFieldType(index) == adVarWChar
  1704. || GetFieldType(index) == adWChar
  1705. || GetFieldType(index) == adLongVarWChar))
  1706. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1707. #endif
  1709. _variant_t vt;
  1710. vt.vt = value.IsEmpty() ? VT_NULL : VT_BSTR;
  1711. vt.bstrVal = value.AllocSysString();
  1712. return PutCollect(index, vt);
  1713. }
  1715. BOOL CAdoRecordSet::PutCollect(LPCTSTR strFieldName, const CString &value)
  1716. {
  1717. ASSERT(m_pRecordset != NULL);
  1718. #ifdef _DEBUG
  1719. if (! (GetFieldType(strFieldName) == adVarChar
  1720. || GetFieldType(strFieldName) == adChar
  1721. || GetFieldType(strFieldName) == adLongVarChar
  1722. || GetFieldType(strFieldName) == adVarWChar
  1723. || GetFieldType(strFieldName) == adWChar
  1724. || GetFieldType(strFieldName) == adLongVarWChar))
  1725. TRACE(_T("Warning: 你要存贮的字段与变量的数据类型不符; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1726. #endif
  1728. _variant_t vt;
  1729. vt.vt = value.IsEmpty() ? VT_NULL : VT_BSTR;
  1730. vt.bstrVal = value.AllocSysString();
  1731. return PutCollect(strFieldName, vt);
  1732. }
  1735. /*########################################################################
  1736.   ------------------------------------------------
  1737.     读取字段的值
  1738.   ------------------------------------------------
  1739.   ########################################################################*/
  1740. BOOL CAdoRecordSet::GetCollect(long index, COleDateTime &value)
  1741. {
  1742. ASSERT(m_pRecordset != NULL);
  1744. try
  1745. {
  1746. value = vartodate(m_pRecordset->GetCollect(_variant_t(index)));
  1747. return TRUE;
  1748. }
  1749. catch (_com_error e)
  1750. {
  1751. value.SetStatus(COleDateTime::null);
  1752. return FALSE;
  1753. }
  1754. }
  1756. BOOL CAdoRecordSet::GetCollect(LPCTSTR strFieldName, COleDateTime &value)
  1757. {
  1758. ASSERT(m_pRecordset != NULL);
  1760. try
  1761. {
  1762. value = vartodate(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1763. return TRUE;
  1764. }
  1765. catch (_com_error e)
  1766. {
  1767. value.SetStatus(COleDateTime::null);
  1768. return FALSE;
  1769. }
  1770. }
  1772. BOOL CAdoRecordSet::GetCollect(long index, COleCurrency &value)
  1773. {
  1774. ASSERT(m_pRecordset != NULL);
  1776. try
  1777. {
  1778. value = vartocy(m_pRecordset->GetCollect(_variant_t(index)));
  1779. return TRUE;
  1780. }
  1781. catch (_com_error e)
  1782. {
  1783. value.m_status = COleCurrency::null;
  1784. return FALSE;
  1785. }
  1786. }
  1788. BOOL CAdoRecordSet::GetCollect(LPCTSTR strFieldName, COleCurrency &value)
  1789. {
  1790. ASSERT(m_pRecordset != NULL);
  1792. try
  1793. {
  1794. value = vartocy(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1795. return TRUE;
  1796. }
  1797. catch (_com_error e)
  1798. {
  1799. value.m_status = COleCurrency::null;
  1800. return FALSE;
  1801. }
  1802. }
  1804. BOOL CAdoRecordSet::GetCollect(long index,  bool &value)
  1805. {
  1806. ASSERT(m_pRecordset != NULL);
  1808. try
  1809. {
  1810. value = vartobool(m_pRecordset->GetCollect(_variant_t(index)));
  1811. return TRUE;
  1812. }
  1813. catch (_com_error e)
  1814. {
  1815. value = false;
  1816. return FALSE;
  1817. } 
  1818. }
  1820. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  bool &value)
  1821. {
  1822. ASSERT(m_pRecordset != NULL);
  1824. try
  1825. {
  1826. value = vartobool(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1827. return TRUE;
  1828. }
  1829. catch (_com_error e)
  1830. {
  1831. value = false;
  1832. return FALSE;
  1833. } 
  1834. }
  1837. BOOL CAdoRecordSet::GetCollect(long index,  BYTE &value)
  1838. {
  1839. ASSERT(m_pRecordset != NULL);
  1841. try
  1842. {
  1843. value = vartoby(m_pRecordset->GetCollect(_variant_t(index)));
  1844. return TRUE;
  1845. }
  1846. catch (_com_error e)
  1847. {
  1848. value = 0;
  1849. return FALSE;
  1850. } 
  1851. }
  1853. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  BYTE &value)
  1854. {
  1855. ASSERT(m_pRecordset != NULL);
  1857. try
  1858. {
  1859. value = vartoby(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1860. return TRUE;
  1861. }
  1862. catch (_com_error e)
  1863. {
  1864. value = 0;
  1865. return FALSE;
  1866. } 
  1867. }
  1869. BOOL CAdoRecordSet::GetCollect(long index,  short &value)
  1870. {
  1871. ASSERT(m_pRecordset != NULL);
  1873. try
  1874. {
  1875. value = vartoi(m_pRecordset->GetCollect(_variant_t(index)));
  1876. return TRUE;
  1877. }
  1878. catch (_com_error e)
  1879. {
  1880. value = 0;
  1881. return FALSE;
  1882. } 
  1883. }
  1885. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  short &value)
  1886. {
  1887. ASSERT(m_pRecordset != NULL);
  1889. try
  1890. {
  1891. value = vartoi(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1892. return TRUE;
  1893. }
  1894. catch (_com_error e)
  1895. {
  1896. value = 0;
  1897. return FALSE;
  1898. } 
  1899. }
  1901. BOOL CAdoRecordSet::GetCollect(long index,  int &value)
  1902. {
  1903. ASSERT(m_pRecordset != NULL);
  1905. try
  1906. {
  1907. value = (int)vartol(m_pRecordset->GetCollect(_variant_t(index)));
  1908. return TRUE;
  1909. }
  1910. catch (_com_error e)
  1911. {
  1912. value = 0;
  1913. return FALSE;
  1914. } 
  1915. return FALSE;
  1916. }
  1918. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  int &value)
  1919. {
  1920. ASSERT(m_pRecordset != NULL);
  1922. try
  1923. {
  1924. value = (int)vartol(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1925. return TRUE;
  1926. }
  1927. catch (_com_error e)
  1928. {
  1929. value = 0;
  1930. return FALSE;
  1931. } 
  1932. }
  1934. BOOL CAdoRecordSet::GetCollect(long index,  long &value)
  1935. {
  1936. ASSERT(m_pRecordset != NULL);
  1938. try
  1939. {
  1940. value = vartol(m_pRecordset->GetCollect(_variant_t(index)));
  1941. return TRUE;
  1942. }
  1943. catch (_com_error e)
  1944. {
  1945. value = 0;
  1946. return FALSE;
  1947. } 
  1948. }
  1950. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  long &value)
  1951. {
  1952. ASSERT(m_pRecordset != NULL);
  1954. try
  1955. {
  1956. value = vartol(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  1957. return TRUE;
  1958. }
  1959. catch (_com_error e)
  1960. {
  1961. value = 0;
  1962. return FALSE;
  1963. } 
  1964. return FALSE;
  1965. }
  1967. BOOL CAdoRecordSet::GetCollect(long index,  DWORD &value)
  1968. {
  1969. ASSERT(m_pRecordset != NULL);
  1971. try
  1972. {
  1973. _variant_t result = m_pRecordset->GetCollect(_variant_t(index));
  1974. switch (result.vt)
  1975. {
  1976. case VT_UI4:
  1977. case VT_I4:
  1978. value = result.ulVal;
  1979. break;
  1980. case VT_NULL:
  1981. case VT_EMPTY:
  1982. value = 0;
  1983. break;
  1984. default:
  1985. TRACE(_T("Warning: 无法读取相应的字段, 数据类型不匹配; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  1986. return FALSE;
  1987. }
  1988. return TRUE;
  1989. }
  1990. catch (_com_error e)
  1991. {
  1992. value = 0;
  1993. return FALSE;
  1994. } 
  1995. }
  1997. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  DWORD &value)
  1998. {
  1999. ASSERT(m_pRecordset != NULL);
  2001. try
  2002. {
  2003. _variant_t result = m_pRecordset->GetCollect(_variant_t(strFieldName));
  2004. switch (result.vt)
  2005. {
  2006. case VT_UI4:
  2007. case VT_I4:
  2008. value = result.ulVal;
  2009. break;
  2010. case VT_NULL:
  2011. case VT_EMPTY:
  2012. value = 0;
  2013. break;
  2014. default:
  2015. TRACE(_T("Warning: 无法读取相应的字段, 数据类型不匹配; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  2016. return FALSE;
  2017. }
  2018. return TRUE;
  2019. }
  2020. catch (_com_error e)
  2021. {
  2022. value = 0;
  2023. return FALSE;
  2024. } 
  2025. }
  2027. BOOL CAdoRecordSet::GetCollect(long index,  float &value)
  2028. {
  2029. ASSERT(m_pRecordset != NULL);
  2031. try
  2032. {
  2033. _variant_t result = m_pRecordset->GetCollect(_variant_t(index));
  2034. switch (result.vt)
  2035. {
  2036. case VT_R4:
  2037. value = result.fltVal;
  2038. break;
  2039. case VT_UI1:
  2040. case VT_I1:
  2041. value = result.bVal;
  2042. break;
  2043. case VT_UI2:
  2044. case VT_I2:
  2045. value = result.iVal;
  2046. break;
  2047. case VT_NULL:
  2048. case VT_EMPTY:
  2049. value = 0;
  2050. break;
  2051. default:
  2052. TRACE(_T("Warning: 无法读取相应的字段, 数据类型不匹配; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  2053. return FALSE;
  2054. }
  2055. return TRUE;
  2056. }
  2057. catch (_com_error e)
  2058. {
  2059. value = 0;
  2060. return FALSE;
  2061. } 
  2062. }
  2064. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  float &value)
  2065. {
  2066. ASSERT(m_pRecordset != NULL);
  2068. try
  2069. {
  2070. _variant_t result = m_pRecordset->GetCollect(_variant_t(strFieldName));
  2071. switch (result.vt)
  2072. {
  2073. case VT_R4:
  2074. value = result.fltVal;
  2075. break;
  2076. case VT_UI1:
  2077. case VT_I1:
  2078. value = result.bVal;
  2079. break;
  2080. case VT_UI2:
  2081. case VT_I2:
  2082. value = result.iVal;
  2083. break;
  2084. case VT_NULL:
  2085. case VT_EMPTY:
  2086. value = 0;
  2087. break;
  2088. default:
  2089. TRACE(_T("Warning: 无法读取相应的字段, 数据类型不匹配; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  2090. return FALSE;
  2091. }
  2092. return TRUE;
  2093. }
  2094. catch (_com_error e)
  2095. {
  2096. value = 0;
  2097. return FALSE;
  2098. } 
  2099. }
  2101. BOOL CAdoRecordSet::GetCollect(long index,  double &value)
  2102. {
  2103. ASSERT(m_pRecordset != NULL);
  2105. try
  2106. {
  2107. value = vartof(m_pRecordset->GetCollect(_variant_t(index)));
  2108. return TRUE;
  2109. }
  2110. catch (_com_error e)
  2111. {
  2112. value = 0;
  2113. return FALSE;
  2114. } 
  2115. }
  2117. BOOL CAdoRecordSet::GetCollect(LPCSTR strFieldName,  double &value)
  2118. {
  2119. ASSERT(m_pRecordset != NULL);
  2121. try
  2122. {
  2123. value = vartof(m_pRecordset->GetCollect(_variant_t(strFieldName)));
  2124. return TRUE;
  2125. }
  2126. catch (_com_error e)
  2127. {
  2128. value = 0;
  2129. return FALSE;
  2130. } 
  2131. }
  2133. BOOL CAdoRecordSet::GetCollect(long index, CString& strValue)
  2134. {
  2135. ASSERT(m_pRecordset != NULL);
  2136. if (index < 0 || index >= GetFieldsCount())
  2137. {
  2138. return FALSE;
  2139. }
  2141. try
  2142. {
  2143. if (!IsOpen())
  2144. {
  2145. MessageBox(NULL, _T("数据库可能已经断开,rn请重新连接、然后重试."), _T("提示"), MB_ICONINFORMATION);
  2146. return FALSE;
  2147. } 
  2148. if (m_pRecordset->adoEOF)
  2149. {
  2150. return FALSE;
  2151. }
  2152. _variant_t value = m_pRecordset->GetCollect(_variant_t(index));
  2153. strValue = vartostr(value);
  2154. return TRUE;
  2155. }
  2156. catch (_com_error e)
  2157. {
  2158. TRACE(_T("Warning: 字段访问失败. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2159. return FALSE;
  2160. }
  2162. return FALSE;
  2163. }
  2165. BOOL CAdoRecordSet::GetCollect(LPCTSTR strFieldName, CString &strValue)
  2166. {
  2167. ASSERT(m_pRecordset != NULL);
  2168. try
  2169. {
  2170. if (!IsOpen())
  2171. {
  2172. MessageBox(NULL, _T("数据库可能已经断开,rn请重新连接、然后重试."), _T("提示"), MB_ICONINFORMATION);
  2173. return FALSE;
  2174. } 
  2175. if (m_pRecordset->adoEOF)
  2176. {
  2177. return FALSE;
  2178. }
  2179. _variant_t value = m_pRecordset->GetCollect(_variant_t(LPCTSTR(strFieldName)));
  2180. strValue = vartostr(value);
  2181. return TRUE;
  2182. }
  2183. catch (_com_error e)
  2184. {
  2185. TRACE(_T("Warning: 字段访问失败. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2186. return FALSE;
  2187. }
  2189. return FALSE;
  2190. }
  2192. /*########################################################################
  2193.   ------------------------------------------------
  2194. 将数据追加到大型文本、二进制数据 Field 对象. 
  2195.   ------------------------------------------------
  2196.   ########################################################################*/
  2197. BOOL CAdoRecordSet::AppendChunk(FieldPtr pField, LPVOID lpData, UINT nBytes)
  2198. {
  2199. SAFEARRAY FAR *pSafeArray = NULL;
  2200. SAFEARRAYBOUND rgsabound[1];
  2202. try
  2203. {
  2204. rgsabound[0].lLbound = 0;
  2205. rgsabound[0].cElements = nBytes;
  2206. pSafeArray = SafeArrayCreate(VT_UI1, 1, rgsabound);
  2208. for (long i = 0; i < (long)nBytes; i++)
  2209. {
  2210. UCHAR &chData = ((UCHAR*)lpData)[i];
  2211. HRESULT hr = SafeArrayPutElement(pSafeArray, &i, &chData);
  2212. if (FAILED(hr)) return FALSE;
  2213. }
  2215. _variant_t varChunk;
  2216. varChunk.vt = VT_ARRAY | VT_UI1;
  2217. varChunk.parray = pSafeArray;
  2219. return (pField->AppendChunk(varChunk) == S_OK);
  2220. }
  2221. catch (_com_error &e)
  2222. {
  2223. TRACE(_T("Warning: AppendChunk 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2224. return FALSE;
  2225. }
  2226. }
  2228. BOOL CAdoRecordSet::AppendChunk(long index, LPVOID lpData, UINT nBytes)
  2229. {
  2230. ASSERT(m_pRecordset != NULL);
  2231. ASSERT(lpData != NULL);
  2232. if (adFldLong & GetFieldAttributes(index))
  2233. {
  2234. return AppendChunk(GetField(index), lpData, nBytes);
  2235. }
  2236. else return FALSE;
  2237. }
  2239. BOOL CAdoRecordSet::AppendChunk(LPCSTR strFieldName, LPVOID lpData, UINT nBytes)
  2240. {
  2241. ASSERT(m_pRecordset != NULL);
  2242. ASSERT(lpData != NULL);
  2243. if (adFldLong & GetFieldAttributes(strFieldName))
  2244. {
  2245. return AppendChunk(GetField(strFieldName), lpData, nBytes);
  2246. }
  2247. else return FALSE;
  2248. }
  2250. BOOL CAdoRecordSet::AppendChunk(long index, LPCTSTR lpszFileName)
  2251. {
  2252. ASSERT(m_pRecordset != NULL);
  2253. ASSERT(lpszFileName != NULL);
  2254. BOOL bret = FALSE;
  2255. if (adFldLong & GetFieldAttributes(index))
  2256. {
  2257. CFile file;
  2258. if (file.Open(lpszFileName, CFile::modeRead))
  2259. {
  2260. long length = (long)file.GetLength();
  2261. char *pbuf = new char[length];
  2262. if (pbuf != NULL && file.Read(pbuf, length) == (DWORD)length)
  2263. {
  2264. bret = AppendChunk(GetField(index), pbuf, length);
  2265. }
  2266. if (pbuf != NULL) delete[] pbuf;
  2267. }
  2268. file.Close();
  2269. }
  2270. return bret;
  2271. }
  2273. BOOL CAdoRecordSet::AppendChunk(LPCSTR strFieldName, LPCTSTR lpszFileName)
  2274. {
  2275. ASSERT(m_pRecordset != NULL);
  2276. ASSERT(lpszFileName != NULL);
  2277. BOOL bret = FALSE;
  2278. if (adFldLong & GetFieldAttributes(strFieldName))
  2279. {
  2280. CFile file;
  2281. if (file.Open(lpszFileName, CFile::modeRead))
  2282. {
  2283. long length = (long)file.GetLength();
  2284. char *pbuf = new char[length];
  2285. if (pbuf != NULL && file.Read(pbuf, length) == (DWORD)length)
  2286. {
  2287. bret = AppendChunk(GetField(strFieldName), pbuf, length);
  2288. }
  2289. if (pbuf != NULL) delete[] pbuf;
  2290. }
  2291. file.Close();
  2292. }
  2293. return bret;
  2294. }
  2296. BOOL CAdoRecordSet::GetChunk(FieldPtr pField, LPVOID lpData)
  2297. {
  2298. ASSERT(pField != NULL);
  2299. ASSERT(lpData != NULL);
  2301. UCHAR chData;
  2302. long index = 0;
  2304. while (index < pField->ActualSize)
  2305. { 
  2306. try
  2307. {
  2308. _variant_t varChunk = pField->GetChunk(100);
  2309. if (varChunk.vt != (VT_ARRAY | VT_UI1))
  2310. {
  2311. return FALSE;
  2312. }
  2314.             for (long i = 0; i < 100; i++)
  2315.             {
  2316.                 if (SUCCEEDED( SafeArrayGetElement(varChunk.parray, &i, &chData) ))
  2317.                 {
  2318. ((UCHAR*)lpData)[index] = chData;
  2319.                     index++;
  2320.                 }
  2321.                 else
  2322. {
  2323.                     break;
  2324. }
  2325.             }
  2326. }
  2327. catch (_com_error e)
  2328. {
  2329. TRACE(_T("Warning: GetChunk 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2330. return FALSE;
  2331. }
  2332. }
  2334. return TRUE;
  2335. }
  2337. BOOL CAdoRecordSet::GetChunk(long index, LPVOID lpData)
  2338. {
  2339. if (adFldLong & GetFieldAttributes(index))
  2340. return  GetChunk(GetField(index), lpData);
  2341. else return FALSE;
  2342. }
  2344. BOOL CAdoRecordSet::GetChunk(LPCSTR strFieldName, LPVOID lpData)
  2345. {
  2346. if (adFldLong & GetFieldAttributes(strFieldName))
  2347. return  GetChunk(GetField(strFieldName), lpData);
  2348. else return FALSE;
  2349. }
  2351. BOOL CAdoRecordSet::GetChunk(long index, CBitmap &bitmap)
  2352. {
  2353. return GetChunk(GetFieldName(index), bitmap);
  2354. }
  2356. BOOL CAdoRecordSet::GetChunk(LPCSTR strFieldName, CBitmap &bitmap)
  2357. {
  2358. BOOL bret = FALSE;
  2359. long size = GetFieldActualSize(strFieldName);
  2360. if ((adFldLong & GetFieldAttributes(strFieldName)) && size > 0)
  2361. {
  2362. BYTE *lpData = new BYTE[size];
  2364. if (GetChunk(GetField(strFieldName), (LPVOID)lpData))
  2365. {
  2366. BITMAPFILEHEADER bmpHeader;
  2367. DWORD bmfHeaderLen = sizeof(bmpHeader);
  2368. strncpy((LPSTR)&bmpHeader, (LPSTR)lpData, bmfHeaderLen);
  2370. // 是否是位图 ----------------------------------------
  2371. if (bmpHeader.bfType == (*(WORD*)"BM"))
  2372. {
  2373. BYTE* lpDIBBits = lpData + bmfHeaderLen;
  2374. BITMAPINFOHEADER &bmpiHeader = *(LPBITMAPINFOHEADER)lpDIBBits;
  2375. BITMAPINFO &bmpInfo = *(LPBITMAPINFO)lpDIBBits;
  2376. lpDIBBits = lpData + ((BITMAPFILEHEADER *)lpData)->bfOffBits;
  2378. // 创建位图 --------------------------------------
  2379. CDC dc;
  2380. HDC hdc = GetDC(NULL);
  2381. dc.Attach(hdc);
  2382. HBITMAP hBmp = CreateDIBitmap(dc.m_hDC, &bmpiHeader, CBM_INIT, lpDIBBits, &bmpInfo, DIB_RGB_COLORS);
  2383. if (bitmap.GetSafeHandle() != NULL) bitmap.DeleteObject();
  2384. bitmap.Attach(hBmp);
  2385. dc.Detach();
  2386. ReleaseDC(NULL, hdc);
  2387. bret = TRUE;
  2388. }
  2389. }
  2390. delete[] lpData;
  2391. lpData = NULL;
  2392. }
  2393. return bret;
  2394. }
  2396. /*########################################################################
  2397.   ------------------------------------------------
  2398.    其他方法
  2399.   ------------------------------------------------
  2400.   ########################################################################*/
  2402. _RecordsetPtr CAdoRecordSet::operator =(_RecordsetPtr &pRecordSet)
  2403. {
  2404. Close();
  2405. if (pRecordSet != NULL)
  2406. {
  2407. m_pRecordset = NULL;
  2408. m_pRecordset = pRecordSet;
  2409. return m_pRecordset;
  2410. }
  2411. return NULL;
  2412. }
  2414. /*========================================================================
  2415. Name: 确定指定的 Recordset 对象是否支持特定类型的功能.
  2416.     ----------------------------------------------------------
  2417. Params: CursorOptions   长整型, 包括一个或多个下列 CursorOptionEnum 值.
  2418. [常量] [说明] 
  2419. ------------------------------------
  2420. adAddNew 可使用 AddNew 方法添加新记录. 
  2421. adApproxPosition 可读取并设置 AbsolutePosition 和 AbsolutePage 的属性. 
  2422. adBookmark 可使用 Bookmark 属性获得对特定记录的访问. 
  2423. adDelete 可以使用 Delete 方法删除记录. 
  2424. adHoldRecords 可以检索多个记录或者更改下一个检索位置而不必提交所
  2425. 有挂起的更改. 
  2426. adMovePrevious 可使用 MoveFirst 和 MovePrevious 方法, 以及 Move 或
  2427. GetRows 方法将当前记录位置向后移动而不必使用书签. 
  2428. adResync 通过 Resync 方法, 使用在基本的数据库中可见的数据更
  2429. 新游标. 
  2430. adUpdate 可使用 Update 方法修改现有的数据. 
  2431. adUpdateBatch 可以使用批更新(UpdateBatch 和 CancelBatch 方法) 将
  2432. 更改组传输给提供者. 
  2433. adIndex 可以使用 Index 属性命名索引. 
  2434. adSeek 可以使用 Seek 方法定位 Recordset 中的行. 
  2435.     ----------------------------------------------------------
  2436. returns: 返回布尔型值, 指示是否支持 CursorOptions 参数所标识的所有功能.
  2437.     ----------------------------------------------------------
  2438. Remarks: 使用 Supports 方法确定 Recordset 对象所支持的功能类型. 如
  2439. 果 Recordset 对象支持其相应常量在 CursorOptions 中的功能, 那么 Supports
  2440. 方法返回 True.否则返回 False.
  2441. 注意   尽管 Supports 方法可对给定的功能返回 True, 但它不能保证提供者可
  2442. 以使功能在所有环境下均有效. Supports 方法只返回提供者是否支持指定的功能
  2443. (假定符合某些条件). 例如, Supports 方法可能指示 Recordset 对象支持更新
  2444. (即使游标基于多个表的合并), 但并且某些列仍然无法更新.
  2445. ==========================================================================*/
  2446. BOOL CAdoRecordSet::Supports(CursorOptionEnum CursorOptions)
  2447. {
  2448. ASSERT(m_pRecordset != NULL);
  2449. try
  2450. {
  2451. if (m_pRecordset != NULL)
  2452. {
  2453. return m_pRecordset->Supports(CursorOptions);
  2454. }
  2455. }
  2456. catch (const _com_error& e)
  2457. {
  2458. TRACE(_T("Warning: Supports方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2459. return FALSE;
  2460. }
  2461. return FALSE;
  2462. }
  2464. /*========================================================================
  2465. name: 为 Recordset 中的数据指定筛选条件.
  2466. ==========================================================================*/
  2467. BOOL CAdoRecordSet::SetFilter(LPCTSTR lpszFilter)
  2468. {
  2469. ASSERT(m_pRecordset != NULL);
  2470. ASSERT(IsOpen());
  2472. try
  2473. {
  2474. m_pRecordset->PutFilter(lpszFilter);
  2475. return TRUE;
  2476. }
  2477. catch (_com_error e)
  2478. {
  2479. TRACE(_T("Warning: SetFilter 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2480. return FALSE;
  2481. }
  2482. }
  2484. /*========================================================================
  2485. name: 为 Recordset 中的数据指定排序条件.
  2486. ==========================================================================*/
  2487. BOOL CAdoRecordSet::SetSort(LPCTSTR lpszCriteria)
  2488. {
  2489. ASSERT(IsOpen());
  2491. try
  2492. {
  2493. m_pRecordset->PutSort(lpszCriteria);
  2494. return TRUE;
  2495. }
  2496. catch (_com_error e)
  2497. {
  2498. TRACE(_T("Warning: SetFilter 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2499. return FALSE;
  2500. }
  2501. }
  2503. /*========================================================================
  2504. name: 返回唯一标识 Recordset 对象中当前记录的书签。
  2505. ==========================================================================*/
  2506. _variant_t CAdoRecordSet::GetBookmark()
  2507. {
  2508. ASSERT(m_pRecordset != NULL);
  2509. try
  2510. {
  2511. if (IsOpen())
  2512. {
  2513. m_varBookmark = m_pRecordset->GetBookmark();
  2514. return m_varBookmark;
  2515. }
  2516. }
  2517. catch (_com_error e)
  2518. {
  2519. TRACE(_T("Warning: GetBookmark 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2520. }
  2521. return _variant_t((long)adBookmarkFirst);
  2522. }
  2524. /*========================================================================
  2525. name: 将 Recordset 对象的当前记录设置为由有效书签所标识的记录。
  2526. ==========================================================================*/
  2527. BOOL CAdoRecordSet::SetBookmark(_variant_t varBookMark)
  2528. {
  2529. ASSERT(m_pRecordset != NULL);
  2531. try
  2532. {
  2533. if (IsOpen() && varBookMark.vt != VT_EMPTY && varBookMark.vt != VT_NULL)
  2534. {
  2535. m_pRecordset->PutBookmark(varBookMark);
  2536. return TRUE;
  2537. }
  2538. }
  2539. catch (_com_error e)
  2540. {
  2541. TRACE(_T("Warning: SetBookmark 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2542. }
  2543. return FALSE;
  2544. }
  2546. void CAdoRecordSet::SetAdoConnection(CAdoConnection *pConnection)
  2547. {
  2548. m_pConnection = pConnection;
  2549. }
  2551. _RecordsetPtr& CAdoRecordSet::GetRecordset()
  2552. {
  2553. return m_pRecordset;
  2554. }
  2556. CString CAdoRecordSet::GetLastError()
  2557. {
  2558. ASSERT(m_pConnection != NULL);
  2559. return m_pConnection->GetLastErrorText();
  2560. }
  2562. /*========================================================================
  2563. name: 创建与现有 Recordset 对象相同的复制 Recordset 对象。可选择指定
  2564. 该副本为只读。
  2565. ==========================================================================*/
  2566. BOOL CAdoRecordSet::Clone(CAdoRecordSet &pRecordSet)
  2567. {
  2568. ASSERT(m_pRecordset != NULL);
  2570. try
  2571. {
  2572. pRecordSet = m_pRecordset->Clone(adLockUnspecified);
  2573. return TRUE;
  2574. }
  2575. catch (_com_error e)
  2576. {
  2577. TRACE(_T("Warning: Clone 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2578. return FALSE;
  2579. }
  2580. }
  2582. /*========================================================================
  2583. name: 搜索 Recordset 中满足指定标准的记录. 如果满足标准，则记录集
  2584. 位置设置在找到的记录上，否则位置将设置在记录集的末尾. 
  2585.     ----------------------------------------------------------
  2586. params: [criteria]:   字符串，包含指定用于搜索的列名、比较操作符和
  2587. 值的语句. 
  2588. [searchDirection]:    可选的 SearchDirectionEnum 值，指定搜
  2589. 索应从当前行还是下一个有效行开始. 其值可为 adSearchForward 或 adSearchBackward. 
  2590. 搜索是在记录集的开始还是末尾结束由 searchDirection 值决定. 
  2591. [常量] [说明]
  2592. ---------------------------------
  2593. adSearchForward 
  2594. adSearchBackward
  2595.     ----------------------------------------------------------
  2596. Remarks: criteria 中的"比较操作符"可以是">"(大于)、"<"(小于)、"="(等
  2597. 于)、">="(大于或等于)、"<="(小于或等于)、"<>"(不等于)或"like"(模式匹配).  
  2598. criteria 中的值可以是字符串、浮点数或者日期. 字符串值以单引号分界(如
  2599. "state = 'WA'"). 日期值以"#"(数字记号)分界(如"start_date > #7/22/97#"). 
  2600. 如"比较操作符"为"like"，则字符串"值"可以包含"*"(某字符可出现一次或
  2601. 多次)或者"_"(某字符只出现一次). (如"state like M_*"与 Maine 和 Massachusetts 
  2602. 匹配.). 
  2603. ==========================================================================*/
  2604. BOOL CAdoRecordSet::Find(LPCTSTR lpszFind, SearchDirectionEnum SearchDirection)
  2605. {
  2606. ASSERT(m_pRecordset != NULL);
  2607. ASSERT(AfxIsValidString(lpszFind));
  2609. try
  2610. {
  2611. if (strcmp(lpszFind, _T("")) != 0)
  2612. {
  2613. m_strFind = lpszFind;
  2614. }
  2616. if (m_strFind.IsEmpty()) return FALSE;
  2618. m_pRecordset->Find(_bstr_t(m_strFind), 0, SearchDirection, "");
  2620. if ((IsEOF() || IsBOF()) )
  2621. {
  2622. return FALSE;
  2623. }
  2624. else
  2625. {
  2626. m_SearchDirection = SearchDirection;
  2627. GetBookmark();
  2628. return TRUE;
  2629. }
  2630. }
  2631. catch (_com_error e)
  2632. {
  2633. TRACE(_T("Warning: Find 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2634. return FALSE;
  2635. }
  2636. }
  2638. /*========================================================================
  2639. name: 查找下一条满足条件的记录.
  2640. ==========================================================================*/
  2641. BOOL CAdoRecordSet::FindNext()
  2642. {
  2643. ASSERT(m_pRecordset != NULL);
  2645. try
  2646. {
  2647. if (m_strFind.IsEmpty()) return FALSE;
  2649. m_pRecordset->Find(_bstr_t(m_strFind), 1, m_SearchDirection, m_varBookmark);
  2651. if ((IsEOF() || IsBOF()) )
  2652. {
  2653. return FALSE;
  2654. }
  2655. else
  2656. {
  2657. GetBookmark();
  2658. return TRUE;
  2659. }
  2660. }
  2661. catch (_com_error e)
  2662. {
  2663. TRACE(_T("Warning: FindNext 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2664. return FALSE;
  2665. }
  2666. }
  2668. BOOL CAdoRecordSet::RecordBinding(CADORecordBinding &pAdoRecordBinding)
  2669. {
  2670. m_pAdoRecordBinding = NULL;
  2672. try
  2673. {
  2674. if (SUCCEEDED(m_pRecordset->QueryInterface(__uuidof(IADORecordBinding), (LPVOID*)&m_pAdoRecordBinding)))
  2675. {
  2676. if (SUCCEEDED(m_pAdoRecordBinding->BindToRecordset(&pAdoRecordBinding)))
  2677. {
  2678. return TRUE;
  2679. }
  2680. }
  2681. return TRUE;
  2682. }
  2683. catch (_com_error e)
  2684. {
  2685. TRACE(_T("Warning: RecordBinding 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2686. return FALSE;
  2687. }
  2688. }
  2690. BOOL CAdoRecordSet::AddNew(CADORecordBinding &pAdoRecordBinding)
  2691. {
  2692. try
  2693. {
  2694. if (m_pAdoRecordBinding->AddNew(&pAdoRecordBinding) == S_OK)
  2695. {
  2696. m_pAdoRecordBinding->Update(&pAdoRecordBinding);
  2697. return TRUE;
  2698. }
  2699. return FALSE;
  2700. }
  2701. catch (_com_error e)
  2702. {
  2703. TRACE(_T("Warning: AddNew 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  2704. return FALSE;
  2705. }
  2706. }
  2708. /*========================================================================
  2709. Name: 获得当前游标位置
  2710. -----------------------------------------------------
  2711. Remarks: 返回位置。
  2712. ==========================================================================*/
  2713. long CAdoRecordSet::GetCursorPos()
  2714. {
  2715. long count = m_pRecordset->GetRecordCount();
  2716. while (!m_pRecordset->adoEOF)
  2717. {
  2718. m_pRecordset->MoveNext();
  2719. count--;
  2720. }
  2721. m_pRecordset->MoveFirst();
  2722. m_pRecordset->Move(count);
  2723. return count;
  2724. }
  2727. /*========================================================================
  2728. Name: 获得指定列在集合中的位置。
  2729. -----------------------------------------------------
  2730. params: filedName   列名
  2731. ---------------------------------
  2732. ==========================================================================*/
  2734. int CAdoRecordSet::GetFieldIndex(CString filedName)
  2735. {
  2736. long colCount = GetFieldsCount();
  2737. for (int i = 0 ;i < colCount; i++)
  2738. {
  2739. if (filedName == GetFieldName(i))
  2740. {
  2741. break;
  2742. }
  2743. }
  2744. return i == colCount ?-1:i;
  2745. }
  2747. /*========================================================================
  2748. Name: 获取记录集合中指定列的字符串形式的值
  2749. -----------------------------------------------------
  2750. params: index   列在集合中的位置
  2751.         lockCursorPos   为TRUE时，保持游标原来的位置不变
  2752. maxRows    一次返回记录的最大行
  2753. ---------------------------------
  2754. remarks: 如果lockCursorPos为TRUE时,保持游标原来的位置不变,所以重复调用该函数返回
  2755.          内容一样。考虑到如果记录集合中记录数较多，array数组很大，会占用较多的系统
  2756.  资源，所以对它进行优化：
  2757.      当lockCursorPos 为FALSE 时，将从当前记录开始，返回maxRows条记录的值。
  2758. ==========================================================================*/
  2759. BOOL CAdoRecordSet::GetFieldValues(CStringArray *array, int index ,BOOL lockCursorPos,int maxRows)
  2760. {
  2761. BOOL flag(TRUE);
  2762. long pos ;
  2763. long count = m_pRecordset->GetRecordCount();
  2764. long colCount = GetFieldsCount();
  2765. if (count <=0 || index >= colCount || index <0) //check values
  2766. {
  2767.      #ifdef _DEBUG
  2768. if (count <=0 )
  2769. TRACE(_T("记录集合为空"));
  2770. else
  2771. TRACE(_T("超出字段范围"));
  2772.      #endif
  2773. return FALSE;
  2774. }
  2775. //
  2776. if (lockCursorPos)
  2777. {
  2778. pos= GetCursorPos();
  2779. }
  2780. array->RemoveAll();
  2781. // m_pRecordset->MoveFirst();
  2782. for (int i = 0 ;i < maxRows ;i ++)
  2783. {
  2784. CString temp;
  2785. if (!GetCollect(index,temp))
  2786. {
  2787. flag = FALSE;
  2788. TRACE(_T("CAdoRecordSet::GetFieldValues 失败--%s"),GetLastError());
  2789. break;
  2790. }
  2791. array->Add(temp);
  2792. if (m_pRecordset->adoEOF)
  2793. {
  2794. flag = FALSE;
  2795. break;
  2796. }
  2797. m_pRecordset->MoveNext();
  2798. }
  2800. if (lockCursorPos)
  2801. {
  2802. m_pRecordset->MoveFirst();
  2803. m_pRecordset->Move(pos);
  2804. }
  2805. return flag;
  2806. }
  2809. BOOL CAdoRecordSet::GetFieldValues(CStringArray *array, CString fieldName,BOOL lockCursorPos ,int maxRows)
  2811. {
  2812. int index =GetFieldIndex(fieldName);
  2813. return GetFieldValues(array,index,lockCursorPos,maxRows);
  2814. }
  2816. /*========================================================================
  2817. Name: 获取记录集合中指定列的字符串形式的值
  2818. -----------------------------------------------------
  2819. params: index   列在集合中的位置
  2820.         lockCursorPos   为TRUE时，保持游标原来的位置不变
  2821. maxRows    一次返回记录的最大行
  2822. size        Array数组大小
  2823. ---------------------------------
  2824. remarks: 如果lockCursorPos为TRUE时,保持游标原来的位置不变,所以重复调用该函数返回
  2825.          内容一样。考虑到如果记录集合中记录数较多，array数组很大，会占用较多的系统
  2826.  资源，所以对它进行优化：
  2827.      当lockCursorPos 为FALSE 时，将从当前记录开始，返回maxRows条记录的值。
  2828. ==========================================================================*/
  2829. int CAdoRecordSet::GetFieldValues(int *Array, int size, int index, BOOL lockCursorPos, int maxRows)
  2830. {
  2831. long pos ;
  2832. long count = m_pRecordset->GetRecordCount();
  2833. long colCount = GetFieldsCount();
  2834. if (count <=0 || index >= colCount || index <0) //check values
  2835. {
  2836.      #ifdef _DEBUG
  2837. if (count <=0 )
  2838. TRACE(_T("记录集合为空"));
  2839. else
  2840. TRACE(_T("超出字段范围"));
  2841.      #endif
  2842. return FALSE;
  2843. }
  2844. //
  2845. if (lockCursorPos)
  2846. {
  2847. pos= GetCursorPos();
  2848. }
  2850. for (int i = 0 ;i < maxRows && i < size;)
  2851. {
  2852. int temp;
  2853. if (!GetCollect(index,temp))
  2854. {
  2855. TRACE(_T("CAdoRecordSet::GetFieldValues 失败--%s"),GetLastError());
  2856. break;
  2857. }
  2858. Array[i++] = temp;
  2859. if (m_pRecordset->adoEOF)
  2860. {
  2861. break;
  2862. }
  2863. m_pRecordset->MoveNext();
  2864. }
  2866. if (lockCursorPos)
  2867. {
  2868. m_pRecordset->MoveFirst();
  2869. m_pRecordset->Move(pos);
  2870. }
  2871. return i;
  2872. }
  2875. int CAdoRecordSet::GetFieldValues(int *Array, int size, CString fieldName, BOOL lockCursorPos, int maxRows)
  2876. {
  2877. int index =GetFieldIndex(fieldName);
  2878. return GetFieldValues(Array,size,index,lockCursorPos,maxRows);
  2879. }
  2881. /*========================================================================
  2882. Name: 获取记录集合中指定列的字符串形式的值
  2883. -----------------------------------------------------
  2884. params: index   列在集合中的位置
  2885.         lockCursorPos   为TRUE时，保持游标原来的位置不变
  2886. maxRows    一次返回记录的最大行
  2887. size        Array数组大小
  2888. ---------------------------------
  2889. remarks: 如果lockCursorPos为TRUE时,保持游标原来的位置不变,所以重复调用该函数返回
  2890.          内容一样。考虑到如果记录集合中记录数较多，array数组很大，会占用较多的系统
  2891.  资源，所以对它进行优化：
  2892.      当lockCursorPos 为FALSE 时，将从当前记录开始，返回maxRows条记录的值。
  2893. ==========================================================================*/
  2894. int CAdoRecordSet::GetFieldValues(double *Array, int size, int index, BOOL lockCursorPos, int maxRows)
  2895. {
  2896. long pos ;
  2897. long count = m_pRecordset->GetRecordCount();
  2898. long colCount = GetFieldsCount();
  2899. if (count <=0 || index >= colCount || index <0) //check values
  2900. {
  2901.      #ifdef _DEBUG
  2902. if (count <=0 )
  2903. TRACE(_T("记录集合为空"));
  2904. else
  2905. TRACE(_T("超出字段范围"));
  2906.      #endif
  2907. return FALSE;
  2908. }
  2909. //
  2910. if (lockCursorPos)
  2911. {
  2912. pos= GetCursorPos();
  2913. }
  2915. for (int i = 0 ;i < maxRows && i < size;)
  2916. {
  2917. double temp;
  2918. if (!GetCollect(index,temp))
  2919. {
  2920. TRACE(_T("CAdoRecordSet::GetFieldValues 失败--%s"),GetLastError());
  2921. break;
  2922. }
  2923. Array[i++] = temp;
  2924. if (m_pRecordset->adoEOF)
  2925. {
  2926. break;
  2927. }
  2928. m_pRecordset->MoveNext();
  2929. }
  2931. if (lockCursorPos)
  2932. {
  2933. m_pRecordset->MoveFirst();
  2934. m_pRecordset->Move(pos);
  2935. }
  2936. return i;
  2937. }
  2940. int CAdoRecordSet::GetFieldValues(double *Array, int size, CString fieldName, BOOL lockCursorPos, int maxRows)
  2941. {
  2942. int index =GetFieldIndex(fieldName);
  2943. return GetFieldValues(Array,size,index,lockCursorPos,maxRows);
  2944. }
  2946. /*========================================================================
  2947. Name: 获取记录集合中指定列的字符串形式的值
  2948. -----------------------------------------------------
  2949. params: index   列在集合中的位置
  2950.         lockCursorPos   为TRUE时，保持游标原来的位置不变
  2951. maxRows    一次返回记录的最大行
  2952. size        Array数组大小
  2953. ---------------------------------
  2954. remarks: 如果lockCursorPos为TRUE时,保持游标原来的位置不变,所以重复调用该函数返回
  2955.          内容一样。考虑到如果记录集合中记录数较多，array数组很大，会占用较多的系统
  2956.  资源，所以对它进行优化：
  2957.      当lockCursorPos 为FALSE 时，将从当前记录开始，返回maxRows条记录的值。
  2958. ==========================================================================*/
  2959. int CAdoRecordSet::GetFieldValues(COleDateTime *Array, int size, int index, BOOL lockCursorPos, int maxRows)
  2960. {
  2961. long pos ;
  2962. long count = m_pRecordset->GetRecordCount();
  2963. long colCount = GetFieldsCount();
  2964. if (count <=0 || index >= colCount || index <0) //check values
  2965. {
  2966.      #ifdef _DEBUG
  2967. if (count <=0 )
  2968. TRACE(_T("记录集合为空"));
  2969. else
  2970. TRACE(_T("超出字段范围"));
  2971.      #endif
  2972. return FALSE;
  2973. }
  2974. //
  2975. if (lockCursorPos)
  2976. {
  2977. pos= GetCursorPos();
  2978. }
  2980. for (int i = 0 ;i < maxRows && i < size;)
  2981. {
  2982. COleDateTime temp;
  2983. if (!GetCollect(index,temp))
  2984. {
  2985. TRACE(_T("CAdoRecordSet::GetFieldValues 失败--%s"),GetLastError());
  2986. break;
  2987. }
  2988. Array[i++] = temp;
  2989. if (m_pRecordset->adoEOF)
  2990. {
  2991. break;
  2992. }
  2993. m_pRecordset->MoveNext();
  2994. }
  2996. if (lockCursorPos)
  2997. {
  2998. m_pRecordset->MoveFirst();
  2999. m_pRecordset->Move(pos);
  3000. }
  3001. return i;
  3002. }
  3005. int CAdoRecordSet::GetFieldValues(COleDateTime *Array, int size, CString fieldName, BOOL lockCursorPos, int maxRows)
  3006. {
  3007. int index =GetFieldIndex(fieldName);
  3008. return GetFieldValues(Array,size,index,lockCursorPos,maxRows);
  3009. }
  3012. BOOL CAdoRecordSet::SeekToFieldValue(int fieldIndex, const CString & Value ,BOOL flag)
  3013. {
  3014. if (flag)
  3015. {
  3016. MoveLast();
  3017. CString Fieldvalue;
  3018. while (!IsBOF())
  3019. {
  3020. GetCollect(fieldIndex, Fieldvalue);
  3021. if (Value == Fieldvalue)
  3022. return TRUE;
  3023. MovePrevious();
  3024. }
  3025. return FALSE;
  3026. }
  3027. else
  3028. {
  3029. MoveFirst();
  3030. CString Fieldvalue;
  3031. while (!IsEOF())
  3032. {
  3033. GetCollect(fieldIndex, Fieldvalue);
  3034. if (Value == Fieldvalue)
  3035. return TRUE;
  3036. MoveNext();
  3037. }
  3038. return FALSE;
  3039. }
  3041. }
  3043. BOOL CAdoRecordSet::LoadOLEDataFromDB(CString CreateFileName ,CString feildName)
  3044. {
  3045. long nSize = GetFields()->GetItem(_variant_t(feildName))->ActualSize;
  3046. if(nSize > 0)
  3047. {
  3048. _variant_t varBLOB;
  3049. varBLOB = GetFields()->GetItem(_variant_t(feildName))->GetChunk(nSize);
  3050. if(varBLOB.vt == (VT_ARRAY | VT_UI1))
  3051. {
  3052. CFile file;
  3053. if (!file.Open(CreateFileName,CFile::modeWrite|CFile::modeCreate))
  3054. return FALSE;
  3055. // if(BYTE *pBuffer = new BYTE [nSize+1]) ///重新申请必要的存储空间
  3056. // {
  3057. char *pBuf = NULL;
  3058. SafeArrayAccessData(varBLOB.parray,(void **)&pBuf);
  3059. // memcpy(pBuffer,pBuf,nSize); ///复制数据到缓冲区m_pBMPBuffer
  3060. SafeArrayUnaccessData (varBLOB.parray);
  3061. // int nSize = lDataSize;
  3062. // (Pic->LoadPictureData(pBuffer, nSize));
  3063. file.WriteHuge((void*) pBuf,nSize);
  3064. file.Close();
  3065. // delete [] pBuffer;
  3066. pBuf=0;
  3068. // }
  3069. }
  3070. }
  3071. return TRUE;
  3072. }