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

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

MySQL数据库

开发平台：

Visual C++

ScanFilter.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 SCAN_FILTER_HPP
  18. #define SCAN_FILTER_HPP
  20. class ScanFilter {
  21. public:
  22. #if 0
  23.   /**
  24.    * Create a scan filter for table tab
  25.    * colNo - column to filter on
  26.    * val - val to use when selecting valu to filter on
  27.    *
  28.    */
  29.   ScanFilter(const NDBT_Table& tab, 
  30.      int colNo,
  31.      int val);
  32. #endif
  33.   ScanFilter(int records = 1000){};
  34.   virtual int filterOp(NdbOperation*) = 0;
  35.   virtual int verifyRecord(NDBT_ResultRow&) = 0;
  36. private:
  38.   //  const NDBT_Table& tab;
  39. };
  41. class LessThanFilter : public ScanFilter {
  42. public:
  43.   LessThanFilter(int records){ compare_value = records / 100; };
  44. private:
  45.   Uint32 compare_value;
  46.   int filterOp(NdbOperation* pOp);
  47.   int verifyRecord(NDBT_ResultRow&);
  48. };
  50. class EqualFilter : public ScanFilter {
  51.   static const Uint32 compare_value = 100;
  52.   int filterOp(NdbOperation* pOp);
  53.   int verifyRecord(NDBT_ResultRow&);
  54. };
  56. class NoFilter : public ScanFilter {
  57.   int filterOp(NdbOperation* pOp);
  58.   int verifyRecord(NDBT_ResultRow&);
  59. };
  62. int LessThanFilter::filterOp(NdbOperation* pOp){
  63.   
  64.   if (pOp->load_const_u32(1, compare_value) != 0)
  65.     return NDBT_FAILED;
  67.   if (pOp->read_attr("KOL2", 2) != 0)
  68.     return NDBT_FAILED;
  70.   if (pOp->branch_lt(1, 2, 0) != 0)
  71.     return NDBT_FAILED;
  73.   if (pOp->interpret_exit_nok() != 0)
  74.     return NDBT_FAILED;
  75.   
  76.   if (pOp->def_label(0) != 0)
  77.     return NDBT_FAILED;
  79.   if (pOp->interpret_exit_ok() != 0)
  80.     return NDBT_FAILED;
  82.   return NDBT_OK;
  83. }
  85. int LessThanFilter::verifyRecord(NDBT_ResultRow& row){
  86.   NdbRecAttr* rec = row.attributeStore(1);
  87.   if (rec->u_32_value() < compare_value)
  88.     return NDBT_OK;
  89.   return NDBT_FAILED;
  90. }
  92. int EqualFilter::filterOp(NdbOperation* pOp){
  93.   
  94.   if (pOp->load_const_u32(1, compare_value) != 0)
  95.     return NDBT_FAILED;
  97.   if (pOp->read_attr("KOL2", 2) != 0)
  98.     return NDBT_FAILED;
  100.   if (pOp->branch_eq(1, 2, 0) != 0)
  101.     return NDBT_FAILED;
  103.   if (pOp->interpret_exit_nok() != 0)
  104.     return NDBT_FAILED;
  105.   
  106.   if (pOp->def_label(0) != 0)
  107.     return NDBT_FAILED;
  109.   if (pOp->interpret_exit_ok() != 0)
  110.     return NDBT_FAILED;
  112.   return NDBT_OK;
  113. }
  115. int EqualFilter::verifyRecord(NDBT_ResultRow& row){
  116.   NdbRecAttr* rec = row.attributeStore(1);
  117.   if (rec->u_32_value() == compare_value)
  118.     return NDBT_OK;
  119.   return NDBT_FAILED;
  120. }
  122. int NoFilter::filterOp(NdbOperation* pOp){
  123.   return NDBT_OK;
  124. }
  126. int NoFilter::verifyRecord(NDBT_ResultRow& row){
  127.   // Check if this record should be in the result set or not
  128.   return NDBT_OK;
  129. }
  131. #endif