mysql的存储过程、游标、事务实例详解

2023-09-27 04:34:07 43

DELIMITER$$ DROPPROCEDUREIFEXISTS`transferEmailTempData`$$ CREATEPROCEDUREtransferEmailTempData(INjobIdVARCHAR(24)) BEGIN DECLAREidvalVARCHAR(24)DEFAULT''; DECLAREtaskIdvalVARCHAR(24)DEFAULT''; DECLAREgroupIdvalVARCHAR(24)DEFAULT''; DECLAREemailvalVARCHAR(50)DEFAULT''; /*标识正式表是否存在一条相同数据，即：groupId、email相同*/ DECLAREinfoIdVARCHAR(24)DEFAULT''; /*标识事务错误*/ DECLAREerrINTDEFAULT0; /*达到一定数量就进行提交，计数器*/ DECLAREcountsINTDEFAULT0; /*标识是否回滚过*/ DECLAREisrollbackINTDEFAULT0; /*游标遍历时，作为判断是否遍历完全部记录的标记*/ DECLAREdoneINTEGERDEFAULT0; /*获取临时表该任务的数据*/ DECLAREcurCURSORFORSELECTid,taskId,groupId,emailFROM`t_email_data_temp`WHEREtaskId=jobId; /*根据群组id、email查询是否存在相同记录*/ DECLAREcur2CURSORFORSELECTidFROM`t_email_info`eWHEREe.`group_id`=groupIdvalANDe.`email_address`=emailval; /*出现错误，设置为1，只要发生异常就回滚*/ DECLARECONTINUEHANDLERFORSQLEXCEPTIONSETerr=1; /*声明当游标遍历完全部记录后将标志变量置成某个值*/ DECLARECONTINUEHANDLERFORNOTFOUND SETdone=1; /*开启事务*/ STARTTRANSACTION; /*打开游标*/ OPENcur; /*使用LOOP循环遍历*/ out_loop:LOOP /*将每一条结果对应的字段值赋值给变量*/ FETCHcurINTOidval,taskIdval,groupIdval,emailval; IFdone=1THEN LEAVEout_loop; ENDIF; /*打开第二个游标*/ OPENcur2; SETdone=0; FETCHcur2INTOinfoId; /*如果正式表不存在相同groupIdandemail记录，添加到正式表*/ IFdone=1THEN /*插入正式表*/ INSERTINTO`t_email_info`VALUES(idval,emailval,groupIdval,0,'',NOW(),'admin',NOW(),'admin'); /*删除临时数据*/ DELETEFROM`t_email_data_temp`WHEREid=idval; /*计数器，每1000条才提交*/ SETcounts=counts+1; /*发生异常，回滚*/ IFerr=1THEN SETisrollback=1; ROLLBACK; ELSE IFcounts=1000THEN COMMIT; /*达到1000条提交后，重置计数器*/ SETcounts=0; ENDIF; ENDIF; ELSE /*已经存在相同记录，则删除该记录*/ IFdone=0THEN DELETEFROM`t_email_data_temp`WHEREid=idval; ENDIF; ENDIF; FETCHcur2INTOinfoId; CLOSEcur2; /*控制外部的循环，该步骤不能缺少，否则只循环一次就结束了*/ SETdone=0; ENDLOOPout_loop; CLOSEcur; /*如果没有发生过回滚事件，则更新task状态*/ /*如果回滚过，不更新task状态，下次执行任务的时候，会再次将剩余没有提交的数据进行添加到正式表*/ IFisrollback=0THEN UPDATE`t_email_task`tSETt.`if_finish`=1WHEREt.`id`=jobId; ENDIF; END$$ DELIMITER;

mysql的存储过程、游标 、事务实例详解

热门推荐

随机推荐

mysql的存储过程、游标、事务实例详解