快捷導(dǎo)航

MySQL存儲過程使用實例詳解

更新時間：2013年11月08日 10:58:27 作者：

本文介紹關(guān)于在MySQL存儲過程游標(biāo)使用實例，包括簡單游標(biāo)使用與游標(biāo)循環(huán)跳出等方法

例1、一個簡單存儲過程游標(biāo)實例

DELIMITER $$
DROP PROCEDURE IF EXISTS getUserInfo $$
CREATE PROCEDURE getUserInfo(in date_day datetime)
--
-- 實例
-- 存儲過程名為：getUserInfo
-- 參數(shù)為：date_day日期格式:2008-03-08
--
    BEGIN
declare _userName varchar(12); -- 用戶名
declare _chinese int ; -- 語文
declare _math int ;    -- 數(shù)學(xué)
declare done int;
-- 定義游標(biāo)
DECLARE rs_cursor CURSOR FOR SELECT username,chinese,math from userInfo where datediff(createDate, date_day)=0;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done=1;
-- 獲取昨天的日期
if date_day is null then
   set date_day = date_add(now(),interval -1 day);
end if;
open rs_cursor;
cursor_loop:loop
   FETCH rs_cursor into _userName, _chinese, _math; -- 取數(shù)據(jù)

   if done=1 then
    leave cursor_loop;
   end if;
   -- 更新表
   update infoSum set total=_chinese+_math where UserName=_userName;
end loop cursor_loop;
close rs_cursor;

END$$
DELIMITER ;

例2、存儲過程游標(biāo)循環(huán)跳出現(xiàn)
在MySQL的存儲過程中,游標(biāo)操作時,需要執(zhí)行一個conitnue的操作.眾所周知,MySQL中的游標(biāo)循環(huán)操作常用的有三種,LOOP,REPEAT,WHILE.三種循環(huán),方式大同小異.以前從沒用過,所以記下來,方便以后查閱.
1.REPEAT

復(fù)制代碼代碼如下:

REPEAT
    Statements;
  UNTIL expression
END REPEAT
demo
DECLARE num INT;
DECLARE my_string  VARCHAR(255);
REPEAT
SET  my_string =CONCAT(my_string,num,',');
SET  num = num +1;
  UNTIL num <5
END REPEAT; 

2.WHILE

復(fù)制代碼代碼如下:

WHILE expression DO
    Statements;
END WHILE
demo
DECLARE num INT;
DECLARE my_string  VARCHAR(255);
SET num =1;
SET str ='';
  WHILE num  < span>10DO
SET  my_string =CONCAT(my_string,num,',');
SET  num = num +1;
END WHILE; 
3.LOOP(這里面有非常重要的ITERATE,LEAVE)
 代碼如下 復(fù)制代碼 
DECLARE num  INT;
DECLARE str  VARCHAR(255);
SET num =1;
SET my_string ='';
  loop_label:  LOOP
IF  num <10THEN
      LEAVE  loop_label;
ENDIF;
SET  num = num +1;
IF(num mod3)THEN
      ITERATE  loop_label;
ELSE
SET  my_string =CONCAT(my_string,num,',');
ENDIF;
END LOOP;
 

PS:可以這樣理解ITERATE就是我們程序中常用的contiune,而ITERATE就是break.當(dāng)然在MySQL存儲過程,需要循環(huán)結(jié)構(gòu)有個名稱,其他都是一樣的.
例3,mysql 存儲過程中使用多游標(biāo)

先創(chuàng)建一張表，插入一些測試數(shù)據(jù)：

復(fù)制代碼代碼如下:

