存储过程中的mysql动态查询

Posted 2023-02-24

【中文标题】存储过程中的mysql动态查询

【英文标题】：mysql dynamic query in stored procedure

【发布时间】：2014-06-04 10:06:09

【问题描述】：

我正在存储过程中创建一个动态查询。我的存储过程如下：

CREATE PROCEDURE `test1`(IN tab_name VARCHAR(40),IN w_team VARCHAR(40))
BEGIN
SET @t1 =CONCAT("SELECT * FROM ",tab_name," where team=",w_team);
 PREPARE stmt3 FROM @t1;
 EXECUTE stmt3;
 DEALLOCATE PREPARE stmt3;
END

当我尝试通过以下调用运行它时：

call test1 ('Test','SPA');

我收到以下错误消息：

错误代码：1054。“where 子句”中的未知列“SPA”

我在没有 where 条件的情况下进行了测试，它工作正常，但是在 where 条件下它不起作用，我尝试使用带有变量名的 @，但它仍然不起作用。

感谢您的帮助。

【参考方案1】：

错误代码：1054。“where 子句”中的未知列“SPA”

当您没有将输入字符串括在引号中时，会发生这种情况，并且 SQL 引擎会尝试将其识别为正在查询的表中的列。但它失败了，因为它找不到它。

但是当它找到这样的列时会发生什么？ 当它在列值上找到一些匹配项时，它会获取结果。 显然，这不是人们所期望的。

如何克服这个问题？使用带有动态输入值的预处理语句。

您也可以在存储过程中使用像? 这样的占位符来处理动态输入值，以便与Prepared Statements 一起使用。当分配给 SQL 表达式或在 SQL 表达式中进行比较时，引擎将处理转义字符和其他字符串值。

您只需根据需要将过程输入重新分配给一个或多个会话变量。

程序示例：

CREATE PROCEDURE `test1`( IN tab_name VARCHAR(40), IN w_team VARCHAR(40) )
BEGIN
  SET @t1 = CONCAT( 'SELECT * FROM ', tab_name, ' where team = ?' ); -- <-- placeholder
  SET @w_team := w_team;

  PREPARE stmt3 FROM @t1;
  EXECUTE stmt3 USING @w_team; -- <-- input for placeholder
  DEALLOCATE PREPARE stmt3;
END;

【参考方案2】：

您错过了在WHERE 子句中包含参数w_team。

试试这样：

SET @t1 =CONCAT("SELECT * FROM ",tab_name," where team='",w_team,"'");

解释：

您的代码中的查询类似于：

SELECT * FROM Test where team=SPA

它将尝试查找不可用的列SPA，因此会出现错误。

我们将其更改为：

SELECT * FROM Test where team='SPA'

【讨论】：

SET @t1 =CONCAT("SELECT col1 into '@'var1 FROM ",tab_name," where team='",w_team,"'"); var1 总是为空，这是为什么呢？

@Shann：你想做什么？

我正在尝试将 col1 存储到 var1 中，我将 @ 放在 '' 中，因为我在堆栈上有错误。

尝试删除@周围的单引号。

我试过了，但我得到了空值，因为堆栈错误我添加了单引号。

【参考方案3】：

试试这个..

CREATE PROCEDURE `test1`(IN tab_name VARCHAR(40),IN w_team VARCHAR(40))
BEGIN
SET @t1 =CONCAT("SELECT * FROM ",tab_name," where team='",w_team,"'");
 PREPARE stmt3 FROM @t1;
 EXECUTE stmt3;
 DEALLOCATE PREPARE stmt3;
END

w_team 变量周围缺少引号。

您应该打印动态构建的语句，这样您就可以复制打印的语句并尝试这样您就可以轻松找到此类问题。

select @t1 将打印动态构建的语句..

【参考方案4】：

您可以使用 CONCAT() mysql 函数添加动态字段和条件。我检查了它工作正常。

 DELIMITER $$
 /*define procedure name*/
 CREATE PROCEDURE getSearchData()
 BEGIN
 
 DECLARE conditions varchar(1000);
 DECLARE selectField varchar(1000);
 DECLARE SQL_QUERY  varchar(1000);   

 /*define  default select and condition*/
 SET @selectField = 'status,id';
 set @conditions = ' where return_flight=0'; 

 SET @SQL_QUERY = CONCAT('SELECT ',@selectField, ' FROM flights ',@conditions);   
/* you can add more select fields and conditions according to your requirement */ 

PREPARE stmt1 FROM @SQL_QUERY ;
EXECUTE stmt1;
DEALLOCATE PREPARE stmt1;
END$$
DELIMITER ;