2. 程式人生 > >mysql 儲存過程動態sql

mysql 儲存過程動態sql

阿新 • • 發佈：2018-11-12
DROP PROCEDURE IF EXISTS PRO_STA_SYSTEM_ORDER_STATE;
DELIMITER //
CREATE DEFINER=`root`@`%` PROCEDURE `PRO_STA_SYSTEM_ORDER_STATE`(OUT O_RESULT_CODE CHAR(4))
    COMMENT '系統訂單實時統計'
BEGIN
DECLARE DONE INT DEFAULT TRUE;-- 定義一個標識為true
DECLARE YEAR_MONTH_STR VARCHAR(10);-- 當前年月

DECLARE CONTINUE HANDLER FOR NOT FOUND,SQLEXCEPTION  SET DONE = FALSE;-- 異常的情況標識為false

IF month(curdate()) <= 10 THEN
   SET YEAR_MONTH_STR = CONCAT(year(curdate()),0,month(curdate()));-- 例如:201703
ELSE
   SET YEAR_MONTH_STR = CONCAT(year(curdate()),month(curdate()));-- 例如:201710
END IF;
#到t_company_flows_order_*_*表查尋包括:今日總訂單量,成功訂單量,流量訂單量,流量成功訂單量,話費訂單量,話費成功訂單量,系統卡單數量（流量貝貝平臺總卡單數量）
SET @asql = CONCAT('SELECT COUNT(1) TOTAL_ORDER_COUNT,
                                        COUNT(CASE WHEN  status  = ''2'' then 1 else null end ) TOTAL_SUCCESS_ORDER_COUNT,
                                        COUNT(CASE WHEN  businessType  = 2 then 1 else null end ) FLOW_ORDER_COUNT,
                    COUNT(CASE WHEN  businessType  = 2 AND status = ''2'' then 1 else null end ) FLOW_SUCCESS_ORDER_COUNT,
                                        COUNT(CASE WHEN  businessType  = 1 then 1 else null end ) BILL_ORDER_COUNT,
                    COUNT(CASE WHEN  businessType  = 1 AND status = ''2'' then 1 else null end ) BILL_SUCCESS_ORDER_COUNT,
                    COUNT(CASE WHEN  status in(''1'',''3'') then 1 else null end) SYSTEM_STUCK_ORDER_COUNT  INTO @TOTAL_ORDER_COUNT,@TOTAL_SUCCESS_ORDER_COUNT,@FLOW_ORDER_COUNT,
                    @FLOW_SUCCESS_ORDER_COUNT,@BILL_ORDER_COUNT,@BILL_SUCCESS_ORDER_COUNT,@SYSTEM_STUCK_ORDER_COUNT',' FROM (',
                                                       'SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_01 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_02 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_03 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_04 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                             'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_05 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_06 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_07 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_08 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_09 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ',
                                             'UNION ALL SELECT businessType,status FROM t_company_flows_order_',YEAR_MONTH_STR,'_10 WHERE createDate >= date(now()) and createDate < date(date_add(now(),interval 1 day)) ) tbl');
 prepare sqlstmt from @asql;
 execute sqlstmt;
#到order_reau_record_*_*表包括：回撥平均成功率,上游渠道卡單數（卡在上游渠道的訂單數量）,回撥平均時長（毫秒）
SET @bsql = CONCAT('SELECT  IFNULL(ROUND(COUNT(CASE WHEN  CALLBACK_STATUS  = ''1'' then 1 else null end )/count(1),2),0) CALLBACK_SUCCESS_AVG,
                                                COUNT(CASE WHEN  REQUEST_STATUS  = ''1'' AND CALLBACK_STATUS = ''0'' then 1 else null end ) REAU_STUCK_ORDER_COUNT,
                                                IFNULL(ROUND(AVG(CALLBACK_TIME),0),0)  CALLBACK_TIMES_AVG  INTO @CALLBACK_SUCCESS_AVG,@REAU_STUCK_ORDER_COUNT,@CALLBACK_TIMES_AVG',' FROM (',
                                                      'SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_01 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_02 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_03 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_04 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_05 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_06 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_07 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_08 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_09 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ',
                                            'UNION ALL SELECT CALLBACK_STATUS,REQUEST_STATUS,CALLBACK_TIME FROM order_reau_record_',YEAR_MONTH_STR,'_10 WHERE DATE_CREATE >= date(now()) and DATE_CREATE < date(date_add(now(),interval 1 day)) ) tb1');
prepare sqlstmt from @bsql;
execute sqlstmt;

#儲存到sta_system_order_state系統訂單實時統計表中
INSERT INTO sta_system_order_state(DATE_CREATED,TOTAL_ORDER_COUNT,TOTAL_SUCCESS_ORDER_COUNT,FLOW_ORDER_COUNT,FLOW_SUCCESS_ORDER_COUNT,BILL_ORDER_COUNT,BILL_SUCCESS_ORDER_COUNT,CALLBACK_SUCCESS_AVG,
                                  SYSTEM_STUCK_ORDER_COUNT,REAU_STUCK_ORDER_COUNT,CALLBACK_TIMES_AVG) VALUES
                                                                     (NOW(),@TOTAL_ORDER_COUNT,@TOTAL_SUCCESS_ORDER_COUNT,@FLOW_ORDER_COUNT,@FLOW_SUCCESS_ORDER_COUNT,@BILL_ORDER_COUNT,@BILL_SUCCESS_ORDER_COUNT,@CALLBACK_SUCCESS_AVG,
                                                                     @SYSTEM_STUCK_ORDER_COUNT,@REAU_STUCK_ORDER_COUNT,@CALLBACK_TIMES_AVG);
IF DONE THEN
   SET O_RESULT_CODE = '0000';-- 成功 '0000'
ELSE
   SET O_RESULT_CODE = '9999';-- 失敗 '9999'
END IF;

END//

DELIMITER ;



總結：通過into關鍵字可以將欄位放入臨時變數中，然後就可以操作了

相關推薦

mysql 儲存過程動態sql

DROP PROCEDURE IF EXISTS PRO_STA_SYSTEM_ORDER_STATE; DELIMITER // CREATE DEFINER=`root`@`%` PROCEDURE `PRO_STA_SYSTEM_ORDER_STATE`(OUT O_RESULT_

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

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

SQL Server建立儲存過程——動態SQL

儲存過程(stored procedure)是一組為了完成特定功能的SQL語句集合，經編譯後儲存在伺服器端的資料庫中，利用儲存過程可以加速SQL語句的執行。 自定義儲存過程，由使用者建立並能完成某一特定功能的儲存過程，儲存過程既可以有引數又有返回值，但是它與函式不同，儲存過程的返回值只是指明執行是否成功，

oracle儲存過程,動態sql

CREATE OR REPLACE PROCEDURE "TUBEMNG"."RE" (one OUT INTEGER,two OUT INTEGER,three OUT INTEGER,four OUT INTEGER,ptype IN VARCHAR2,D

mysql 儲存過程 動態排序

//引數 set @sidx=sx;/排序名稱/ set @sord=sd;/排序方式/ 動態排序 if @sord=“desc” then CASE @sidx WHEN ‘zj’ THEN select * from ywtjb ORDER BY zj D

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

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

mysql儲存過程迴圈遍歷sql結果集，並執行動態sql

/* 將其他幾張表資料複製到一張總表中 */ DROP PROCEDURE IF EXISTS sp_customer; CREATE PROCEDURE sp_customer() BEGIN -- 需要執行的SQL語句 DECLARE v_sql_1 VARCH

mysql儲存過程執行動態sql語句並返回值

Java程式碼 set @sql=’xxx’; prepare stmt from @sql; execute stmt; deallocate prepare stmt; select @curd1; set @sql=’xxx’; prepare stmt f

mysql儲存過程 在動態SQL內獲取返回值

MySql通用分頁儲存過程 過程引數 p_cloumns varchar(500),p_tables varchar(100),p_where varchar(4000),p_order varchar(100),p_pageindex int,p_pagesize int

mysql儲存過程接收動態sql返回值

一、今天需要用到mysql儲存過程接受動態sql的返回值，特此做以下記錄 二、具體如下 -- BS追加公能欄位 獲取型別和公能分組ID declare vPartName,vType,vSql,vId varchar(100); declare vPartGroupId i

mysql 儲存過程 執行動態sql

使用mysql的儲存過程執行動態sql語句 delimiter // create procedure proce2(in old varchar(100), in newT varchar(1

mysql儲存過程在動態SQL內獲取返回值

DROPPROCEDUREIFEXISTS stat_cube.sp_get_end_date;CREATEPROCEDURE stat_cube.`sp_get_end_date`( p_sp_name varchar(50), out p_ret_date date )BEGINdeclare src_1

MySQL儲存過程中使用動態SQL與靜態SQL的區別

儲存過程中使用動態SQL 例項 [sql] view plain copy print? DELIMITER $$ DROP PROCEDURE IF EXISTS `test`.`t1`$$ CREATE /** [DEFINER

MySQL儲存過程的動態行轉列

轉載：http://segmentfault.com/a/1190000004314724?ref=myread MySQL儲存過程中使用動態行轉列 最近做專案關於資料報表處理，然而資料庫儲存格式和報表展現形式不同，需要進行一下行轉列的操作，在做上一個專案的時候也看

Hive儲存過程HQL/SQL（二）– 在Hive儲存過程中讀寫MySQL表

關鍵字：Hive儲存過程、PL/HQL、HQL/SQL、MySQL 通過PL/HQL可以在一個指令碼中同時訪問多個數據庫系統。在實際業務場景中，經常會有需要將Hive和RDBMS中的資料結合分析，比如： 往RDBMS中寫入Hive分析的審計資訊；從RDBMS中獲取一些維

關於mysql儲存過程建立動態表名及引數處理

轉載請註明出處：簾卷西風的專欄(http://blog.csdn.net/ljxfblog) 最近遊戲開始第二次內測，開始處理操作日誌，最開始把日誌放到同一個表裡面，發現一天時間，平均100玩家線上，操作記錄就超過13萬條，決定拆表，按照日期來儲存日誌，每天的日誌存到一個表裡

MYSQL儲存過程執行用字串拼成的sql語句

執行的sql必須定義為 @sql  才能執行  否則報錯DROP PROCEDURE IF EXISTS  test_prepareStam;    delimiter // CREATE PROCE

mysql動態遊標學習(mysql儲存過程遊標)

-- 建立測試表和資料 create table webuser (username varchar(10)); insert into webuser values ('a1'),('a2'),('a3'),('b1'),('b2'),('b3'); commit; -- 建立儲存過程 drop pro

Mysql儲存過程8:repeat循環

local cal 其他 host ted query code class pan 語法: repeat SQL until 條件 end repeat; 就是相當於其他語言中的: do{ # }while(); mys

Mysql儲存過程4:mysql變量設置

from 默認 pan procedure weight use mysql變量 sql 寫法 默認全局變量是兩個@@開頭, 可用show variables查看所有默認變量: @@user #declare定義變量只能用在儲存過程中 #declare 變量名 數據類型