日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
拆表用的MySQL存儲過程

MySQL存儲過程用途很廣泛，下面就為您介紹拆表用的MySQL存儲過程，希望對您學習MySQL存儲過程方面能夠有所幫助。

成都創(chuàng)新互聯(lián)長期為1000多家客戶提供的網(wǎng)站建設(shè)服務，團隊從業(yè)經(jīng)驗10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為秦皇島企業(yè)提供專業(yè)的網(wǎng)站設(shè)計制作、成都網(wǎng)站設(shè)計，秦皇島網(wǎng)站改版等技術(shù)服務。擁有十載豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。

mysql表或分表的數(shù)據(jù)達到一定量（也許是800w或者1000w..）這個時候非常需要再分表，簡單的辦法是直接寫
--假設(shè)根據(jù)user_id分表，分成64張

 
 
 
      
  
  
  1. insert into table_new_0000 select * from table_old where mod(user_id,64)=0;  
    2.   
  
  
  2. insert into table_new_0001 select * from table_old where mod(user_id,64)=1;  
    3.   
  
  
  3. ...  
    4.

一共64條sql，OK 搞定。  但是這個一張表被全表掃描了64次，做的無用功比較多，而且導致停機時間比較長。

雖然MySQL存儲過程不是很熟，稍稍學習了下寫了兩個腳本，一個全量+一個增量腳本完成表的拆分。
線上庫也實踐了下，8個分表，每個分表1000W記錄拆分到64個分表。
全量 時間 150分鐘，全量的時候幾個分表可以一起跑，我是同時跑3個分表
增量 時間 每個分表4分鐘 4個一起跑，一共是 8分鐘搞定。 這樣停機時間加上應用的發(fā)布一共只需要20分鐘就可以搞定了。

附腳本：

###################
delimeter //

-----------
--- 全量腳本：

 
 
 
      
  
  
  1. CREATE PROCEDURE  sp_xf_move_item()  
    2.   
  
  
  2. begin  
    3.   
  
  
  3. declare v_exit int default 0;  
    4.   
  
  
  4. declare v_spid bigint;  
    5.   
  
  
  5. declare v_id bigint;  
    6.   
  
  
  6. declare i int default 0;  
    7.   
  
  
  7. declare c_table int;  
    8.

--定義游標（要分拆的表，定義一個數(shù)量的截止時間）

 
 
 
      
  
  
  1. declare c_ids cursor for select id,user_id from item_records_0000 where gmt_modified < '2010-8-25 00:00:00';  
    2.   
  
  
  2. declare  continue handler for not found set v_exit=1;  
    3.   
  
  
  3. open c_ids;  
    4.   
  
  
  4. repeat  
    5.

--將需要的值裝入變量

 
 
 
      
  
  
  1. fetch c_ids into v_id,v_spid;  
    2.   
  
  
  2. if v_exit = 0 then  
    3.   
  
  
  3. set @vv_id = v_id;  
    4.

--根據(jù)取模字段獲取數(shù)據(jù)存在的表

 
 
 
      
  
  
  1. select mod(v_spid,64) into c_table;  
    2.

--組裝動態(tài)sql

 
 
 
      
  
  
  1. SET @SQL_CONTEXT =  
    2.   
  
  
  2. CONCAT('insert into item_record_',  
    3.   
  
  
  3. LPAD(c_table, 4, 0),  
    4.   
  
  
  4. ' select * from item_records_0000 where id = ?');  
    5.   
  
  
  5.  
    6.   
  
  
  6. PREPARE STMT FROM @SQL_CONTEXT;  
    7.   
  
  
  7. --執(zhí)行sql  
    8.   
  
  
  8. EXECUTE STMT using @vv_id;  
    9.   
  
  
  9. DEALLOCATE PREPARE STMT;  
    10.   
  
  
  10. end if;  
    11.   
  
  
  11. set ii=i+1;  
    12.   
  
  
  12.  
    13.

