一、首先說下本篇部落格所實現功能的背景和功能是怎樣的：

      背景：因為公司專案開始遷移新平臺專案，所以以前的平臺老資料以及訂單資訊需要拆分表，而且需要業務邏輯來分析以前的訂單表，來拆分成另外的幾個新表，包括增加新的流水分析，以及更新其他使用者或者商家的餘額以及對賬資訊。

      功能：需要查詢出某個日期節點後的幾十萬條訂單資訊，迴圈遍歷每條訂單，獲取每條訂單的交易額，從而根據訂單中的商家id和使用者id來更新使用者表中的積分或者餘額資訊，並且要在迴圈中為商家儲存流水。

      講解：其實這個儲存過程一點都不難，主要是本人在之前沒有寫過儲存過程的經驗，而且這次是直接用在新舊專案中訂單模組的遷移，所以說其實還是有點小小的壓力的。所以如果沒有寫過儲存過程的同學們可以看看這一篇，然後思考一下。

二、儲存過程技術點

    1、適用場景，因為儲存過程是存在記憶體中的，直接跳過了用sql語言語法檢查，編譯等過程中（具體需要百度），所以儲存過程的效率非常高。另外加上儲存過程非常適合有業務邏輯的多表操作，結果集操作等等，所以比我們寫一個複雜的sql

去完成一個功能，思路會更加清晰以及更加接近與程式語言的風格，比如迴圈，判斷等等。但是儲存過程使用的場景還是比較少的，原因就是維護成本比較高，尤其是資料庫有叢集的時候，我還沒有研究到那些深度。所以本人現在用儲存過程的

場景就是某些特別耗時，而且改動不大的操作，列入統計，資料遷移等等。

    2、語法

1、建立儲存過程
create procedure sp_name()
begin
.........
end

sp_name() 為儲存過程名稱，（）裡面可以設定帶引數的，本列子不帶引數。
邏輯程式碼存在於begin 和 end 之中

2、定義變數
DECLARE a VARCHAR(32);相當於定義了一個全域性的（作用於begin和end之中的變數，這個變數可以用來承接每次迴圈的某個值，相當於在while迴圈外設定值來接收的）
注意：這裡的變數必須設定到begin之後，不能定義在
例如java   
int a=0;
while(a<10){
  a+1;
}

這裡先定義幾個變數待會要使用：
 

DECLARE name VARCHAR(32);

DECLARE phone VARCHAR(32);

DECLARE password VARCHAR(32);

3、遊標的使用
其實儲存過程中的遊標和java 中的iterator使用有點相似，都是處理迴圈遍歷的，遊標我現在是用來處理結果集遍歷的
首先設定一個遊標的結束標誌位，這裡和java這些iterator.hasNext()相似

DECLARE s int DEFAULT 0;／／如果是開發的話，直接這句話拷貝進去，具體原理不是很瞭解

將結果集存入遊標中，相當於 iterator  listiterator = list.iterator();  listiterator就相當於遊標，list就是結果集

DECLARE user CURSOR FOR SELECT a.name,a.phone,a.password from user_info a ;//從使用者表中查詢出name，phone，password進入user這個遊標中
 

DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET s=1; ／／這句話是用在while迴圈前的，如果遊標到了最後就會將之前定義的s設定為1 ，直接拷貝進入就行

剛才演示的是把結果集存入遊標，現在開始要使用遊標了，就是java中的相當於要while(iterator.hasNext()){}這個步驟了

儲存過程的遊標使用要使用,user是剛才的遊標名
  OPEN user
    ...
  CLOSE user

將遊標中的值用變數來接收需要使用剛才在begin後定義的變數  如 name phone password

FETCH user into name,phone,password;//將遊標中的值賦值給變數，要注意順序

4、while迴圈

一般在遊標的處理過程中進行while迴圈，這裡的while條件要使用剛才定義的遊標結束標誌 s 的值
過程如下（結合遊標）

OPEN user

  FETCH user into name,phone,password;／／先將遊標中的資料存入到變數中，這裡和java的iterator有點不一樣
  while a<>1 do  //當a不等於1的時候執行內容操作
     ...／／進行邏輯操作
   FETCH user into name,phone,password; //再在迴圈中將遊標中的值傳入到變數中
  end while 

CLOSE user


5、if判斷

 在剛才的邏輯操作中，可以對變數的值進行邏輯操作，就像和java之類的程式語言一樣，最常用的不過if判斷，語法如下

1.     if (a > 0) then  
2.         select '> 0';  
3.     elseif (a = 0) then  
4.         select '= 0';  
5.     else  
6.         select '< 0';  
7.     end if;  

除此之外，還可以坐很多其他表的增刪改查的操作，完全可以在儲存過程中完成業務邏輯的修改，但是由於維護的難度以及測試的難度，這種運用場景還是不多的

BEGIN 
  DECLARE stationId VARCHAR(32);
  DECLARE consumeId VARCHAR(32);
  DECLARE openMoney DECIMAL(11,2);

  DECLARE balance DECIMAL(11,4);
 
  DECLARE payRate DECIMAL(11,4);

  DECLARE s int DEFAULT 0;
  
  DECLARE consume CURSOR FOR SELECT a.id_ AS consumeId,ROUND( a.consume_money - a.station_save - a.station_discount_save, 2 ) AS openMoney,a.station_id AS stationId FROM upim_user_consume a WHERE a.order_status = 1 AND a.status_ = '0' AND a.consume_time > '2017-08-01 00:00:00'  ORDER BY a.consume_time DESC;

  DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET s=1;


  OPEN consume;
 
    FETCH consume into consumeId,openMoney,stationId;

    while s <> 1 DO
              
    SELECT a.balance_ as balance,a.pay_rate AS payRate INTO balance,payRate from station_detail a where a.id=stationId and a.status_<>'-2';
                                
    INSERT INTO upim_station_money_flow(id_,flow_type,source_id,before_change,change_,after_change,station_id) VALUES(REPLACE(UUID(),'-',''),0,consumeId,balance,-openMoney,balance-openMoney,stationId);
                                
    UPDATE station_detail a set a.balance_=balance-openMoney where id=stationId ;           

    SELECT a.balance_ as balance,a.pay_rate AS payRate INTO balance,payRate from station_detail a where a.id=stationId and a.status_<>'-2';

    INSERT INTO upim_station_money_flow(id_,flow_type,source_id,before_change,change_,after_change,station_id) VALUES(REPLACE(UUID(),'-',''),3,consumeId,balance,openMoney*payRate,balance+(openMoney*payRate),stationId);
                                
    UPDATE station_detail a set a.balance_=balance+(openMoney*payRate) where id=stationId ;

         
    FETCH consume INTO consumeId,openMoney,stationId;
    end WHILE;

  CLOSE consume;
  
END