记录mysql 存储过程中通过使用PREPARE、EXECUTE 预处理语句实现执行动态SQL语句

背景:一个定时执行的存储过程中需要用到分表的数据,需要根据当前执行时间确定要查询哪个表的数据。

 

预处理语句语法如下:

# 
第一种使用方式: 使用USING 传入参数

PREPARE stmt_name FROM preparable_stmt

EXECUTE stmt_name

 [USING @var_name [, @var_name] ...] 


{DEALLOCATE | DROP} PREPARE stmt_name

# 第二种使用方式: 

PREPARE ... FROM可以直接接用户变量:
SET @select_test = CONCAT('SELECT * FROM ', @table_name);
PREPARE pr2 FROM @select_test;

 

 

我的实现方式是使用第二种方式 提前拼接好SQL语句 作为一个用户变量。 

第一步 : 构造拼接你要执行的SQL语句 为preparable_stmt 部分:

SET @TargetTableName = CONCAT('xxxxxxx',DATE_FORMAT(NOW(),'%Y')); -- yourtablename_2022 你的分表格式,前缀加日期。。
SET @c_ExecSql = CONCAT(' SELECT AVG(AvgDust) INTO @c_AvgDust FROM  ', @TargetTableName);
SET @c_ExecSqlFinally = CONCAT(@c_ExecSql,' WHERE id = @id AND StartTime >=@StartTime AND EndTime <= @EndTime '); # 最终要执行的SQL语句

# 说明: 最终要执行的语句要看你自己的业务了 我这里只是计算一个均值, 直接使用了 CONCAT函数 把语句依次拼接完整。


 

第二步

PREPARE pr1 FROM @c_ExecSqlFinally;

 

第三步

EXECUTE  pr1; # 最终执行语句
DEALLOCATE PREPARE pr1 ; # 释放资源

 

 

注意:  使用预处理语句时  要使用的是  【用户变量】(使用SET @xxx = xxxx 方式声明 )  不同于局部变量 (DECLARE 定义的变量)。

上一篇:Hive-3.1.2安装部署


下一篇:使用Sqoop job工具同步数据