mysql動態執行sql

阿新 • • 發佈：2019-02-13

這邊重點程式碼是：

set f_sql=CONCAT('rename table cw_computer_resulttest to cw_computer_result',f_last,';');
set @ms=f_sql; 
PREPARE stmt1 FROM @ms;
EXECUTE stmt1;
DEALLOCATE PREPARE stmt1 ;

其中@ms是系統變數，不用declare，這是重點

下面是寫的全部儲存過程：（本例中還給出了巢狀cursor的應用）

drop PROCEDURE IF EXISTS  cw_year1_deal;

create PROCEDURE cw_year1_deal()
BEGIN

DECLARE f_date VARCHAR(20);
DECLARE f_month VARCHAR(20);
DECLARE f_last VARCHAR(20);
DECLARE DONE INT;
DECLARE I int DEFAULT 0;
DECLARE f_sql VARCHAR(200);

DECLARE d_cursor CURSOR FOR select date from tb_date where date>='2016-01-11' ;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET DONE = 1;

set f_last='201601';
set f_month='201601';

START TRANSACTION;
OPEN d_cursor;
READ_LOOP :LOOP
FETCH d_cursor INTO f_date;


IF DONE THEN 
LEAVE READ_LOOP;
END IF;
set f_last=f_month;
set f_month =CONCAT(SUBSTR(f_date FROM 1 FOR 4),SUBSTR(f_date FROM 6 FOR 2));
if f_last<>f_month THEN


-- SET cal1=CONCAT(cal1," ","AND OPEDOC_ID = ","'",DoctorId,"'");
set f_sql=CONCAT('rename table cw_computer_resulttest to cw_computer_result',f_last,';');
set @ms=f_sql; 
PREPARE stmt1 FROM @ms;
EXECUTE stmt1;
DEALLOCATE PREPARE stmt1 ;


