1. 程式人生 > >MySQL儲存過程實現動態執行SQL

MySQL儲存過程實現動態執行SQL

 
create procedure p_procedurecode(in sumdate varchar(10))   
begin
     declare v_sql varchar(500);    #需要執行的SQL語句      declare sym varchar(6);            declare var1 varchar(20);      declare var2 varchar(70);      declare var3 integer;
     #定義遊標遍歷時,作為判斷是否遍歷完全部記錄的標記      declare no_more_departments integer DEFAULT 0;     
     #定義遊標名字為C_RESULT       DECLARE C_RESULT CURSOR FOR              SELECT barcode,barname,barnum FROM tmp_table;
    #聲明當遊標遍歷完全部記錄後將標誌變數置成某個值      DECLARE CONTINUE HANDLER FOR NOT FOUND              SET no_more_departments=1;
     set sym=substring(sumdate,1,6);     #擷取字串,並將其賦值給一個遍歷
     #連線字串構成完整SQL語句,動態SQL執行後的結果記錄集,在MySQL中無法獲取,因此需要轉變思路將其放置到一個臨時表中(注意程式碼中的寫法)。一般寫法如下:
     #     '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;   #注意很重要,將連成成的字串賦值給一個變數(可以之前沒有定義,但要以@開頭)      prepare stmt from @v_sql;  #預處理需要執行的動態SQL,其中stmt是一個變數      EXECUTE stmt;      #執行SQL語句      deallocate prepare stmt;     #釋放掉預處理段
     OPEN C_RESULT;       #開啟之前定義的遊標      REPEAT                      #迴圈語句的關鍵詞            FETCH C_RESULT INTO VAR1, VAR2, VAR3;   #取出每條記錄並賦值給相關變數,注意順序
          #執行查詢語句,並將獲得的值付給一個變數 @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;    #迴圈語句結束      CLOSE C_RESULT;                            #關閉遊標
     DROP TEMPORARY TABLE tmp_table;       #刪除臨時表 end