使用存儲(chǔ)過(guò)程，在操作數(shù)據(jù)庫(kù)時(shí)開(kāi)啟事務(wù)，避免并發(fā)時(shí)同時(shí)操作造成數(shù)據(jù)重復(fù)
CREATE DEFINER=`root`@`localhost` PROCEDURE `GetSerialNo`(IN tsCode VARCHAR(50),OUT result VARCHAR(200) )
BEGIN
DECLARE tsValue VARCHAR(50);
DECLARE tdToday VARCHAR(20);
DECLARE nowdate VARCHAR(20);
DECLARE tsQZ VARCHAR(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 ;
-- 因子表中沒(méi)有記錄，插入初始值
IF tsValue IS NULL THEN
SELECT CONCAT(DATE_FORMAT(NOW(),'%y%m'),'0001') INTO tsValue;
UPDATE sys_sno SET sValue=tsValue WHERE sCode=tsCode ;
SELECT CONCAT(tsQZ,tsValue) INTO result;
ELSE
SELECT 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;
dao
Integer getFaultNo(MapString, 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>
調(diào)用
MapString, String> parameterMap = new HashMapString, 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();
}
總結(jié)
以上所述是小編給大家介紹的mybatis+mysql 使用存儲(chǔ)過(guò)程生成流水號(hào)的實(shí)現(xiàn)代碼，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
您可能感興趣的文章:- oracle(plsql)生成流水號(hào)
- PHP獲取MySQL執(zhí)行sql語(yǔ)句的查詢(xún)時(shí)間方法
- ThinkPHP框架獲取最后一次執(zhí)行SQL語(yǔ)句及變量調(diào)試簡(jiǎn)單操作示例
- mysql 獲取今天、昨天0點(diǎn)時(shí)間戳的實(shí)例
- mysql 獲取昨天日期、今天日期、明天日期以及前一個(gè)小時(shí)和后一個(gè)小時(shí)的時(shí)間
- sql 流水號(hào)獲取代碼實(shí)例
