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

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

MySQL数据库

开发平台：

Visual C++

NDBT_DataSetTransaction.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 NDBT_DATA_SET_TRANSACTION_HPP
  18. #define NDBT_DATA_SET_TRANSACTION_HPP
  20. #include "NDBT_Table.hpp"
  21. #include <NdbApi.hpp>
  23. class NDBT_DataSet;
  25. /**
  26.  * This class contains a bunch a methods
  27.  * that operates on NDB together with a NDBT_DataSet
  28.  * using <b>one</b> transaction
  29.  */
  30. class NDBT_DataSetTransaction {
  31. public:
  32.   /**
  33.    * Store the data into ndb
  34.    */
  35.   static void insert(Ndb * theNdbObject,
  36.      const NDBT_DataSet *,
  37.      bool rollback = false);
  38.   
  39.   /**
  40.    * Read data (using pk) from ndb
  41.    */
  42.   static void readByPk(Ndb * theNdbObject,
  43.        NDBT_DataSet *,
  44.        bool rollback = false);
  45.   
  46.   /**
  47.    * Update data using pk
  48.    *
  49.    */
  50.   static void updateByPk(Ndb * theNdbObject,
  51.  const NDBT_DataSet *,
  52.  bool rollback = false);
  54.   /**
  55.    * Delete 
  56.    */
  57.   static void deleteByPk(Ndb * theNdbObject,
  58.  const NDBT_DataSet *,
  59.  bool rollback = false);
  60. };
  62. class NDBT_DataSetAsyncTransaction {
  63. public:
  64.   enum OperationType {
  65.     OT_Insert,
  66.     OT_ReadByPk,
  67.     OT_UpdateByPk,
  68.     OT_DeleteByPk
  69.   };
  71.   /**
  72.    * A callback for the NDBT_DataSetAsyncTransaction 
  73.    * interface.
  74.    *
  75.    * The callback method returns:
  76.    * - the operation performed
  77.    * - the data set
  78.    * - if the transaction was commited or aborted
  79.    */
  80.   typedef (* NDBT_DataSetAsyncTransactionCallback)(OperationType,
  81.    const NDBT_DataSet *,
  82.    bool commit,
  83.    void * anyObject);
  84.   /**
  85.    * Store the data into ndb
  86.    */
  87.   static void insert(Ndb * theNdbObject,
  88.      const NDBT_DataSet *,
  89.      bool rollback = false,
  90.      NDBT_DataSetAsyncTransactionCallback fun,
  91.      void * anyObject);
  92.   
  93.   /**
  94.    * Read data (using pk) from ndb
  95.    */
  96.   static void readByPk(Ndb * theNdbObject,
  97.        NDBT_DataSet *,
  98.        bool rollback = false,
  99.        NDBT_DataSetAsyncTransactionCallback fun,
  100.        void * anyObject);
  102.   
  103.   /**
  104.    * Update data using pk
  105.    *
  106.    */
  107.   static void updateByPk(Ndb * theNdbObject,
  108.  const NDBT_DataSet *,
  109.  bool rollback = false,
  110.  NDBT_DataSetAsyncTransactionCallback fun,
  111.  void * anyObject);
  114.   /**
  115.    * Delete 
  116.    */
  117.   static void deleteByPk(Ndb * theNdbObject,
  118.  const NDBT_DataSet *,
  119.  bool rollback = false,
  120.  NDBT_DataSetAsyncTransactionCallback fun,
  121.  void * anyObject);
  122.   
  123. };
  125. class NDBT_DataSetBulkOperation {
  126. public:
  127.   /**
  128.    * Store the data into ndb
  129.    */
  130.   static void insert(Ndb * theNdbObject,
  131.      const NDBT_DataSet *,
  132.      int parallellTransactions = 1,
  133.      int operationsPerTransaction = 10);
  134.   
  135.   /**
  136.    * Read data (using pk) from ndb
  137.    */
  138.   static void readByPk(Ndb * theNdbObject,
  139.        NDBT_DataSet *,
  140.        int parallellTransactions = 1,
  141.        int operationsPerTransaction = 10);
  142.   
  143.   /**
  144.    * Update data using pk
  145.    *
  146.    */
  147.   static void updateByPk(Ndb * theNdbObject,
  148.  const NDBT_DataSet *,
  149.  int parallellTransactions = 1,
  150.  int operationsPerTransaction = 10);
  152.   /**
  153.    * Delete 
  154.    */
  155.   static void deleteByPk(Ndb * theNdbObject,
  156.  const NDBT_DataSet *,
  157.  int parallellTransactions = 1,
  158.  int operationsPerTransaction = 10);
  159. };
  162. #endif