DROP TABLE IF EXISTS netingcn_proc_test;
CREATE TABLE `netingcn_proc_test` (
  `id` INTEGER(11) NOT NULL AUTO_INCREMENT,
  `name` VARCHAR(20),
  `password` VARCHAR(20),
  PRIMARY KEY (`id`)
)ENGINE=InnoDB;
insert into netingcn_proc_test(name, password) values
('procedure1', 'pass1'),
('procedure2', 'pass2'),
('procedure3', 'pass3'),
('procedure4', 'pass4');下面就是一個簡單存儲過程的例子：
drop procedure IF EXISTS test_proc;
delimiter //
create procedure test_proc()
begin
 -- 聲明一個標(biāo)志done， 用來判斷游標(biāo)是否遍歷完成
 DECLARE done INT DEFAULT 0;
 -- 聲明一個變量，用來存放從游標(biāo)中提取的數(shù)據(jù)
 -- 特別注意這里的名字不能與由游標(biāo)中使用的列明相同，否則得到的數(shù)據(jù)都是NULL
 DECLARE tname varchar(50) DEFAULT NULL;
 DECLARE tpass varchar(50) DEFAULT NULL;
 -- 聲明游標(biāo)對應(yīng)的 SQL 語句
 DECLARE cur CURSOR FOR
  select name, password from netingcn_proc_test;
 -- 在游標(biāo)循環(huán)到最后會將 done 設(shè)置為 1
 DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
 -- 執(zhí)行查詢
 open cur;
 -- 遍歷游標(biāo)每一行
 REPEAT
  -- 把一行的信息存放在對應(yīng)的變量中
  FETCH cur INTO tname, tpass;
  if not done then
   -- 這里就可以使用 tname， tpass 對應(yīng)的信息了
   select tname, tpass;
  end if;
  UNTIL done END REPEAT;
 CLOSE cur;
end
//
delimiter ;
-- 執(zhí)行存儲過程
call test_proc();
 

需要注意的是變量的聲明、游標(biāo)的聲明和HANDLER聲明的順序不能搞錯，必須是先聲明變量，再申明游標(biāo)，最后聲明HANDLER。上述存儲過程的例子中只使用了一個游標(biāo)，那么如果要使用兩個或者更多游標(biāo)怎么辦，其實很簡單，可以這么說，一個怎么用兩個就是怎么用的。例子如下：

復(fù)制代碼代碼如下:

drop procedure IF EXISTS test_proc_1;
delimiter //
create procedure test_proc_1()
begin
 DECLARE done INT DEFAULT 0;
 DECLARE tid int(11) DEFAULT 0;
 DECLARE tname varchar(50) DEFAULT NULL;
 DECLARE tpass varchar(50) DEFAULT NULL;
 DECLARE cur_1 CURSOR FOR
  select name, password from netingcn_proc_test;
 DECLARE cur_2 CURSOR FOR
  select id, name from netingcn_proc_test;
 DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
 open cur_1;
 REPEAT
  FETCH cur_1 INTO tname, tpass;
  if not done then
   select tname, tpass;
  end if;
  UNTIL done END REPEAT;
 CLOSE cur_1;
 -- 注意這里，一定要重置done的值為 0
 set done = 0;
 open cur_2;
 REPEAT
  FETCH cur_2 INTO tid, tname;
  if not done then
   select tid, tname;
  end if;
  UNTIL done END REPEAT;
 CLOSE cur_2;
end
//
delimiter ;
call test_proc_1();
 

上述代碼和第一個例子中基本一樣，就是多了一個游標(biāo)聲明和遍歷游標(biāo)。這里需要注意的是，在遍歷第二個游標(biāo)前使用了set done = 0，因為當(dāng)?shù)谝粋€游標(biāo)遍歷玩后其值被handler設(shè)置為1了，如果不用set把它設(shè)置為 0 ，那么第二個游標(biāo)就不會遍歷了。當(dāng)然好習(xí)慣是在每個打開游標(biāo)的操作前都用該語句，確保游標(biāo)能真正遍歷。當(dāng)然還可以使用begin語句塊嵌套的方式來處理多個游標(biāo),例如：

復(fù)制代碼代碼如下:

drop procedure IF EXISTS test_proc_2;
delimiter //
create procedure test_proc_2()
begin
 DECLARE done INT DEFAULT 0;
 DECLARE tname varchar(50) DEFAULT NULL;
 DECLARE tpass varchar(50) DEFAULT NULL;
 DECLARE cur_1 CURSOR FOR
  select name, password from netingcn_proc_test;
 DECLARE cur_2 CURSOR FOR
  select id, name from netingcn_proc_test;
 DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
 open cur_1;
 REPEAT
  FETCH cur_1 INTO tname, tpass;
  if not done then
   select tname, tpass;
  end if;
  UNTIL done END REPEAT;
 CLOSE cur_1;
 begin
  DECLARE done INT DEFAULT 0;
  DECLARE tid int(11) DEFAULT 0;
  DECLARE tname varchar(50) DEFAULT NULL;
  DECLARE cur_2 CURSOR FOR
   select id, name from netingcn_proc_test;
  DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
  open cur_2;
  REPEAT
   FETCH cur_2 INTO tid, tname;
   if not done then
    select tid, tname;
   end if;
   UNTIL done END REPEAT;
  CLOSE cur_2;
 end;
end
//
delimiter ;
call test_proc_2();