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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
NdbEventOperation.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：3k
源码类别：

MySQL数据库

开发平台：

Visual C++

NdbEventOperation.cpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  18. /*****************************************************************************
  19.  * Name:          NdbEventOperation.cpp
  20.  * Include:
  21.  * Link:
  22.  * Author:        Tomas Ulin MySQL AB
  23.  * Date:          2003-11-21
  24.  * Version:       0.1
  25.  * Description:   Event support
  26.  * Documentation:
  27.  * Adjust:  2003-11-21  Tomas Ulin   First version.
  28.  ****************************************************************************/
  30. #include <Ndb.hpp>
  31. #include <signaldata/SumaImpl.hpp>
  32. #include <portlib/NdbMem.h>
  33. #include <transporter/TransporterDefinitions.hpp>
  34. #include <NdbEventOperation.hpp>
  35. #include "NdbEventOperationImpl.hpp"
  36. #include "NdbDictionaryImpl.hpp"
  38. NdbEventOperation::NdbEventOperation(Ndb *theNdb, 
  39.      const char* eventName, 
  40.      int bufferLength) 
  41.   : m_impl(* new NdbEventOperationImpl(*this,theNdb, 
  42.        eventName, 
  43.        bufferLength))
  44. {
  45. }
  47. NdbEventOperation::~NdbEventOperation()
  48. {
  49.   NdbEventOperationImpl * tmp = &m_impl;
  50.   if (this != tmp)
  51.     delete tmp;
  52. }
  54. NdbEventOperation::State NdbEventOperation::getState()
  55. {
  56.   return m_impl.getState();
  57. }
  59. NdbRecAttr *
  60. NdbEventOperation::getValue(const char *colName, char *aValue)
  61. {
  62.   return m_impl.getValue(colName, aValue, 0);
  63. }
  65. NdbRecAttr *
  66. NdbEventOperation::getPreValue(const char *colName, char *aValue)
  67. {
  68.   return m_impl.getValue(colName, aValue, 1);
  69. }
  71. int
  72. NdbEventOperation::execute()
  73. {
  74.   return m_impl.execute();
  75. }
  77. int
  78. NdbEventOperation::next(int *pOverrun)
  79. {
  80.   return m_impl.next(pOverrun);
  81. }
  83. bool
  84. NdbEventOperation::isConsistent()
  85. {
  86.   return m_impl.isConsistent();
  87. }
  89. Uint32
  90. NdbEventOperation::getGCI()
  91. {
  92.   return m_impl.getGCI();
  93. }
  95. Uint32
  96. NdbEventOperation::getLatestGCI()
  97. {
  98.   return m_impl.getLatestGCI();
  99. }
  101. NdbDictionary::Event::TableEvent
  102. NdbEventOperation::getEventType()
  103. {
  104.   return m_impl.getEventType();
  105. }
  107. void
  108. NdbEventOperation::print()
  109. {
  110.   m_impl.print();
  111. }
  113. /*
  114.  * Private members
  115.  */
  117. int
  118. NdbEventOperation::wait(void *p, int aMillisecondNumber)
  119. {
  120.   return NdbEventOperationImpl::wait(p, aMillisecondNumber);
  121. }
  123. NdbEventOperation::NdbEventOperation(NdbEventOperationImpl& impl) 
  124.   : m_impl(impl) {}