主页 > 知识库 > mybatis+mysql 使用存储过程生成流水号的实现代码

mybatis+mysql 使用存储过程生成流水号的实现代码

热门标签:服务外包 AI电销 网站排名优化 铁路电话系统 百度竞价排名 地方门户网站 呼叫中心市场需求 Linux服务器

使用存储过程,在操作数据库时开启事务,避免并发时同时操作造成数据重复

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 ; 
 -- 因子表中没有记录,插入初始值  
  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>

调用

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();
  }

总结

以上所述是小编给大家介绍的mybatis+mysql 使用存储过程生成流水号的实现代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

您可能感兴趣的文章:
  • oracle(plsql)生成流水号
  • PHP获取MySQL执行sql语句的查询时间方法
  • ThinkPHP框架获取最后一次执行SQL语句及变量调试简单操作示例
  • mysql 获取今天、昨天0点时间戳的实例
  • mysql 获取昨天日期、今天日期、明天日期以及前一个小时和后一个小时的时间
  • sql 流水号获取代码实例

标签:湘潭 湖南 铜川 黄山 仙桃 崇左 衡水 兰州

巨人网络通讯声明:本文标题《mybatis+mysql 使用存储过程生成流水号的实现代码》,本文关键词  ;如发现本文内容存在版权问题,烦请提供相关信息告之我们,我们将及时沟通与处理。本站内容系统采集于网络,涉及言论、版权与本站无关。
  • 相关文章
  • 收缩
    • 微信客服
    • 微信二维码
    • 电话咨询

    • 400-1100-266