bitsCN.com
 
MYSQL存储过程中表名使用变量
 
# 该存储过程定义了几个传入参数，前缀都是para_
 
# 该存储过程的此部分功能是，查询根据传入参数动态生成的tbl_name表名的表中
 
SET tbl_name = CONCAT("result_", para_user);SET @STMT := CONCAT("SELECT COUNT(*) INTO @num_count FROM ", tbl_name ," WHERE rng = '", para_rng ,"' AND north_latitude = ", para_north ," AND bck_datetime = '", para_datetime ,"' AND east_longitude = ", para_east, ";"); PREPARE STMT FROM @STMT; EXECUTE STMT;
 
注：目前 存储过程 支持动态SQL，函数不支持。bitsCN.com
 
本条技术文章来源于互联网，如果无意侵犯您的权益请点击此处反馈版权投诉
 
本文系统来源：php中文网

                       Kettle使用_9 存储过程与设置变量
 
需求: 通过传递给kettle位置参数的方式执行存储过程。其中存储过程的需求是往tb_user（字段user_id, name）里插入一条记录(覆盖式，即有则删除；参数是用户id和用户名)。
 
解决方法：结合设置变量(设置参数名)和DB存储过程（指定数据库连接和参数）组件解决。
 
Step1:新建一个转换。
 
Step2: 拖动一个表输入或者自定义常量组件到转换里，该组件位于转换的输入分类下。
 
 
 
Step3: 配置表输入组件，自定义常量较为简单，这里用的是表输入。其中SQL编辑器区域可以写从某个表读取参数值，这里写的固定值。即user_id=3000,name=300$。
 
 
 
Step4:拖个设置变量组件，并将表输入通过SHIFT连接。
 
 
Step5:配置设置变量。
 
 
 
Step6：在数据库里编写存储过程（这里以Mysql为例）
 
DROP PROCEDURE IF EXISTS kettlexp.sp_adduser_v2;
CREATE PROCEDURE kettlexp.`sp_adduser_v2`( IN userid int,v_name varchar(100))
BEGIN
  DELETE FROM tb_user WHERE id = userid AND name = v_name;
  INSERT INTO tb_user(id,name) VALUES(userid,v_name);
  commit;
END;
 
 
Step7：拖并配置DB存储过程组件。
 
 
Step8：SHIFT连接组件设置变量、DB存储过程。
 
Step9：点击运行该转换
 
 
 
Step10：数据库查看结果
 
 
 
完整流程示意：
 
 

 
MySQL数据库中的变量分为MySQL系统变量和MySQL用户变量。 一、MySQL用户变量：基于会话变量实现的, 可以暂存, 并传递给同一连接里的下一条sql使用的变量.当客户端连接退出时,变量会被释放。 1、用户变量定义： 用户变量：以@开始，形式为@变量名 注 ：用户变
 
MySQL数据库中的变量分为MySQL系统变量和MySQL用户变量。
 
一、MySQL用户变量：基于会话变量实现的, 可以暂存值, 并传递给同一连接里的下一条sql使用的变量.当客户端连接退出时,变量会被释放。
 
1、用户变量定义：
 
用户变量：以"@"开始，形式为"@变量名"
 
注：用户变量跟mysql客户端是绑定的，设置的变量，只对当前用户使用的客户端生效。也叫回话变量。
 
2、赋值：(可以使用set或select)
 
set @test=1;
 
或者
 
select @test，@tt:=2;
 
查看变量的值：
 
select @tt;
 
注：如果使用没有初始化的变量，其值是NULL。
 
使用set赋值时，使用的是“=”，使用select赋值时使用的是“:="。
 
二、系统变量：
 
MySQL可以访问许多系统变量。当服务器运行时许多变量可以动态更改。这样通常允许你修改服务器操作而不需要停止并重启服务器。当服务器启动时，它将所有全局变量初始化为默认值。这些默认值可以在选项文件中或在命令行中指定的选项进行更改。服务器启动后，通过连接服务器并执行SET GLOBAL var_name语句，可以动态更改这些全局变量。要想更改全局变量，必须具有SUPER权限。
 
1、变量使用：
 
可以通过@@或global来操作系统变量，如下：
 
mysql> SET GLOBAL sort_buffer_size=value;
 
mysql> SET @@global.sort_buffer_size=value;
 
三、局部变量：
 
作用范围在begin到end语句块之间。在该语句块里设置的变量成为局部变量。
 
1、定义：
 
declare语句专门用于定义局部变量。
 
begin
 
declare test int;
 
2、赋值：
 
set语句进行赋值
 
set i=500;
 
本条技术文章来源于互联网，如果无意侵犯您的权益请点击此处反馈版权投诉
 
本文系统来源：php中文网

 
下面给出一个具体例子：
 
在model数据库中创建如下表：
 
DROP TABLE IF EXISTS `model`.`model_director`;
 
CREATE TABLE `model`.`model_director` (
 
`model_id` int(11) NOT NULL,
 
`director_id` int(11) NOT NULL,
 
PRIMARY KEY (`model_id`,`director_id`),
 
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=FIXED;
 
创建存储过程：
 
DELIMITER $$
 
DROP PROCEDURE IF EXISTS `testINVarchar` $$
 
CREATE PROCEDURE `testINVarchar`(IN inTableName VARCHAR(128),OUT inNUM INT)
 
BEGIN
 
SET @tmpNUM = 0;
 
SET @SQLStr=CONCAT('SELECT COUNT(*) INTO
 
@tmpNUM FROM ',inTableName );
 
PREPARE stmt from @SQLStr;
 
EXECUTE stmt;
 
SET inNUM =
 
@tmpNUM;
 
END $$
 
DELIMITER ;
 
不能直接将数据INTO到OUT变量中，还有另一个要注意的问题是，这里不能使用DECLARE声名的局部变量，因为使用CONCAT的时候会将其变成字符串！所以一定要使用SET来声名变量。
 
--错误做法1(OUT变量直接在SQL语句中使用)
 
DELIMITER $$
 
DROP PROCEDURE IF EXISTS `testINVarchar` $$
 
CREATE PROCEDURE `testINVarchar`(IN inTableName VARCHAR(128),OUT inNUM INT)
 
BEGIN
 
SET @SQLStr=CONCAT('SELECT COUNT(*) INTO ',
 
inNUM ,' FROM ',inTableName );
 
PREPARE stmt from @SQLStr;
 
EXECUTE stmt;
 
END $$
 
DELIMITER ;
 
--错误做法2(使用DECLARE声名变量是不可以在CONCAT中使用！)
 
DELIMITER $$
 
DROP PROCEDURE IF EXISTS `testINVarchar` $$
 
CREATE PROCEDURE `testINVarchar`(IN inTableName VARCHAR(128),OUT inNUM INT)
 
BEGIN
 
DECLARE tmpNUM = 0;
 
SET @SQLStr=CONCAT('SELECT COUNT(*) INTO
 
tmpNUM FROM ',inTableName );
 
PREPARE stmt from @SQLStr;
 
EXECUTE stmt;
 
SET inNUM = tmpNUM;
 
END $$
 
DELIMITER ;