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

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

MySQL数据库

开发平台：

Visual C++

UtilTransactions.hpp：源码内容
  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 */
  17. #ifndef UTIL_TRANSACTIONS_HPP
  18. #define UTIL_TRANSACTIONS_HPP
  20. #include <NDBT.hpp>
  22. typedef int (ReadCallBackFn)(NDBT_ResultRow*);
  24. class UtilTransactions {
  25. public:
  26.   enum ScanLock {
  27.     SL_Read = 0,
  28.     SL_ReadHold = 1,
  29.     SL_Exclusive = 2
  30.   };
  32.   UtilTransactions(const NdbDictionary::Table&);
  33.   UtilTransactions(Ndb* ndb, const char * tableName);
  35.   int clearTable(Ndb*, 
  36.  int records = 0,
  37.  int parallelism = 0);
  38.   
  39.   // Delete all records from the table using a scan
  40.   int clearTable1(Ndb*, 
  41.   int records = 0,
  42.   int parallelism = 0);
  43.   // Delete all records from the table using a scan
  44.   // Using batching
  45.   int clearTable2(Ndb*, 
  46.   int records = 0,
  47.   int parallelism = 0);
  48.   
  49.   int clearTable3(Ndb*, 
  50.   int records = 0,
  51.   int parallelism = 0);
  52.   
  53.   int selectCount(Ndb*, 
  54.   int parallelism = 0,
  55.   int* count_rows = NULL,
  56.   NdbOperation::LockMode lm = NdbOperation::LM_CommittedRead,
  57.   NdbConnection* pTrans = NULL);
  58.   int scanReadRecords(Ndb*,
  59.       int parallelism,
  60.       NdbOperation::LockMode lm,
  61.       int records,
  62.       int noAttribs,
  63.       int* attrib_list,
  64.       ReadCallBackFn* fn = NULL);
  65.   int verifyIndex(Ndb*,
  66.   const char* indexName,
  67.   int parallelism = 0,
  68.   bool transactional = false);
  70.   int copyTableData(Ndb*,
  71. const char* destName);
  73.   
  74. private:
  75.   static int takeOverAndDeleteRecord(Ndb*, 
  76.      NdbOperation*);
  78.   int addRowToDelete(Ndb* pNdb, 
  79.      NdbConnection* pDelTrans,
  80.      NdbOperation* pOrgOp);
  82.   
  83.   int addRowToInsert(Ndb* pNdb, 
  84.      NdbConnection* pInsTrans,
  85.      NDBT_ResultRow & row,
  86.      const char* insertTabName);
  89.   int verifyUniqueIndex(Ndb*,
  90. const NdbDictionary::Index *,
  91. int parallelism = 0,
  92. bool transactional = false);
  94.   int scanAndCompareUniqueIndex(Ndb* pNdb,
  95. const NdbDictionary::Index *,
  96. int parallelism,
  97. bool transactional);
  98.   
  99.   int readRowFromTableAndIndex(Ndb* pNdb,
  100.        NdbConnection* pTrans,
  101.        const NdbDictionary::Index *,
  102.        NDBT_ResultRow& row );
  104.   int verifyOrderedIndex(Ndb*,
  105.  const NdbDictionary::Index *,
  106.  int parallelism = 0,
  107.  bool transactional = false);
  108.   
  110.   int get_values(NdbOperation* op, NDBT_ResultRow& dst);
  111.   int equal(const NdbDictionary::Table*, NdbOperation*, const NDBT_ResultRow&);
  112.   int equal(const NdbDictionary::Index*, NdbOperation*, const NDBT_ResultRow&);
  114. protected:
  115.   int m_defaultClearMethod;
  116.   const NdbDictionary::Table& tab;
  117. };
  119. #endif