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

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

数据库系统

开发平台：

Visual C++

AdoConnection.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "AdoConnection.h"
  3. #include <math.h>
  5. #ifdef _DEBUG
  6. #undef THIS_FILE
  7. static char THIS_FILE[]=__FILE__;
  8. #define new DEBUG_NEW
  9. #endif
  11. /*########################################################################
  12.   ------------------------------------------------
  13.     数值类型转换
  14.   ------------------------------------------------
  15.   ########################################################################*/
  16. COleDateTime vartodate(const _variant_t& var)
  17. {
  18. COleDateTime value;
  19. switch (var.vt) 
  20. {
  21. case VT_DATE:
  22. {
  23. value = var.date;
  24. }
  25. break;
  26. case VT_EMPTY:
  27. case VT_NULL:
  28. value.SetStatus(COleDateTime::null);
  29. break;
  30. default:
  31. value.SetStatus(COleDateTime::null);
  32. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  33. }
  34. return value;
  35. }
  37. COleCurrency vartocy(const _variant_t& var)
  38. {
  39. COleCurrency value;
  40. switch (var.vt) 
  41. {
  42. case VT_CY:
  43. value = (CURRENCY)var.cyVal;
  44. break;
  45. case VT_EMPTY:
  46. case VT_NULL:
  47. value.m_status = COleCurrency::null;
  48. break;
  49. default:
  50. value.m_status = COleCurrency::null;
  51. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  52. }
  53. return value;
  54. }
  56. bool vartobool(const _variant_t& var)
  57. {
  58. bool value = false;
  59. switch (var.vt)
  60. {
  61. case VT_BOOL:
  62. value = var.boolVal ? true : false;
  63. case VT_EMPTY:
  64. case VT_NULL:
  65. break;
  66. default:
  67. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  68. }
  69. return value;
  70. }
  72. BYTE vartoby(const _variant_t& var)
  73. {
  74. BYTE value = 0;
  75. switch (var.vt)
  76. {
  77. case VT_I1:
  78. case VT_UI1:
  79. value = var.bVal;
  80. break;
  81. case VT_NULL:
  82. case VT_EMPTY:
  83. value = 0;
  84. break;
  85. default:
  86. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  87. }
  88. return value;
  89. }
  91. short vartoi(const _variant_t& var)
  92. {
  93. short value = 0;
  94. switch (var.vt)
  95. {
  96. case VT_BOOL:
  97. value = var.boolVal;
  98. break;
  99. case VT_UI1:
  100. case VT_I1:
  101. value = var.bVal;
  102. break;
  103. case VT_I2:
  104. case VT_UI2:
  105. value = var.iVal;
  106. break;
  107. case VT_NULL:
  108. case VT_EMPTY:
  109. value = 0;
  110. break;
  111. default:
  112. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  113. }
  114. return value;
  115. }
  117. long vartol(const _variant_t& var)
  118. {
  119. long value = 0;
  120. switch (var.vt)
  121. {
  122. case VT_BOOL:
  123. value = var.boolVal;
  124. break;
  125. case VT_UI1:
  126. case VT_I1:
  127. value = var.bVal;
  128. break;
  129. case VT_UI2:
  130. case VT_I2:
  131. value = var.iVal;
  132. break;
  133. case VT_I4:
  134. case VT_UI4:
  135. value = var.lVal;
  136. break;
  137. case VT_INT:
  138. value = var.intVal;
  139. break;
  140. case VT_R4:
  141. value = (long)(var.fltVal + 0.5);
  142. break;
  143. case VT_R8:
  144. value = (long)(var.dblVal + 0.5);
  145. break;
  146. case VT_DECIMAL:
  147. value = (long)var;
  148. break;
  149. case VT_CY:
  150. value = (long)var;
  151. break;
  152. case VT_BSTR://字符串
  153. case VT_LPSTR://字符串
  154. case VT_LPWSTR://字符串
  155. value = atol((LPCTSTR)(_bstr_t)var);
  156. break;
  157. case VT_NULL:
  158. case VT_EMPTY:
  159. value = 0;
  160. break;
  161. default:
  162. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  163. }
  164. return value;
  165. }
  167. double vartof(const _variant_t& var)
  168. {
  169. double value = 0;
  170. switch (var.vt)
  171. {
  172. case VT_R4:
  173. value = var.fltVal;
  174. break;
  175. case VT_R8:
  176. value = var.dblVal;
  177. break;
  178. case VT_DECIMAL:
  179. value = (double)var;
  180. break;
  181. case VT_CY:
  182. value = (double)var;
  183. break;
  184. case VT_BOOL:
  185. value = var.boolVal;
  186. break;
  187. case VT_UI1:
  188. case VT_I1:
  189. value = var.bVal;
  190. break;
  191. case VT_UI2:
  192. case VT_I2:
  193. value = var.iVal;
  194. break;
  195. case VT_UI4:
  196. case VT_I4:
  197. value = var.lVal;
  198. break;
  199. case VT_INT:
  200. value = var.intVal;
  201. break;
  202. case VT_BSTR://字符串
  203. case VT_LPSTR://字符串
  204. case VT_LPWSTR://字符串
  205. value = atof((LPCTSTR)(_bstr_t)var);
  206. break;
  207. case VT_NULL:
  208. case VT_EMPTY:
  209. value = 0;
  210. break;
  211. default:
  212. value = 0;
  213. TRACE(_T("Warning: 未处理的 _variant_t 类型值; 文件: %s; 行: %dn"), __FILE__, __LINE__);
  214. }
  215. return value;
  216. }
  218. CString vartostr(const _variant_t &var)
  219. {
  220. CString strValue;
  222. switch (var.vt)
  223. {
  224. case VT_BSTR://字符串
  225. case VT_LPSTR://字符串
  226. case VT_LPWSTR://字符串
  227. strValue = (LPCTSTR)(_bstr_t)var;
  228. break;
  229. case VT_I1:
  230. case VT_UI1:
  231. strValue.Format("%d", var.bVal);
  232. break;
  233. case VT_I2://短整型
  234. strValue.Format("%d", var.iVal);
  235. break;
  236. case VT_UI2://无符号短整型
  237. strValue.Format("%d", var.uiVal);
  238. break;
  239. case VT_INT://整型
  240. strValue.Format("%d", var.intVal);
  241. break;
  242. case VT_I4: //整型
  243. strValue.Format("%d", var.lVal);
  244. break;
  245. case VT_I8: //长整型
  246. strValue.Format("%d", var.lVal);
  247. break;
  248. case VT_UINT://无符号整型
  249. strValue.Format("%d", var.uintVal);
  250. break;
  251. case VT_UI4: //无符号整型
  252. strValue.Format("%d", var.ulVal);
  253. break;
  254. case VT_UI8: //无符号长整型
  255. strValue.Format("%d", var.ulVal);
  256. break;
  257. case VT_VOID:
  258. strValue.Format("%8x", var.byref);
  259. break;
  260. case VT_R4://浮点型
  261. strValue.Format("%.4f", var.fltVal);
  262. break;
  263. case VT_R8://双精度型
  264. strValue.Format("%.8f", var.dblVal);
  265. break;
  266. case VT_DECIMAL: //小数
  267. strValue.Format("%.8f", (double)var);
  268. break;
  269. case VT_CY:
  270. {
  271. COleCurrency cy = var.cyVal;
  272. strValue = cy.Format();
  273. }
  274. break;
  275. case VT_BLOB:
  276. case VT_BLOB_OBJECT:
  277. case 0x2011:
  278. strValue = "[BLOB]";
  279. break;
  280. case VT_BOOL://布尔型
  282. strValue = var.boolVal ? "TRUE" : "FALSE";
  283. break;
  284. case VT_DATE: //日期型
  285. {
  286. DATE dt = var.date;
  287. COleDateTime da = COleDateTime(dt); 
  288. strValue = da.Format("%Y-%m-%d %H:%M:%S");
  289. }
  290. break;
  291. case VT_NULL://NULL值
  292. strValue = "";
  293. break;
  294. case VT_EMPTY://空
  295. strValue = "";
  296. break;
  297. case VT_UNKNOWN://未知类型
  298. default:
  299. strValue = "UN_KNOW";
  300. break;
  301. }
  302. return strValue;
  303. }
  305. /*########################################################################
  306.  ------------------------------------------------
  307. CAdoConnection class 构造/析构函数
  308.  ------------------------------------------------
  309.   ########################################################################*/
  311. CAdoConnection::CAdoConnection()
  312. {
  313. //创建 Connection 对象---------------------------
  314. m_pConnection.CreateInstance("ADODB.Connection");
  315. #ifdef _DEBUG
  316. if (m_pConnection == NULL)
  317. {
  318. AfxMessageBox("Connection 对象创建失败! 请确认是否初始化了COM环境rn");
  319. }
  320. #endif
  321. ASSERT(m_pConnection != NULL);
  322. }
  324. CAdoConnection::~CAdoConnection()
  325. {
  326. if (m_pConnection != NULL)
  327. {
  328. Release();
  329. }
  330. }
  332. /*========================================================================
  333. Name: 连接到数据源.
  334. -----------------------------------------------------
  335. Params: [lpszConnect]: 连接字符串, 包含连接信息.
  336. [lOptions]: 可选. 决定该方法是以同步还是异步的方式连接数据
  337. 源. 可以是如下某个常量:
  338. [常量] [说明] 
  339. ----------------------------------
  340. adConnectUnspecified (默认)同步方式打开连接. 
  341. adAsyncConnect 异步方式打开连接. Ado用 ConnectComplete 事
  342. 件来通知已经完成连接. 
  343. ==========================================================================*/
  344. BOOL CAdoConnection::Open(LPCTSTR lpszConnect, long lOptions)
  345. {
  346. ASSERT(m_pConnection != NULL);
  347. ASSERT(AfxIsValidString(lpszConnect));
  349. if (strcmp(lpszConnect, _T("")) != 0)
  350. {
  351. m_strConnect = lpszConnect;
  352. }
  354. if (m_strConnect.IsEmpty())
  355. {
  356. ASSERT(FALSE);
  357. return FALSE;
  358. }
  360. if (IsOpen()) Close();
  362. try
  363. {
  364. // 连接数据库 ---------------------------------------------
  365. return (m_pConnection->Open(_bstr_t(LPCTSTR(m_strConnect)), "", "", lOptions) == S_OK);
  366. }
  367. catch (_com_error e)
  368. {
  369. TRACE(_T("Warning: 连接数据库发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  370. TRACE(_T("%srn"), GetLastErrorText());
  371. return FALSE;
  372. } 
  373. catch (...)
  374. {
  375. TRACE(_T("Warning: 连接数据库时发生未知错误:"));
  376. }
  377. return FALSE;
  378. }
  380. /*========================================================================
  381. Name: 连接 SQL SERVER 数据库. 
  382. -----------------------------------------------------
  383. Params: [dbsrc]: SQL SERVER 服务器名.
  384. [dbname]: 默认的数据库名.
  385. [user]: 用户名.
  386. [pass]: 密码.
  387. ==========================================================================*/
  388. BOOL CAdoConnection::ConnectSQLServer(CString dbsrc, CString dbname, CString user, CString pass, long lOptions)
  389. {
  390. CString strConnect = _T("Provider=SQLOLEDB.1; Data Source=") + dbsrc + 
  391.  _T("; Initial Catalog=") + dbname  +
  392.  _T("; User ID=") + user + 
  393.  _T("; PWD=") + pass;
  394. return Open(LPCTSTR(strConnect), lOptions);
  395. }
  398. BOOL CAdoConnection::ConnectAccess(CString dbpath, CString pass, long lOptions)
  399. {
  400. CString strConnect = _T("Provider=Microsoft.Jet.OLEDB.4.0; Data Source=") + dbpath;
  401. if (pass != _T("")) 
  402. {
  403. strConnect += _T("Jet OLEDB:Database Password=") + pass + _T(";");
  404. }
  405. return Open(LPCTSTR(strConnect), lOptions);
  406. }
  409. /*========================================================================
  410. Name: 连接 Oracle 数据库. 
  411. -----------------------------------------------------
  412. Params: [server]: 服务器名.
  413. [name]: 访问用户名.
  414. [password]: 访问密码.
  415. ===========================================================================*/
  416. BOOL CAdoConnection::ConnectToOracle(CString server, CString name, CString password, long lOptions)
  417. {
  418. //Oracle 的连接：
  419. CString strConnection = "Provider=MSDAORA;Data Source=" + server +
  420. ";User ID=" + name + "; Password=" + password;
  421. return Open((_bstr_t)strConnection,lOptions);
  422. }
  424. /*========================================================================
  425. Name: 通过 udl 文件连接数据库. 
  426. -----------------------------------------------------
  427. Params: [strFileName]: UDL 数据库连接文件路径名.
  428. ==========================================================================*/
  429. BOOL CAdoConnection::OpenUDLFile(LPCTSTR strFileName, long lOptions)
  430. {
  431. CString strConnect = _T("File Name=");
  432. strConnect += strFileName;
  433. return Open(LPCTSTR(strConnect), lOptions);
  434. }
  436. /*========================================================================
  437. Name: 关闭与数据源的连接.
  438. -----------------------------------------------------
  439. Remarks: 使用 Close 方法可关闭 Connection 对象以便释放所有关联的系统资源. 
  440. ==========================================================================*/
  441. void CAdoConnection::Close()
  442. {
  443. try
  444. {
  445. if (m_pConnection != NULL && IsOpen()) 
  446. {
  447. m_pConnection->Close();
  448. }
  449. }
  450. catch (_com_error e)
  451. {
  452. TRACE(_T("Warning: 关闭数据库发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  453. } 
  454. }
  456. /*========================================================================
  457. Name: 关闭连接并释放对象.
  458. -----------------------------------------------------
  459. Remarks: 关闭连接并释放connection对象.
  460. ==========================================================================*/
  461. void CAdoConnection::Release()
  462. {
  463. if (IsOpen()) Close();
  464. m_pConnection.Release();
  465. }
  467. /*========================================================================
  468. Name: 执行指定的查询、SQL 语句、存储过程等.
  469.     ----------------------------------------------------------
  470. Remarks: 请参考 CAdoRecordSet 类的Open方法. 返回的 Recordset 对象始
  471. 终为只读、仅向前的游标.
  472. ==========================================================================*/
  473. _RecordsetPtr CAdoConnection::Execute(LPCTSTR lpszSQL, long lOptions)
  474. {
  475. ASSERT(m_pConnection != NULL);
  476. ASSERT(AfxIsValidString(lpszSQL));
  478. try
  479. {
  480. return m_pConnection->Execute(_bstr_t(lpszSQL), NULL, lOptions);
  481. }
  482. catch (_com_error e)
  483. {
  484. TRACE(_T("Warning: Execute 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  485. return FALSE;
  486. } 
  487. return FALSE;
  488. }
  490. /*========================================================================
  491. Remarks: 请参考 CAdoRecordSet 类 Cancel 方法.
  492. ==========================================================================*/
  493. BOOL CAdoConnection::Cancel()
  494. {
  495. ASSERT(m_pConnection != NULL);
  496. try
  497. {
  498. return m_pConnection->Cancel();
  499. }
  500. catch (_com_error e)
  501. {
  502. TRACE(_T("Warning: Cancel 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  503. return FALSE;
  504. } 
  505. return FALSE;
  506. }
  508. /*========================================================================
  509. Name: 取得最后发生的错误信息.
  510. ==========================================================================*/
  511. CString CAdoConnection::GetLastErrorText()
  512. {
  513. ASSERT(m_pConnection != NULL);
  514. CString strErrors = "";
  515. try
  516. {
  517. if (m_pConnection != NULL)
  518. {
  519. ErrorsPtr pErrors = m_pConnection->Errors;
  520. CString strError;
  521. for (long n = 0; n < pErrors->Count; n++)
  522. {
  523. ErrorPtr pError = pErrors->GetItem(n);
  524. strError.Format(_T("Description: %srnState: %s, Native: %d, Source: %srn"),
  525. (LPCTSTR)pError->Description,
  526. (LPCTSTR)pError->SQLState,
  527.  pError->NativeError,
  528. (LPCTSTR)pError->Source);
  529. strErrors += strError;
  530. }
  531. }
  532. return strErrors;
  533. }
  534. catch (_com_error e)
  535. {
  536. TRACE(_T("Warning: GetLastError 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  537. return strErrors;
  538. } 
  539. #ifdef _DEBUG
  540. return strErrors;
  541. #else
  542. return "数据操作错误";
  543. #endif
  545. }
  547. ErrorsPtr CAdoConnection::GetErrors()
  548. {
  549. ASSERT(m_pConnection != NULL);
  550. try
  551. {
  552. if (m_pConnection != NULL)
  553. {
  554. return m_pConnection->Errors;
  555. }
  556. return NULL;
  557. }
  558. catch (_com_error e)
  559. {
  560. TRACE(_T("Warning: GetErrors 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  561. return NULL;
  562. } 
  563. return NULL;
  564. }
  566. ErrorPtr CAdoConnection::GetError(long index)
  567. {
  568. ASSERT(m_pConnection != NULL);
  569. try
  570. {
  571. if (m_pConnection != NULL)
  572. {
  573. ErrorsPtr pErrors =  m_pConnection->Errors;
  574. if (index >= 0 && index < pErrors->Count)
  575. {
  576. return pErrors->GetItem(_variant_t(index));
  577. }
  578. }
  579. return NULL;
  580. }
  581. catch (_com_error e)
  582. {
  583. TRACE(_T("Warning: GetError 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  584. return NULL;
  585. } 
  586. return NULL;
  587. }
  589. /*========================================================================
  590. Name: 取得连接时间.
  591. ==========================================================================*/
  592. long CAdoConnection::GetConnectTimeOut()
  593. {
  594. ASSERT(m_pConnection != NULL);
  595. try
  596. {
  597. return m_pConnection->GetConnectionTimeout();
  598. }
  599. catch (_com_error e)
  600. {
  601. TRACE(_T("Warning: GetConnectTimeOut 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  602. return -1;
  603. } 
  604. return -1;
  605. }
  607. /*========================================================================
  608. Name: 设置连接时间.
  609. ==========================================================================*/
  610. BOOL CAdoConnection::SetConnectTimeOut(long lTime)
  611. {
  612. ASSERT(m_pConnection != NULL);
  613. try
  614. {
  615. m_pConnection->PutConnectionTimeout(lTime);
  616. return TRUE;
  617. }
  618. catch (_com_error e)
  619. {
  620. TRACE(_T("Warning: SetConnectTimeOut 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  621. return FALSE;
  622. } 
  623. }
  625. /*========================================================================
  626. Name: 取得默认数据库的名称.
  627. ==========================================================================*/
  628. CString CAdoConnection::GetDefaultDatabase()
  629. {
  630. ASSERT(m_pConnection != NULL);
  631. try
  632. {
  633. return CString(LPCTSTR(_bstr_t(m_pConnection->GetDefaultDatabase())));
  634. }
  635. catch (_com_error e)
  636. {
  637. TRACE(_T("Warning: GetDefaultDatabase 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  638. return CString(_T(""));
  639. } 
  640. }
  642. /*========================================================================
  643. Name: 取得 Connection 对象提供者的名称.
  644. ==========================================================================*/
  645. CString CAdoConnection::GetProviderName()
  646. {
  647. ASSERT(m_pConnection != NULL);
  648. try
  649. {
  650. return CString(LPCTSTR(_bstr_t(m_pConnection->GetProvider())));
  651. }
  652. catch (_com_error e)
  653. {
  654. TRACE(_T("Warning: GetProviderName 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  655. return CString(_T(""));
  656. } 
  657. }
  659. /*========================================================================
  660. Name: 取得 ADO 的版本号
  661. ==========================================================================*/
  662. CString CAdoConnection::GetVersion()
  663. {
  664. ASSERT(m_pConnection != NULL);
  665. try
  666. {
  667. return CString(LPCTSTR(_bstr_t(m_pConnection->GetVersion())));
  668. }
  669. catch (_com_error e)
  670. {
  671. TRACE(_T("Warning: GetVersion 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  672. return CString(_T(""));
  673. } 
  674. }
  676. /*========================================================================
  677. Name: 取得对象的状态(同 Recordset 对象的 GetState 方法).
  678. -----------------------------------------------------
  679. returns: 返回下列常量之一的长整型值.
  680. [常量] [说明] 
  681. ----------------------------------
  682. adStateClosed 指示对象是关闭的. 
  683. adStateOpen 指示对象是打开的. 
  684. -----------------------------------------------------
  685. Remarks: 可以随时使用 State 属性取得指定对象的当前状态.
  686. ==========================================================================*/
  687. long CAdoConnection::GetState()
  688. {
  689. ASSERT(m_pConnection != NULL);
  690. try
  691. {
  692. return m_pConnection->GetState();
  693. }
  694. catch (_com_error e)
  695. {
  696. TRACE(_T("Warning: GetState 发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  697. return -1;
  698. } 
  699. return -1;
  700. }
  702. /*========================================================================
  703. Name: 检测连接对象是否为打开状态.
  704. ==========================================================================*/
  705. BOOL CAdoConnection::IsOpen()
  706. {
  707. try
  708. {
  709. return (m_pConnection != NULL && (m_pConnection->State & adStateOpen));
  710. }
  711. catch (_com_error e)
  712. {
  713. TRACE(_T("Warning: IsOpen 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  714. return FALSE;
  715. } 
  716. return FALSE;
  717. }
  719. /*========================================================================
  720. Name: 取得在 Connection 对象中修改数据的可用权限.
  721.     ----------------------------------------------------------
  722. returns: 返回以下某个 ConnectModeEnum 的值.
  723. [常量]  [说明] 
  724. ----------------------------------
  725. adModeUnknown  默认值. 表明权限尚未设置或无法确定. 
  726. adModeRead  表明权限为只读. 
  727. adModeWrite  表明权限为只写. 
  728. adModeReadWrite  表明权限为读/写. 
  729. adModeShareDenyRead  防止其他用户使用读权限打开连接. 
  730. adModeShareDenyWrite 防止其他用户使用写权限打开连接. 
  731. adModeShareExclusive 防止其他用户打开连接. 
  732. adModeShareDenyNone  防止其他用户使用任何权限打开连接.
  733.     ----------------------------------------------------------
  734. Remarks: 使用 Mode 属性可设置或返回当前连接上提供者正在使用的访问权限.
  735. ==========================================================================*/
  736. ConnectModeEnum CAdoConnection::GetMode()
  737. {
  738. ASSERT(m_pConnection != NULL);
  739. try
  740. {
  741. return m_pConnection->GetMode();
  742. }
  743. catch (_com_error e)
  744. {
  745. TRACE(_T("Warning: GetMode 发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  746. return adModeUnknown;
  747. } 
  748. return adModeUnknown;
  749. }
  751. /*========================================================================
  752. Name: 设置在 Connection 中修改数据的可用权限. 请参考 GetMode 方法.
  753.     ----------------------------------------------------------
  754. Remarks: 只能在关闭 Connection 对象时方可设置 Mode 属性.
  755. ==========================================================================*/
  756. BOOL CAdoConnection::SetMode(ConnectModeEnum mode)
  757. {
  758. ASSERT(m_pConnection != NULL);
  759. ASSERT(!IsOpen());
  761. try
  762. {
  763. m_pConnection->PutMode(mode);
  764. }
  765. catch (_com_error e)
  766. {
  767. TRACE(_T("Warning: SetMode 发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  768. return FALSE;
  769. } 
  770. return TRUE;
  771. }
  773. /*========================================================================
  774.     Name: 从数据源获取数据库信息.
  775. -----------------------------------------------------
  776. Params: QueryType  所要运行的模式查询类型,可以为下列任意常量.
  777. adSchemaAsserts CONSTRAINT_CATALOG
  778. CONSTRAINT_SCHEMA
  779. CONSTRAINT_NAME 
  780. adSchemaCatalogs CATALOG_NAME 
  781. adSchemaCharacterSets CHARACTER_SET_CATALOG
  782. CHARACTER_SET_SCHEMA
  783. CHARACTER_SET_NAME 
  784. adSchemaCheckConstraints CONSTRAINT_CATALOG
  785. CONSTRAINT_SCHEMA
  786. CONSTRAINT_NAME 
  787. adSchemaCollations  COLLATION_CATALOG
  788. COLLATION_SCHEMA
  789. COLLATION_NAME 
  790. adSchemaColumnDomainUsage DOMAIN_CATALOG
  791. DOMAIN_SCHEMA
  792. DOMAIN_NAME
  793. COLUMN_NAME 
  794. adSchemaColumnPrivileges TABLE_CATALOG
  795. TABLE_SCHEMA
  796. TABLE_NAME
  797. COLUMN_NAME
  798. GRANTOR
  799. GRANTEE 
  800. adSchemaColumns TABLE_CATALOG
  801. TABLE_SCHEMA
  802. TABLE_NAME
  803. COLUMN_NAME 
  804. adSchemaConstraintColumnUsage TABLE_CATALOG
  805. TABLE_SCHEMA
  806. TABLE_NAME
  807. COLUMN_NAME 
  808. adSchemaConstraintTableUsage TABLE_CATALOG
  809. TABLE_SCHEMA
  810. TABLE_NAME 
  811. adSchemaForeignKeys PK_TABLE_CATALOG
  812. PK_TABLE_SCHEMA
  813. PK_TABLE_NAME
  814. FK_TABLE_CATALOG
  815. FK_TABLE_SCHEMA
  816. FK_TABLE_NAME 
  817. adSchemaIndexes TABLE_CATALOG
  818. TABLE_SCHEMA
  819. INDEX_NAME
  820. TYPE
  821. TABLE_NAME 
  822. adSchemaKeyColumnUsage CONSTRAINT_CATALOG
  823. CONSTRAINT_SCHEMA
  824. CONSTRAINT_NAME
  825. TABLE_CATALOG
  826. TABLE_SCHEMA
  827. TABLE_NAME
  828. COLUMN_NAME 
  829. adSchemaPrimaryKeys PK_TABLE_CATALOG
  830. PK_TABLE_SCHEMA
  831. PK_TABLE_NAME 
  832. adSchemaProcedureColumns PROCEDURE_CATALOG
  833. PROCEDURE_SCHEMA
  834. PROCEDURE_NAME
  835. COLUMN_NAME 
  836. adSchemaProcedureParameters PROCEDURE_CATALOG
  837. PROCEDURE_SCHEMA
  838. PROCEDURE_NAME
  839. PARAMTER_NAME 
  840. adSchemaProcedures PROCEDURE_CATALOG
  841. PROCEDURE_SCHEMA
  842. PROCEDURE_NAME
  843. PROCEDURE_TYPE 
  844. adSchemaProviderSpecific  参见说明 
  845. adSchemaProviderTypes DATA_TYPE
  846. BEST_MATCH 
  847. adSchemaReferentialConstraints CONSTRAINT_CATALOG
  848. CONSTRAINT_SCHEMA
  849. CONSTRAINT_NAME 
  850. adSchemaSchemata CATALOG_NAME
  851. SCHEMA_NAME
  852. SCHEMA_OWNER 
  853. adSchemaSQLLanguages <无> 
  854. adSchemaStatistics TABLE_CATALOG
  855. TABLE_SCHEMA
  856. TABLE_NAME 
  857. adSchemaTableConstraints CONSTRAINT_CATALOG
  858. CONSTRAINT_SCHEMA
  859. CONSTRAINT_NAME
  860. TABLE_CATALOG
  861. TABLE_SCHEMA
  862. TABLE_NAME
  863. CONSTRAINT_TYPE 
  864. adSchemaTablePrivileges TABLE_CATALOG
  865. TABLE_SCHEMA
  866. TABLE_NAME
  867. GRANTOR
  868. GRANTEE 
  869. adSchemaTables TABLE_CATALOG
  870. TABLE_SCHEMA
  871. TABLE_NAME
  872. TABLE_TYPE 
  873. adSchemaTranslations TRANSLATION_CATALOG
  874. TRANSLATION_SCHEMA
  875. TRANSLATION_NAME 
  876. adSchemaUsagePrivileges OBJECT_CATALOG
  877. OBJECT_SCHEMA
  878. OBJECT_NAME
  879. OBJECT_TYPE
  880. GRANTOR
  881. GRANTEE 
  882. adSchemaViewColumnUsage VIEW_CATALOG
  883. VIEW_SCHEMA
  884. VIEW_NAME 
  885. adSchemaViewTableUsage VIEW_CATALOG
  886. VIEW_SCHEMA
  887. VIEW_NAME 
  888. adSchemaViews TABLE_CATALOG
  889. TABLE_SCHEMA
  890. TABLE_NAME 
  891. -----------------------------------------------------
  892. returns: 返回包含数据库信息的 Recordset 对象. Recordset 将以只读、静态
  893. 游标打开.
  894. -----------------------------------------------------
  895. Remarks: OpenSchema方法返回与数据源有关的信息，例如关于服务器上的表
  896. 以及表中的列等信息, 上述数据仅供参考, 视具体的数据源可能会有不同。
  897. ==========================================================================*/
  898. _RecordsetPtr CAdoConnection::OpenSchema(SchemaEnum QueryType)
  899. {
  900. ASSERT(m_pConnection != NULL);
  901. try
  902. {
  903. return m_pConnection->OpenSchema(QueryType, vtMissing, vtMissing);
  904. }
  905. catch(_com_error e)
  906. {
  907. TRACE(_T("Warning: OpenSchema方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  908. return NULL;
  909. } 
  910. return NULL;
  911. }
  913. /*########################################################################
  914.   ------------------------------------------------
  915. 事务处理
  916.   ------------------------------------------------
  917.   ########################################################################*/
  919. /*========================================================================
  920.     Name: 开始新事务.
  921. -----------------------------------------------------
  922. returns: 对于支持嵌套事务的数据库来说, 在已打开的事务中调用 BeginTrans 
  923. 方法将开始新的嵌套事务. 返回值将指示嵌套层次: 返回值为 1 表示已打开顶层
  924. 事务 (即事务不被另一个事务所嵌套), 返回值为 2 表示已打开第二层事务(嵌套
  925. 在顶层事务中的事务), 依次类推.
  926. -----------------------------------------------------
  927. Remarks: 一旦调用了 BeginTrans 方法, 在调用 CommitTrans 或 RollbackTrans
  928. 结束事务之前, 数据库将不再立即提交所作的任何更改.
  930. ==========================================================================*/
  931. long CAdoConnection::BeginTrans()
  932. {
  933. ASSERT(m_pConnection != NULL);
  934. try
  935. {
  936. return m_pConnection->BeginTrans();
  937. }
  938. catch (_com_error e)
  939. {
  940. TRACE(_T("Warning: BeginTrans 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  941. return -1;
  942. } 
  943. return -1;
  944. }
  946. /*########################################################################
  947.   ------------------------------------------------
  948. 事务处理
  949.   ------------------------------------------------
  950. BeginTrans - 开始新事务。
  951. CommitTrans - 保存任何更改并结束当前事务。它也可能启动新事务。
  952. RollbackTrans - 取消当前事务中所作的任何更改并结束事务。它也可能启动
  953. 新事务。
  955. 一旦调用了 BeginTrans 方法，在调用 CommitTrans 或 RollbackTrans 结
  956. 束事务之前，数据库将不再立即提交所作的任何更改。
  957. 对于支持嵌套事务的数据库来说，在已打开的事务中调用 BeginTrans 方法
  958. 将开始新的嵌套事务。返回值将指示嵌套层次：返回值为 1 表示已打开顶层事务
  959. (即事务不被另一个事务所嵌套)，返回值为 2 表示已打开第二层事务(嵌套
  960. 在顶层事务中的事务)，依次类推。调用 CommitTrans 或 RollbackTrans 只影
  961. 响最新打开的事务；在处理任何更高层事务之前必须关闭或回卷当前事务。
  962. 调用 CommitTrans 方法将保存连接上打开的事务中所做的更改并结束事务。
  963. 调用 RollbackTrans方法还原打开事务中所做的更改并结束事务。在未打开事务
  964. 时调用其中任何一种方法都将引发错误。
  965. 取决于 Connection 对象的 Attributes 属性，调用 CommitTrans 或 
  966. RollbackTrans 方法都可以自动启动新事务。如果 Attributes 属性设置为 
  967. adXactCommitRetaining，数据库在 CommitTrans 调用后会自动启动新事务。
  968. 如果 Attributes 属性设置为 adXactAbortRetaining，数据库在调用 
  969. RollbackTrans 之后将自动启动新事务。
  970.   ########################################################################*/
  971. /*========================================================================
  972.     Name: 保存任何更改并结束当前事务.
  973. -----------------------------------------------------
  974. Remarks: 调用 CommitTrans 或 RollbackTrans 只影响最新打开的事务; 在
  975. 处理任何更高层事务之前必须关闭或回卷当前事务.
  976. ==========================================================================*/
  977. BOOL CAdoConnection::CommitTrans()
  978. {
  979. ASSERT(m_pConnection != NULL);
  980. try
  981. {
  982. return SUCCEEDED(m_pConnection->CommitTrans());
  983. }
  984. catch (_com_error e)
  985. {
  986. TRACE(_T("Warning: CommitTrans 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  987. return FALSE;
  988. } 
  989. return FALSE;
  990. }
  992. /*========================================================================
  993.     Name: 取消当前事务中所作的任何更改并结束事务.
  994. ==========================================================================*/
  995. BOOL CAdoConnection::RollbackTrans()
  996. {
  997. ASSERT(m_pConnection != NULL);
  998. try
  999. {
  1000. return SUCCEEDED(m_pConnection->RollbackTrans());
  1001. }
  1002. catch (_com_error e)
  1003. {
  1004. TRACE(_T("Warning: RollbackTrans 方法发生异常. 错误信息: %s; 文件: %s; 行: %dn"), e.ErrorMessage(), __FILE__, __LINE__);
  1005. return FALSE;
  1006. } 
  1007. return FALSE;
  1008. }