--100條提交一次，以提高效率，記得執(zhí)行存儲過程前設(shè)置auto_commit

 
 
 
      
  
  
  1. if mod(i,100)=0 then commit;  
    2.   
  
  
  2. end if;  
    3.   
  
  
  3. until v_exit=1 
    4.   
  
  
  4. end repeat;  
    5.   
  
  
  5. close c_ids;  
    6.   
  
  
  6. commit;  
    7.   
  
  
  7. end;  
    8.   
  
  
  8. //  
    9.   
  
  
  9.  
    10.   
  
  
  10. -----------  
    11.   
  
  
  11. set auto_commit=0;  
    12.   
  
  
  12. call  sp_xf_move_item();  
    13.   
  
  
  13.  
    14.   
  
  
  14. #### 增量腳本 ######  
    15.   
  
  
  15.  
    16.   
  
  
  16. CREATE PROCEDURE sp_xf_add_item()  
    17.   
  
  
  17. begin  
    18.   
  
  
  18. declare v_exit int default 0;  
    19.   
  
  
  19. declare v_spid bigint;  
    20.   
  
  
  20. declare v_id bigint;  
    21.   
  
  
  21. declare i int default 0;  
    22.   
  
  
  22. declare c_table int;  
    23.   
  
  
  23. declare c_ids cursor for select id,supplier_id from item_records_0000 where gmt_modified >= '2010-8-25 00:00:00';  
    24.   
  
  
  24. declare  continue handler for not found set v_exit=1;  
    25.   
  
  
  25. open c_ids;  
    26.   
  
  
  26. repeat  
    27.   
  
  
  27.  
    28.   
  
  
  28. fetch c_ids into v_id,v_spid;  
    29.   
  
  
  29. if v_exit = 0 then  
    30.   
  
  
  30. set @vv_id = v_id;  
    31.   
  
  
  31. set @v_row=0;  
    32.   
  
  
  32. select mod(v_spid,64) into c_table;  
    33.   
  
  
  33.  
    34.

--判斷數(shù)據(jù)是否已經(jīng)存在

 
 
 
      
  
  
  1. SET @SQL_C =  
    2.   
  
  
  2. CONCAT('select count(*) into @v_row from item_record_',  
    3.   
  
  
  3. LPAD(c_table, 4, 0),  
    4.   
  
  
  4. ' where id = ?');  
    5.   
  
  
  5.  
    6.   
  
  
  6. PREPARE STMT_C FROM @SQL_C;  
    7.   
  
  
  7. EXECUTE STMT_C using @vv_id;  
    8.   
  
  
  8. DEALLOCATE PREPARE STMT_C;                         
    9.   
  
  
  9.  
    10.   
  
  
  10. SET @SQL_INSERT =  
    11.   
  
  
  11. CONCAT('insert into bbc_item_record_',  
    12.   
  
  
  12. LPAD(c_table, 4, 0),  
    13.   
  
  
  13. ' select * from item_records_0000 where id = ?');  
    14.   
  
  
  14.  
    15.   
  
  
  15. PREPARE STMT_I FROM @SQL_INSERT;           
    16.   
  
  
  16.  
    17.   
  
  
  17. SET @SQL_DELETE =  
    18.   
  
  
  18. CONCAT('DELETE FROM bbc_item_record_',  
    19.   
  
  
  19. LPAD(c_table, 4, 0),  
    20.   
  
  
  20. ' where id = ?');  
    21.   
  
  
  21. PREPARE STMT_D FROM @SQL_DELETE;       
    22.

--如果數(shù)據(jù)已經(jīng)存在，則先delete在insert          

 
 
 
      
  
  
  1. if @v_row>0 then   
    2.   
  
  
  2.  
    3.   
  
  
  3. EXECUTE STMT_D using @vv_id;  
    4.   
  
  
  4. DEALLOCATE PREPARE STMT_D;  
    5.   
  
  
  5.  
    6.   
  
  
  6. end if;  
    7.   
  
  
  7. EXECUTE STMT_I using @vv_id;  
    8.   
  
  
  8. DEALLOCATE PREPARE STMT_I;         
    9.   
  
  
  9.  
    10.   
  
  
  10. end if;  
    11.   
  
  
  11. set ii=i+1;  
    12.   
  
  
  12. if mod(i,100)=0 then commit;  
    13.   
  
  
  13. end if;  
    14.   
  
  
  14. until v_exit=1 
    15.   
  
  
  15. end repeat;  
    16.   
  
  
  16. close c_ids;  
    17.   
  
  
  17. commit;  
    18.   
  
  
  18. end;  
    19.   
  
  
  19. //  
    20.   
  
  
  20.  
    21.   
  
  
  21. -------  
    22.   
  
  
  22.  
    23.

如果全量和增量之間的時間拖的比較長，那么可以設(shè)置時間，多做幾次增量已縮短最后的停機時間，你懂的。。。
call sp_xf_add_item()//

【編輯推薦】

深入探討MySQL鎖機制

MySQL字段中的集合

MySQL字段類型簡介

Mysql外鍵用法分析

詳解MySQL數(shù)據(jù)表類型

  

文章題目：拆表用的MySQL存儲過程
本文來源：http://m.5511xx.com/article/dhjigeg.html