12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
ADADADADAD
mysql数据库 时间:2024-12-03 10:27:52
作者:文/会员上传
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
使用存储过程,在操作数据库时开启事务,避免并发时同时操作造成数据重复CREATE DEFINER=`root`@`localhost` PROCEDURE `GetSerialNo`(IN tsCode VARCHAR(50),OUT result VARCH
以下为本文的正文内容,内容仅供参考!本站为公益性网站,复制本文以及下载DOC文档全部免费。
使用存储过程,在操作数据库时开启事务,避免并发时同时操作造成数据重复
CREATE DEFINER=`root`@`localhost` PROCEDURE `GetSerialNo`(IN tsCode VARCHAR(50),OUT result VARCHAR(200) )BEGINDECLARE tsValue VARCHAR(50);DECLARE tdToday VARCHAR(20); DECLARE nowdate VARCHAR(20); DECLARE tsQZVARCHAR(50);DECLARE t_error INTEGER DEFAULT 0;DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;START TRANSACTION; /* UPDATE sys_sno SET sValue=sValue WHERE sCode=tsCode; */SELECT sValue INTO tsValue FROM sys_sno WHERE sCode=tsCode; SELECT sQz INTO tsQZ FROM sys_sno WHERE sCode=tsCode ;-- 因子表中没有记录,插入初始值IF tsValue IS NULL THENSELECT CONCAT(DATE_FORMAT(NOW(),'%y%m'),'0001') INTO tsValue;UPDATE sys_sno SET sValue=tsValue WHERE sCode=tsCode ;SELECT CONCAT(tsQZ,tsValue) INTO result; ELSESELECT SUBSTRING(tsValue,1,4) INTO tdToday;SELECT CONVERT(DATE_FORMAT(NOW(),'%y%m'),SIGNED) INTO nowdate; -- 判断年月是否需要更新 IF tdToday = nowdate THEN SET tsValue=CONVERT(tsValue,SIGNED) + 1;ELSE SELECT CONCAT(DATE_FORMAT(NOW(),'%y%m') ,'0001') INTO tsValue ;END IF;UPDATE sys_sno SET sValue =tsValue WHERE sCode=tsCode;SELECT CONCAT(tsQZ,tsValue) INTO result; END IF; IF t_error =1 THEN ROLLBACK; SET result = 'Error'; ELSE COMMIT; END IF; SELECT result ;END;daoInteger getFaultNo(Map<String, String> parameterMap);
xml
<update id="getFaultNo" parameterMap="getFaultMap" statementType="CALLABLE">CALL GetSerialNo(?,?) </update> <!--parameterMap.put("tsCode", 0);parameterMap.put("result", -1);--> <parameterMap type="java.util.Map" id="getFaultMap"><parameter property="tsCode" mode="IN" jdbcType="VARCHAR"/><parameter property="result" mode="OUT" jdbcType="VARCHAR"/> </parameterMap>
调用
Map<String, String> parameterMap = new HashMap<String, String>();parameterMap.put("tsCode", "a");parameterMap.put("result", "-1");faultMapper.getFaultNo(parameterMap);// insert 故障日志 (主表)if (!parameterMap.get("result").equals("-1") && !parameterMap.get("result").equals("Error")) { //成功} else { throw new RuntimeException();}
总结
以上所述是小编给大家介绍的mybatis+mysql 使用存储过程生成流水号的实现代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
11-20
11-19
11-20
11-20
11-20
11-19
11-20
11-20
11-19
11-20
11-19
11-19
11-19
11-19
11-19
11-19