--存儲(chǔ)過程名和參數(shù)，參數(shù)中in表示傳入?yún)?shù)，out標(biāo)示傳出參數(shù)，inout表示傳入傳出參數(shù)

create procedure p_procedurecode(in sumdate varchar(10))

begin

declare v_sql varchar(500); --需要執(zhí)行的SQL語句

declare sym varchar(6);

declare var1 varchar(20);

declare var2 varchar(70);

declare var3 integer;

--定義游標(biāo)遍歷時(shí)，作為判斷是否遍歷完全部記錄的標(biāo)記

declare no_more_departments integer DEFAULT 0;

--定義游標(biāo)名字為C_RESULT

DECLARE C_RESULT CURSOR FOR

SELECT barcode,barname,barnum FROM tmp_table;

--聲明當(dāng)游標(biāo)遍歷完全部記錄后將標(biāo)志變量置成某個(gè)值

DECLARE CONTINUE HANDLER FOR NOT FOUND

SET no_more_departments=1;

set sym=substring(sumdate,1,6); --截取字符串，并將其賦值給一個(gè)遍歷

--連接字符串構(gòu)成完整SQL語句，動(dòng)態(tài)SQL執(zhí)行后的結(jié)果記錄集，在MySQL中無法獲取，因此需要轉(zhuǎn)變思路將其放置到一個(gè)臨時(shí)表中(注意代碼中的寫法)。一般寫法如下：

-- 'Create TEMPORARY Table 表名(Select的查詢語句);

set v_sql= concat('Create TEMPORARY Table tmp_table(select aa as aacode,bb as aaname,count(cc) as ccnum from h',sym,' where substring(dd,1,8)=''',sumdate,''' group by aa,bb)');

set @v_sql=v_sql; --注意很重要，將連成成的字符串賦值給一個(gè)變量(可以之前沒有定義，但要以@開頭)

prepare stmt from @v_sql; --預(yù)處理需要執(zhí)行的動(dòng)態(tài)SQL，其中stmt是一個(gè)變量

EXECUTE stmt; --執(zhí)行SQL語句

deallocate prepare stmt; --釋放掉預(yù)處理段

OPEN C_RESULT; --打開之前定義的游標(biāo)

REPEAT --循環(huán)語句的關(guān)鍵詞

FETCH C_RESULT INTO VAR1, VAR2, VAR3; --取出每條記錄并賦值給相關(guān)變量，注意順序

--執(zhí)行查詢語句，并將獲得的值付給一個(gè)變量 @oldaacode(注意如果以@開頭的變量可以不用通過declare語句事先聲明)

select @oldaacode:=vcaaCode from T_sum where vcaaCode=var1 and dtDate=sumdate;

if @oldaacode=var1 then --判斷

update T_sum set iNum=var3 where vcaaCode=var1 and dtDate=sumdate;

else

insert into T_sum(vcaaCode,vcaaName,iNum,dtDate) values(var1,var2,var3,sumdate);

end if;

UNTIL no_more_departments END REPEAT; --循環(huán)語句結(jié)束

CLOSE C_RESULT; --關(guān)閉游標(biāo)

DROP TEMPORARY TABLE tmp_table; --刪除臨時(shí)表

end;

總結(jié)

以上是生活随笔為你收集整理的mysql存储过程执行update_MySQL存储过程实现动态执行SQL的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。