现在的位置: 首页 > 数据库 > 正文

MySQL存储过程有哪些

2020年05月08日 数据库 ⁄ 共 1808字 ⁄ 字号 评论关闭

  MySQL存储过程用途很广泛,mysql表或分表的数据达到一定量(也许是800w或者1000w..)这个时候非常需要再分表,简单的办法是直接写。下面学步园小编来讲解下MySQL存储过程有哪些?

  MySQL存储过程有哪些

  --假设根据user_id分表,分成64张

  insertintotable_new_0000select*fromtable_oldwheremod(user_id,64)=0;insertintotable_new_0001select*fromtable_oldwheremod(user_id,64)=1;...

  一共64条sql,OK搞定。但是这个一张表被全表扫描了64次,做的无用功比较多,而且导致停机时间比较长。

  虽然MySQL存储过程不是很熟,稍稍学习了下写了两个脚本,一个全量+一个增量脚本完成表的拆分。

  线上库也实践了下,8个分表,每个分表1000W记录拆分到64个分表。

  全量时间150分钟,全量的时候几个分表可以一起跑,我是同时跑3个分表

  增量时间每个分表4分钟4个一起跑,一共是8分钟搞定。这样停机时间加上应用的发布一共只需要20分钟就可以搞定了。

  附脚本:

  ###################

  delimeter//

  -----------

  ---全量脚本:

  CREATEPROCEDUREsp_xf_move_item()begindeclarev_exitintdefault0;declarev_spidbigint;declarev_idbigint;declareiintdefault0;declarec_tableint;

  --定义游标(要分拆的表,定义一个数量的截止时间)

  declarec_idscursorforselectid,user_idfromitem_records_0000wheregmt_modified<'2010-8-2500:00:00';declarecontinuehandlerfornotfoundsetv_exit=1;openc_ids;repeat   --将需要的值装入变量   fetchc_idsintov_id,v_spid;ifv_exit=0thenset@vv_id=v_id;   --根据取模字段获取数据存在的表   selectmod(v_spid,64)intoc_table;   --组装动态sql   SET@SQL_CONTEXT=CONCAT('insertintoitem_record_',LPAD(c_table,4,0),'select*fromitem_records_0000whereid=');PREPARESTMTFROM@SQL_CONTEXT;--执行sqlEXECUTESTMTusing@vv_id;DEALLOCATEPREPARESTMT;endif;setii=i+1;   --100条提交一次,以提高效率,记得执行存储过程前设置auto_commit   ifmod(i,100)=0thencommit;endif;untilv_exit=1endrepeat;closec_ids;commit;end;//-----------setauto_commit=0;callsp_xf_move_item();####增量脚本######CREATEPROCEDUREsp_xf_add_item()begindeclarev_exitintdefault0;declarev_spidbigint;declarev_idbigint;declareiintdefault0;declarec_tableint;declarec_idscursorforselectid,supplier_idfromitem_records_0000wheregmt_modified>='2010-8-2500:00:00';declarecontinuehandlerfornotfoundsetv_exit=1;openc_ids;repeatfetchc_idsintov_id,v_spid;ifv_exit=0thenset@vv_id=v_id;set@v_row=0;selectmod(v_spid,64)intoc_table;

  --判断数据是否已经存在

  SET@SQL_C=CONCAT('selectcount(*)into@v_rowfromitem_record_',LPAD(c_table,4,0),'whereid=');PREPARESTMT_CFROM@SQL_C;EXECUTESTMT_Cusing@vv_id;DEALLOCATEPREPARESTMT_C;SET@SQL_INSERT=CONCAT('insertintobbc_item_record_',LPAD(c_table,4,0),'select*fromitem_records_0000whereid=');PREPARESTMT_IFROM@SQL_INSERT;SET@SQL_DELETE=CONCAT('DELETEFROMbbc_item_record_',LPAD(c_table,4,0),'whereid=');PREPARESTMT_DFROM@SQL_DELETE;

  --如果数据已经存在,则先delete在insert

  if@v_row>0thenEXECUTESTMT_Dusing@vv_id;DEALLOCATEPREPARESTMT_D;endif;EXECUTESTMT_Iusing@vv_id;DEALLOCATEPREPARESTMT_I;endif;setii=i+1;ifmod(i,100)=0thencommit;endif;untilv_exit=1endrepeat;closec_ids;commit;end;//-------

  如果全量和增量之间的时间拖的比较长,那么可以设置时间,多做几次增量已缩短最后的停机时间,你懂的。。。

  callsp_xf_add_item()//

  以上就是关于“MySQL存储过程有哪些”的内容,希望对大家有用。更多资讯请关注学步园。学步园,您学习IT技术的优质平台!

抱歉!评论已关闭.