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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
S3P_MSSQLServer_Result.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：3k
源码类别：

模拟服务器

开发平台：

C/C++

S3P_MSSQLServer_Result.cpp：源码内容
  1. // S3P_MSSQLServer_Result.cpp: implementation of the S3P_MSSQLServer_Result class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "S3P_MSSQLServer_Result.h"
  6. #include <stdio.h>
  8. //////////////////////////////////////////////////////////////////////
  9. // Construction/Destruction
  10. //////////////////////////////////////////////////////////////////////
  11. S3P_MSSQLServer_Result::~S3P_MSSQLServer_Result()
  12. {
  13. m_pResult = NULL;
  14. assert(m_nAddRef == 0);
  15. }
  17. int S3P_MSSQLServer_Result::num_rows() const
  18. {
  19. int iRet = 0;
  20. try
  21. {
  22. if (m_pResult)
  23. iRet = m_pResult->GetRecordCount();
  24. }
  25. catch( _com_error e )
  26. {
  27. //printf("[S3P_MSSQLServer_Result::num_rows]COM error: %srn", e.ErrorMessage());
  28. }
  29. return iRet;
  30. }
  32. int S3P_MSSQLServer_Result::num_fields() const
  33. {
  34. int iRet = 0;
  35. try
  36. {
  37. if (m_pResult)
  38. {
  39. FieldsPtr pFs = m_pResult->GetFields();
  40. iRet = pFs->GetCount();
  41. }
  42. }
  43. catch( _com_error e )
  44. {
  45. //printf("[S3P_MSSQLServer_Result::num_fields]COM error: %srn", e.ErrorMessage());
  46. }
  47. return iRet;
  48. }
  50. void S3P_MSSQLServer_Result::data_seek(unsigned int offset, int nType) const
  51. {
  52. try
  53. {
  54. if (NULL != m_pResult)
  55. {
  56. unsigned int iRows = num_rows();
  57. if (nType == begin)
  58. {
  59. m_pResult->MoveFirst();
  60. if (offset > 0 && offset < iRows)
  61. {
  62. m_pResult->Move(offset);
  63. }
  64. }
  65. else if (nType == end)
  66. {
  67. m_pResult->MoveLast();
  68. }
  69. else if (nType == next)
  70. {
  71. for (;offset > 0; offset--)
  72. m_pResult->MoveNext();
  73. }
  74. else if (nType == previous)
  75. {
  76. for (;offset > 0; offset--)
  77. m_pResult->MovePrevious();
  78. }
  79. else
  80. assert(0);
  81. }
  82. }
  83. catch ( _com_error e )
  84. {
  85. //printf("[S3P_MSSQLServer_Result::data_seek(%d, %d)]COM error: %srn", offset, nType, e.ErrorMessage());
  86. }
  87. }
  89. bool S3P_MSSQLServer_Result::get_field_data(unsigned int nfieldindex, void* pData, unsigned long nsize)
  90. {
  91. BOOL bRet = FALSE;
  92. try
  93. {
  94. if (NULL != m_pResult && nsize == sizeof(VARIANT))
  95. {
  96. if (num_rows() > 0 && nfieldindex >= 0 && nfieldindex < num_fields())
  97. {
  98. _variant_t varIndex;
  99. varIndex = (long)nfieldindex;
  100. FieldPtr pField = m_pResult->Fields->GetItem(varIndex);
  101. if (SUCCEEDED(pField->get_Value((VARIANT*)pData)))
  102. bRet = TRUE;
  103. }
  104. }
  105. }
  106. catch ( _com_error e )
  107. {
  108. //printf("[S3P_MSSQLServer_Result::get_field_data(%d)]COM error: %srn", nfieldindex, e.ErrorMessage());
  109. }
  111. return bRet;
  112. }
  114. int S3P_MSSQLServer_Result::unuse()
  115. {
  116. if (m_pResult)
  117. {
  118. try
  119. {
  120. if (adStateOpen ==
  121. (m_pResult->GetState() & adStateOpen))
  122. {
  123. m_pResult->Close();
  124. }
  125. }
  126. catch (_com_error e)
  127. {
  128. //printf("[S3PDB_MSSQLServer_Connection::Do(1)]COM error: %srn", e.ErrorMessage());
  129. }
  130. m_nAddRef--;
  131. }
  133. return m_nAddRef;
  134. }
  136. int S3P_MSSQLServer_Result::GetResult( _Recordset** ppResult)
  137. {
  138. if (ppResult == NULL)
  139. return m_nAddRef;
  140. if (m_pResult == NULL)
  141. {
  142. HRESULT hr = m_pResult.CreateInstance("ADODB.Recordset");
  143. if (FAILED(hr))
  144. {
  145. m_pResult = NULL;
  146. }
  147. }
  149. assert(m_nAddRef == 0);
  150. if (m_nAddRef == 0)
  151. {
  152. *ppResult = m_pResult;
  154. if (*ppResult)
  155. m_nAddRef++;
  156. }
  158. return m_nAddRef;
  159. }