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

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

MySQL数据库

开发平台：

Visual C++

Code_expr_conv.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 */
  17. #include "Code_expr.hpp"
  18. #include "Code_expr_conv.hpp"
  19. #include "Code_root.hpp"
  21. // Plan_expr_conv
  23. Plan_expr_conv::~Plan_expr_conv()
  24. {
  25. }
  27. Plan_base*
  28. Plan_expr_conv::analyze(Ctx& ctx, Ctl& ctl)
  29. {
  30.     m_exec = 0;
  31.     const SqlType& t1 = sqlType();
  32.     ctx_assert(m_expr != 0);
  33.     m_expr->analyze(ctx, ctl);
  34.     if (! ctx.ok())
  35. return 0;
  36.     const SqlType& t2 = m_expr->sqlType();
  37.     if (t2.type() == SqlType::Unbound) {
  38. return m_expr;
  39.     }
  40.     if (t1.equal(t2)) {
  41. return m_expr;
  42.     }
  43.     // XXX move to runtime or make table-driven
  44.     bool ok = false;
  45.     if (t2.type() == SqlType::Null) {
  46. ok = true;
  47.     } else if (t1.type() == SqlType::Char) {
  48. if (t2.type() == SqlType::Char) {
  49.     ok = true;
  50. } else if (t2.type() == SqlType::Varchar) {
  51.     ok = true;
  52. } else if (t2.type() == SqlType::Binary) {
  53.     ok = true;
  54. } else if (t2.type() == SqlType::Varbinary) {
  55.     ok = true;
  56. }
  57.     } else if (t1.type() == SqlType::Varchar) {
  58. if (t2.type() == SqlType::Char) {
  59.     ok = true;
  60. } else if (t2.type() == SqlType::Varchar) {
  61.     ok = true;
  62. } else if (t2.type() == SqlType::Binary) {
  63.     ok = true;
  64. } else if (t2.type() == SqlType::Varbinary) {
  65.     ok = true;
  66. }
  67.     } else if (t1.type() == SqlType::Binary) {
  68. if (t2.type() == SqlType::Char) {
  69.     ok = true;
  70. } else if (t2.type() == SqlType::Varchar) {
  71.     ok = true;
  72. } else if (t2.type() == SqlType::Binary) {
  73.     ok = true;
  74. } else if (t2.type() == SqlType::Varbinary) {
  75.     ok = true;
  76. }
  77.     } else if (t1.type() == SqlType::Varbinary) {
  78. if (t2.type() == SqlType::Char) {
  79.     ok = true;
  80. } else if (t2.type() == SqlType::Varchar) {
  81.     ok = true;
  82. } else if (t2.type() == SqlType::Binary) {
  83.     ok = true;
  84. } else if (t2.type() == SqlType::Varbinary) {
  85.     ok = true;
  86. }
  87.     } else if (t1.type() == SqlType::Smallint) {
  88. if (t2.type() == SqlType::Smallint) {
  89.     ok = true;
  90. } else if (t2.type() == SqlType::Integer) {
  91.     ok = true;
  92. } else if (t2.type() == SqlType::Bigint) {
  93.     ok = true;
  94. } else if (t2.type() == SqlType::Real) {
  95.     ok = true;
  96. } else if (t2.type() == SqlType::Double) {
  97.     ok = true;
  98. }
  99.     } else if (t1.type() == SqlType::Integer) {
  100. if (t2.type() == SqlType::Smallint) {
  101.     ok = true;
  102. } else if (t2.type() == SqlType::Integer) {
  103.     ok = true;
  104. } else if (t2.type() == SqlType::Bigint) {
  105.     ok = true;
  106. } else if (t2.type() == SqlType::Real) {
  107.     ok = true;
  108. } else if (t2.type() == SqlType::Double) {
  109.     ok = true;
  110. }
  111.     } else if (t1.type() == SqlType::Bigint) {
  112. if (t2.type() == SqlType::Smallint) {
  113.     ok = true;
  114. } else if (t2.type() == SqlType::Integer) {
  115.     ok = true;
  116. } else if (t2.type() == SqlType::Bigint) {
  117.     ok = true;
  118. } else if (t2.type() == SqlType::Real) {
  119.     ok = true;
  120. } else if (t2.type() == SqlType::Double) {
  121.     ok = true;
  122. }
  123.     } else if (t1.type() == SqlType::Real) {
  124. if (t2.type() == SqlType::Smallint) {
  125.     ok = true;
  126. } else if (t2.type() == SqlType::Integer) {
  127.     ok = true;
  128. } else if (t2.type() == SqlType::Bigint) {
  129.     ok = true;
  130. } else if (t2.type() == SqlType::Real) {
  131.     ok = true;
  132. } else if (t2.type() == SqlType::Double) {
  133.     ok = true;
  134. }
  135.     } else if (t1.type() == SqlType::Double) {
  136. if (t2.type() == SqlType::Smallint) {
  137.     ok = true;
  138. } else if (t2.type() == SqlType::Integer) {
  139.     ok = true;
  140. } else if (t2.type() == SqlType::Bigint) {
  141.     ok = true;
  142. } else if (t2.type() == SqlType::Real) {
  143.     ok = true;
  144. } else if (t2.type() == SqlType::Double) {
  145.     ok = true;
  146. }
  147.     } else if (t1.type() == SqlType::Datetime) {
  148. if (t2.type() == SqlType::Datetime) {
  149.     ok = true;
  150. }
  151.     }
  152.     if (! ok) {
  153. char b1[40], b2[40];
  154. t1.print(b1, sizeof(b1));
  155. t2.print(b2, sizeof(b2));
  156. ctx.pushStatus(Error::Gen, "cannot convert %s to %s", b2, b1);
  157. return 0;
  158.     }
  159.     // depend on same tables
  160.     const TableSet& ts = m_expr->tableSet();
  161.     m_tableSet.insert(ts.begin(), ts.end());
  162.     // set alias
  163.     m_alias = m_expr->getAlias();
  164.     return this;
  165. }
  167. Exec_base*
  168. Plan_expr_conv::codegen(Ctx& ctx, Ctl& ctl)
  169. {
  170.     if (m_exec != 0)
  171. return m_exec;
  172.     Exec_expr_conv* exec = new Exec_expr_conv(ctl.m_execRoot);
  173.     ctl.m_execRoot->saveNode(exec);
  174.     // create code for subexpression
  175.     ctx_assert(m_expr != 0);
  176.     Exec_expr* execExpr = static_cast<Exec_expr*>(m_expr->codegen(ctx, ctl));
  177.     if (! ctx.ok())
  178. return 0;
  179.     exec->setExpr(execExpr);
  180.     // create the code
  181.     SqlSpec sqlSpec(sqlType(), SqlSpec::Physical);
  182.     Exec_expr_conv::Code& code = *new Exec_expr_conv::Code(sqlSpec);
  183.     exec->setCode(code);
  184.     m_exec = exec;
  185.     return exec;
  186. }
  188. void
  189. Plan_expr_conv::print(Ctx& ctx)
  190. {
  191.     ctx.print(" [expr_conv ");
  192.     char buf[100];
  193.     m_sqlType.print(buf, sizeof(buf));
  194.     ctx.print("%s", buf);
  195.     Plan_base* a[] = { m_expr };
  196.     printList(ctx, a, 1);
  197.     ctx.print("]");
  198. }
  200. bool
  201. Plan_expr_conv::isEqual(const Plan_expr* expr) const
  202. {
  203.     ctx_assert(expr != 0);
  204.     if (expr->type() != Plan_expr::TypeConv)
  205. return false;
  206.     const Plan_expr_conv* expr2 = static_cast<const Plan_expr_conv*>(expr);
  207.     if (! m_sqlType.equal(expr2->m_sqlType))
  208. return false;
  209.     ctx_assert(m_expr != 0 && expr2->m_expr != 0);
  210.     if (! m_expr->isEqual(expr2->m_expr))
  211. return false;
  212.     return true;
  213. }
  215. bool
  216. Plan_expr_conv::isGroupBy(const Plan_expr_row* row) const
  217. {
  218.     if (isAnyEqual(row))
  219. return true;
  220.     ctx_assert(m_expr != 0);
  221.     if (m_expr->isGroupBy(row))
  222. return true;
  223.     return false;
  224. }
  226. // Code_expr_conv
  228. Exec_expr_conv::Code::~Code()
  229. {
  230. }
  232. Exec_expr_conv::Data::~Data()
  233. {
  234. }
  236. Exec_expr_conv::~Exec_expr_conv()
  237. {
  238. }
  240. void
  241. Exec_expr_conv::alloc(Ctx& ctx, Ctl& ctl)
  242. {
  243.     if (m_data != 0)
  244. return;
  245.     const Code& code = getCode();
  246.     // allocate subexpression
  247.     ctx_assert(m_expr != 0);
  248.     m_expr->alloc(ctx, ctl);
  249.     if (! ctx.ok())
  250. return;
  251.     SqlField sqlField(code.m_sqlSpec);
  252.     Data& data = *new Data(sqlField);
  253.     setData(data);
  254. }
  256. void
  257. Exec_expr_conv::close(Ctx& ctx)
  258. {
  259.     ctx_assert(m_expr != 0);
  260.     m_expr->close(ctx);
  261.     Data& data = getData();
  262.     data.m_groupField.clear();
  263. }
  265. void
  266. Exec_expr_conv::print(Ctx& ctx)
  267. {
  268.     const Code& code = getCode();
  269.     ctx.print(" [expr_conv");
  270.     Exec_base* a[] = { m_expr };
  271.     printList(ctx, a, sizeof(a)/sizeof(a[0]));
  272.     ctx.print("]");
  273. }