DROP TABLE IF EXISTS `cw_computer_result`;
CREATE TABLE `cw_computer_result` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `date` date DEFAULT NULL,
  `bianhao` varchar(20) DEFAULT NULL,
  `licairenbh` varchar(500) DEFAULT NULL,
  `licairen` varchar(200) DEFAULT NULL,
  `SCHEDULE_ID` varchar(32)  COMMENT '主鍵',
  `jiekuandanhao` varchar(50) DEFAULT '0' COMMENT '借款ID',
  `dangqistarttime` datetime DEFAULT NULL COMMENT '每期開始計時時間',
  `dangqiyhtime` datetime DEFAULT NULL COMMENT '預計還款時間',
  `dangqishtime` varchar(19)  DEFAULT '',
  `jiekuanhetongrfl` decimal(18,8) DEFAULT NULL,
  `jiekuanhetongts` int(11) DEFAULT '0' COMMENT '每期天數',
  `fangkuanje` decimal(21,2) DEFAULT NULL,
  `dangqije` decimal(20,2) DEFAULT '0.00' COMMENT '預還本金',
  `jiekuanfuwufeilx` decimal(20,2) DEFAULT '0.00' COMMENT '預還利息',
  `jiekuangudingfy` varchar(10)  DEFAULT '',
  `jiekuanzjzyqfy` decimal(20,8) DEFAULT '0.00' COMMENT '借款-資金佔用期費用',
  `userid` varchar(32) DEFAULT NULL COMMENT '使用者ID',
  `username` varchar(255) DEFAULT NULL COMMENT '借款客戶姓名',
  `jiekuanhetongje` decimal(20,2) DEFAULT NULL COMMENT '借款總金額',
  `fankuandate` datetime DEFAULT NULL COMMENT '借款成功時間',
  `jiekuanyhdate` datetime DEFAULT NULL COMMENT '最後還款時間',
  `licaibenjin` int(11) DEFAULT NULL,
  `zijinduanrfl` varchar(200) DEFAULT NULL,
  `zijinduanstarttime` date DEFAULT NULL,
  `zijinduanendtime` date DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `date_index` (`date`),
  KEY `SCHEDULE_ID` (`SCHEDULE_ID`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

end if;

-- select f_month;
call cw_deal(f_date);


SET I=I+1;
IF I%10000=0
THEN
SELECT I;
COMMIT;
START TRANSACTION;
END IF;

END LOOP READ_LOOP;
COMMIT;
CLOSE d_cursor;

END

引用的儲存過程程式碼：

drop PROCEDURE IF EXISTS  cw_deal;

create PROCEDURE cw_deal(IN indate varchar(20))
BEGIN

DECLARE f_date VARCHAR(20);
DECLARE I int DEFAULT 0;
DECLARE f_licairen VARCHAR(60);
DECLARE f_schedule_id varchar(32);
DECLARE f_jiekuandanghao varchar(50);
DECLARE f_dangqistarttime datetime;
DECLARE f_dangqiyhtime datetime;
DECLARE f_dangqishtime varchar(19);
DECLARE f_jiekuanhetongrfl decimal(18,8);
DECLARE f_jiekuanhetongts  int(11);
DECLARE f_fangkuanje decimal(21,2);
DECLARE f_dangqije decimal(20,2);
DECLARE f_jiekuanfuwulx decimal(20,2);
DECLARE f_jiekuangudingfy varchar(10);

DECLARE f_userid varchar(32);
DECLARE f_username varchar(255);
DECLARE f_jiekuanhetongje  decimal(20,2);
DECLARE f_jiekuanhetongksr datetime;
DECLARE f_jiekuanhetongyhr datetime;

DECLARE f_zijinduanje int(11);
DECLARE f_zijinduanfl varchar(200);
DECLARE f_zijinduanstarttime date;
DECLARE f_zijinduanendtime date;
DECLARE f_bianhao varchar(20);
DECLARE f_licairenbh varchar(100);

DECLARE f_fkje  decimal(20,2);
DECLARE f_fkje2  decimal(20,2);
DECLARE f_lcbj  decimal(20,2);
DECLARE f_ziyou  decimal(20,2);
DECLARE flag INT;
DECLARE DONE INT;

DECLARE dcheck_cursor CURSOR FOR select bianhao,licairenbh,licairen,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime from temp_datecheck_20170122 where `date`=indate ORDER BY zijinduanrfl desc;


DECLARE cw_cursor CURSOR FOR select SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,userid,username,jiekuanhetongje,  fankuandate ,jiekuanyhdate from tmp_detail 
where  is_deal =0 ;
  
DECLARE CONTINUE HANDLER FOR NOT FOUND SET DONE = 1;

DROP temporary TABLE IF EXISTS `tmp_detail`;
CREATE  temporary TABLE `tmp_detail` (
 `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `SCHEDULE_ID` varchar(32) NOT NULL COMMENT '主鍵',
  `jiekuandanhao` varchar(50) DEFAULT '0' COMMENT '借款ID',
  `dangqistarttime` datetime DEFAULT NULL COMMENT '每期開始計時時間',
  `dangqiyhtime` datetime DEFAULT NULL COMMENT '預計還款時間',
  `dangqishtime` varchar(19) NOT NULL DEFAULT '',
  `jiekuanhetongrfl` decimal(18,8) DEFAULT NULL,
  `jiekuanhetongts` int(11) DEFAULT '0' COMMENT '每期天數',
  `fangkuanje` decimal(21,2) DEFAULT NULL,
  `dangqije` decimal(20,2) DEFAULT '0.00' COMMENT '預還本金',
  `jiekuanfuwufeilx` decimal(20,2) DEFAULT '0.00' COMMENT '預還利息',
  `jiekuangudingfy` varchar(10) NOT NULL DEFAULT '',
  `userid` varchar(32) NOT NULL COMMENT '使用者ID',
  `username` varchar(255) DEFAULT NULL COMMENT '借款客戶姓名',
  `jiekuanhetongje` decimal(20,2) DEFAULT NULL COMMENT '借款總金額',
  `fankuandate` datetime DEFAULT NULL COMMENT '借款成功時間',
  `jiekuanyhdate` datetime DEFAULT NULL COMMENT '最後還款時間',
   is_deal int(1) NOT NULL DEFAULT '0',
   PRIMARY KEY (`id`),
  KEY `SCHEDULE_IDindex` (`SCHEDULE_ID`),
  KEY `is_dealindex` (`is_deal`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert into tmp_detail(SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,userid,username,jiekuanhetongje,  fankuandate ,jiekuanyhdate) 
select SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,userid,username,jiekuanhetongje,  fankuandate ,jiekuanyhdate from temp_cw_result_20170119 
where `date`=indate; 

SET flag=1;
SET f_fkje=0;
SET f_fkje2=0;
START TRANSACTION;
OPEN dcheck_cursor;
READ_LOOP :LOOP
FETCH dcheck_cursor INTO f_bianhao,f_licairenbh,f_licairen,f_zijinduanje,f_zijinduanfl,f_zijinduanstarttime,f_zijinduanendtime;
set f_lcbj=f_zijinduanje;



IF DONE THEN

set f_ziyou=0;
select sum(fangkuanje) into f_ziyou from tmp_detail where  is_deal =0;
INSERT INTO cw_computer_result(bianhao,licairenbh,date,licairen,SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,jiekuanzjzyqfy,userid,username,jiekuanhetongje,fankuandate,jiekuanyhdate,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime)
select 'bh_999','ziyou_999',indate,'自由資金',SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,0,userid,username,jiekuanhetongje,  fankuandate ,jiekuanyhdate,f_ziyou,0.0,indate,indate from tmp_detail 
where  is_deal =0;
   
LEAVE READ_LOOP;

END IF;


OPEN cw_cursor;
inner_loop:LOOP

    FETCH cw_cursor INTO f_schedule_id,f_jiekuandanghao,f_dangqistarttime,f_dangqiyhtime,f_dangqishtime,f_jiekuanhetongrfl,f_jiekuanhetongts,f_fangkuanje,f_dangqije,f_jiekuanfuwulx,f_jiekuangudingfy,f_userid,f_username,f_jiekuanhetongje,f_jiekuanhetongksr,f_jiekuanhetongyhr;


  

    IF DONE = 1 THEN

      IF flag =0 
       THEN
       INSERT INTO cw_computer_result(bianhao,licairenbh,date,licairen,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime)
       select f_bianhao,f_licairenbh,indate,f_licairen,f_zijinduanje,f_zijinduanfl,f_zijinduanstarttime,f_zijinduanendtime;
      end if;
       LEAVE inner_loop;

            
    end IF;
    

    
    SET flag=0;
    
    IF f_fkje2>0
    THEN
            set f_lcbj=f_lcbj-f_fkje2;
            IF f_lcbj>0
            THEN
                INSERT INTO cw_computer_result(bianhao,licairenbh,date,licairen,SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,jiekuanzjzyqfy,userid,username,jiekuanhetongje,fankuandate,jiekuanyhdate,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime)
                select f_bianhao,f_licairenbh,indate,f_licairen,f_schedule_id,f_jiekuandanghao,f_dangqistarttime,f_dangqiyhtime,f_dangqishtime,f_jiekuanhetongrfl,f_jiekuanhetongts,f_fkje2,f_dangqije,f_jiekuanfuwulx,f_jiekuangudingfy,f_fkje2*f_zijinduanfl,f_userid,f_username,f_jiekuanhetongje,f_jiekuanhetongksr,f_jiekuanhetongyhr,f_zijinduanje,f_zijinduanfl,f_zijinduanstarttime,f_zijinduanendtime;
                update tmp_detail set is_deal=1 where SCHEDULE_ID=f_schedule_id;
           
                SET f_fkje2=0;

            END IF;
            IF f_lcbj<=0
            THEN
              
              set f_fkje = f_fkje2+f_lcbj;
              set f_fkje2 = -f_lcbj;
              INSERT INTO cw_computer_result(bianhao,licairenbh,date,licairen,SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,jiekuanzjzyqfy,userid,username,jiekuanhetongje,fankuandate,jiekuanyhdate,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime)
              select f_bianhao,f_licairenbh,indate,f_licairen,f_schedule_id,f_jiekuandanghao,f_dangqistarttime,f_dangqiyhtime,f_dangqishtime,f_jiekuanhetongrfl,f_jiekuanhetongts,f_fkje,f_dangqije,f_jiekuanfuwulx,f_jiekuangudingfy,f_fkje*f_zijinduanfl,f_userid,f_username,f_jiekuanhetongje,f_jiekuanhetongksr,f_jiekuanhetongyhr,f_zijinduanje,f_zijinduanfl,f_zijinduanstarttime,f_zijinduanendtime;
              set DONE =1;
              SET flag=1;
            END IF;

            
    else 
    set f_lcbj=f_lcbj-f_fangkuanje; 
    IF f_lcbj>0
    THEN
            INSERT INTO cw_computer_result(bianhao,licairenbh,date,licairen,SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,jiekuanzjzyqfy,userid,username,jiekuanhetongje,fankuandate,jiekuanyhdate,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime)
            select f_bianhao,f_licairenbh,indate,f_licairen,f_schedule_id,f_jiekuandanghao,f_dangqistarttime,f_dangqiyhtime,f_dangqishtime,f_jiekuanhetongrfl,f_jiekuanhetongts,f_fangkuanje,f_dangqije,f_jiekuanfuwulx,f_jiekuangudingfy,f_fangkuanje*f_zijinduanfl,f_userid,f_username,f_jiekuanhetongje,f_jiekuanhetongksr,f_jiekuanhetongyhr,f_zijinduanje,f_zijinduanfl,f_zijinduanstarttime,f_zijinduanendtime;
            update tmp_detail set is_deal=1 where SCHEDULE_ID=f_schedule_id;
    END IF;
    IF f_lcbj<=0
    THEN
            set f_fkje = f_fangkuanje+f_lcbj;
            set f_fkje2 = -f_lcbj;
            INSERT INTO cw_computer_result(bianhao,licairenbh,date,licairen,SCHEDULE_ID,jiekuandanhao,dangqistarttime,dangqiyhtime,dangqishtime,jiekuanhetongrfl,jiekuanhetongts,fangkuanje,dangqije,jiekuanfuwufeilx,jiekuangudingfy,jiekuanzjzyqfy,userid,username,jiekuanhetongje,fankuandate,jiekuanyhdate,licaibenjin,zijinduanrfl,zijinduanstarttime,zijinduanendtime)
            select f_bianhao,f_licairenbh,indate,f_licairen,f_schedule_id,f_jiekuandanghao,f_dangqistarttime,f_dangqiyhtime,f_dangqishtime,f_jiekuanhetongrfl,f_jiekuanhetongts,f_fkje,f_dangqije,f_jiekuanfuwulx,f_jiekuangudingfy,f_fkje*f_zijinduanfl,f_userid,f_username,f_jiekuanhetongje,f_jiekuanhetongksr,f_jiekuanhetongyhr,f_zijinduanje,f_zijinduanfl,f_zijinduanstarttime,f_zijinduanendtime;
            set DONE =1;
            SET flag=1;
    END IF;

    END IF;


    

 
     
  end LOOP inner_loop;
  CLOSE cw_cursor; 





SET DONE=0;




SET I=I+1;
IF I%10000=0
THEN
SELECT I;
COMMIT;
START TRANSACTION;
END IF;

END LOOP READ_LOOP;
COMMIT;
CLOSE dcheck_cursor;

END

MySQL(動態執行SQL)

day61 防sql注入 delimiter \\ CREATE PROCEDURE p4 ( in tpl varchar(255), in arg int ) BEGIN set @xo = arg; PREPARE xxx FROM 's

mysql動態執行sql

這邊重點程式碼是：set f_sql=CONCAT('rename table cw_computer_resulttest to cw_computer_result',f_last,';'); set @ms=f_sql; PREPARE stmt1 FROM @ms

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

create procedure p_procedurecode(in sumdate varchar(10)) begin declare v_sql varchar(500); #需要

mysql source 執行sql腳本，中文變量不顯示問題或亂碼問題

中文 upd highlight 執行編碼 des cal 亂碼問題 lec 執行腳本內容如下： SET @pre_version=2017080901; SET @cur_version=2017090401; SET @ver_desc = ‘測試腳本‘; CAL

在Oracle、MySQL中執行sql指令碼生成hive建表語句

python3指令碼： #mysql for i in range(len(table_name)): sql1 = """SELECT CONCAT('create table ','%s','(') UNION ALL SELECT CONCAT(

Python連線MySQL資料庫執行sql語句時的引數問題

由於工作需要，今天寫了一個Python小指令碼，其中需要連線MySQL資料庫，在執行sql命令時需要傳遞引數，結果出問題了。在網上查了一下，發現有以下幾種方式傳遞引數：一.直接把sql查詢語句完整寫入字串 try: connection = MySQLdb.connect(user

mysql通過執行sql刪除指定資料庫的所有表

原理: 通過儲存過程遍歷獲取指定資料庫的表名稱,然後執行刪除語句,刪除完成後將刪除該儲存過程。預設刪除為當前使用的資料庫,可在第一行SET @table_schema = null指定其他要刪除的資

讓天下沒有難用的資料庫 » 檢視mysql實時執行sql的工具

該工具為我的同事朱旭開發的一款可以檢視mysql資料庫實時執行的sql狀況的工具，以前苦於通過show processlist/show full processlist抓取sql的同志們現在只要盯一盯螢幕就可以了，非常的方便，點選這裡進行下載,使用方法也很簡單，如下： [email pr

MySQL(Navicat)執行.sql檔案時報錯：[Err] 2006

背景：今天匯入一個數據量很大的.sql檔案時，報錯：原因：可能是sql語句過長，超過mysql通訊快取區最大長度。解決：1. 編輯 MySQL 安裝目錄下的 my.ini，在最後新增以下內容： max_allowed_packet=16M 2. 重啟 MyS

動態執行Sql語句與臨時表的問題(物件名無效)

exec('selectIDENTITY(int,1,1) as ID,fnum,into #yuecu from store_store where '+@Parameter) select XX,XX1,XX2 from #yuecu 這樣建立一個臨時表

Mysql 動態執行多條update語句,帶事務的

create procedure P_CallSql_Tran(IN vi_sql text,in vi_splitchar varchar(20),OUT vo_code VARCHAR(20),out vo_msg text)BEGINDECLARE v_sqltemp

jdbc連線mysql資料庫執行sql語句ResultSet結果集一直為空

問題描述：ResultSet rs=sqlstatement.executeQuery(sql); 執行後查詢語句後rs一直為空，但是將sql語句放到資料庫中進行查詢卻能得到結果. 解決：sql=“s

MySQL筆記-執行SQL語句的幾種方式

一、基本介面或類 ——>DriverManager：用於管理JDBC驅動的服務類。主要功能是獲取Connection物件。 ——>Connection：代表資料庫連線物件，每個Connection代表一個物理連線會話。 ——>Statement：用於執行S

MySQL打包執行SQL

cat result disable tell roc 傳輸兩個 pass 類型當一次業務處理計算服務和數據庫交互較多時，將可能有大量時間浪費在數據傳輸上，尤其對於計算服務和數據庫跨機房或跨地區部署時，浪費的時間會極其可觀。為了減少時間浪費可以使用MySQL提供的SQL

MySQL批量執行sql文件

.sql source col eight 文件命令命令行 blog pos 1、待執行的sql文件為1.sql、2.sql、3.sql、4.sql等 2、寫一個batch.sql文件： source 1.sql; source 2.sql; source 3.sql

mybaits（查詢與別名、日誌框架顯示sql語句、物件屬性和資料庫表字段不匹配resultMap使用、mysql資料查詢分頁、執行sql和儲存過程、動態SQL語句）

主要是各種配置檔案，建議把整個專案搬到自己電腦上慢慢看。建立maven專案首先是各種配置檔案： pom.xml: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://m

mysql 儲存過程動態拼接sql並執行賦值

CREATE DEFINER = CURRENT_USER PROCEDURE `NewProc`(in _xnb varchar(50)) BEGIN ## 定義變數 DECLARE _num FLOAT(14,6) DEFAULT 0; ## @表示全域性變數相當於php

mysql 存儲過程動態拼接sql並執行賦值

pro roc ddt reat create 不用 lec efi 語句 CREATE DEFINER = CURRENT_USER PROCEDURE `NewProc`(in _xnb varchar(50)) BEGIN ## 定義變量 DECLA

MySQL查看SQL語句執行效率

博客 union pan art 顯示 uniq left join 匹配 article Explain命令在解決數據庫性能上是第一推薦使用命令，大部分的性能問題可以通過此命令來簡單的解決，Explain可以用來查看 SQL 語句的執行效果，可以幫助選擇更好的索引和優化

Mysql 學習之 SQL的執行順序

src mage order join where clas 讀取 cnblogs num mysql的json查詢：

mysql動態執行sql

相關推薦