Code_query_join.hpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:4k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2003 MySQL AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. #ifndef ODBC_CODEGEN_Code_query_join_hpp
  14. #define ODBC_CODEGEN_Code_query_join_hpp
  15. #include <common/common.hpp>
  16. #include "Code_query.hpp"
  17. #include "Code_table_list.hpp"
  18. #include "Code_pred.hpp"
  19. /**
  20.  * @class Plan_query_join
  21.  * @brief Filter node in PlanTree
  22.  */
  23. class Plan_query_join : public Plan_query {
  24. public:
  25.     Plan_query_join(Plan_root* root);
  26.     virtual ~Plan_query_join();
  27.     Plan_base* analyze(Ctx& ctx, Ctl& ctl);
  28.     Exec_base* codegen(Ctx& ctx, Ctl& ctl);
  29.     void print(Ctx& ctx);
  30.     // children
  31.     void setInner(Plan_query* query);
  32.     void setOuter(Plan_query* query);
  33. protected:
  34.     Plan_query* m_inner;
  35.     Plan_query* m_outer;
  36. };
  37. inline
  38. Plan_query_join::Plan_query_join(Plan_root* root) :
  39.     Plan_query(root),
  40.     m_inner(0),
  41.     m_outer(0)
  42. {
  43. }
  44. // children
  45. inline void
  46. Plan_query_join::setInner(Plan_query* query)
  47. {
  48.     ctx_assert(query != 0);
  49.     m_inner = query;
  50. }
  51. inline void
  52. Plan_query_join::setOuter(Plan_query* query)
  53. {
  54.     ctx_assert(query != 0);
  55.     m_outer = query;
  56. }
  57. /**
  58.  * @class Exec_query_join
  59.  * @brief Filter node in ExecTree
  60.  */
  61. class Exec_query_join : public Exec_query {
  62. public:
  63.     class Code : public Exec_query::Code {
  64.     public:
  65. Code(const SqlSpecs& sqlSpecs);
  66. virtual ~Code();
  67.     protected:
  68. friend class Exec_query_join;
  69. SqlSpecs m_sqlSpecs;
  70.     };
  71.     class Data : public Exec_query::Data {
  72.     public:
  73. Data(Exec_query_join* node, const SqlRow& sqlRow);
  74. virtual ~Data();
  75.     protected:
  76. friend class Exec_query_join;
  77. SqlRow m_sqlRow;
  78.     };
  79.     Exec_query_join(Exec_root* root);
  80.     virtual ~Exec_query_join();
  81.     void alloc(Ctx& ctx, Ctl& ctl);
  82.     void execImpl(Ctx& ctx, Ctl& ctl);
  83.     bool fetchImpl(Ctx& ctx, Ctl& ctl);
  84.     void close(Ctx& ctx);
  85.     void print(Ctx& ctx);
  86.     // children
  87.     const Code& getCode() const;
  88.     Data& getData() const;
  89.     void setInner(Exec_query* query);
  90.     void setOuter(Exec_query* query);
  91. protected:
  92.     Exec_query* m_inner;
  93.     Exec_query* m_outer;
  94. };
  95. inline
  96. Exec_query_join::Code::Code(const SqlSpecs& sqlSpecs) :
  97.     Exec_query::Code(m_sqlSpecs),
  98.     m_sqlSpecs(sqlSpecs)
  99. {
  100. }
  101. inline
  102. Exec_query_join::Data::Data(Exec_query_join* node, const SqlRow& sqlRow) :
  103.     Exec_query::Data(node, m_sqlRow),
  104.     m_sqlRow(sqlRow)
  105. {
  106. }
  107. inline
  108. Exec_query_join::Exec_query_join(Exec_root* root) :
  109.     Exec_query(root),
  110.     m_inner(0),
  111.     m_outer(0)
  112. {
  113. }
  114. // children
  115. inline const Exec_query_join::Code&
  116. Exec_query_join::getCode() const
  117. {
  118.     const Code* code = static_cast<const Code*>(m_code);
  119.     return *code;
  120. }
  121. inline Exec_query_join::Data&
  122. Exec_query_join::getData() const
  123. {
  124.     Data* data = static_cast<Data*>(m_data);
  125.     return *data;
  126. }
  127. inline void
  128. Exec_query_join::setInner(Exec_query* query)
  129. {
  130.     ctx_assert(query != 0);
  131.     m_inner = query;
  132. }
  133. inline void
  134. Exec_query_join::setOuter(Exec_query* query)
  135. {
  136.     ctx_assert(query != 0);
  137.     m_outer = query;
  138. }
  139. #endif