mysql+mybatis实现存储过程+事务 + 多并发流水号获取

小雨敲窗y

数据库存储过程

1. DROP PROCEDURE IF EXISTS `generate_serial_number_by_date`;
   
2. CREATE PROCEDURE `generate_serial_number_by_date`(
   
3.     IN param_key varchar(100),
   
4.     IN param_org_id bigint,
   
5.     IN param_period_date_format varchar(20),
   
6.       OUT result bigint,
   
7.     OUT current_datestr varchar(20))
   
8. begin
   
9. 
   
10.         declare old_datestr varchar(20);
    
11.         
    
12.         START TRANSACTION;
    
13. 
    
14.         if param_period_date_format='infinite' then
    
15.             set current_datestr = '00000000';
    
16.     else
    
17.             set current_datestr = DATE_FORMAT(NOW(), param_period_date_format);
    
18.         end if;
    
19.         
    
20.         select
    
21.                     number, datestr
    
22.         from sys_serial_number
    
23.         where table_key = param_key
    
24.                 and org_id = param_org_id
    
25.                 and period_date_format = param_period_date_format
    
26.                 into result, old_datestr
    
27.                 for update;
    
28. 
    
29.         IF result is null then
    
30.             
    
31.             set result = 1;
    
32.             
    
33.             insert into sys_serial_number(table_key, org_id, period_date_format, datestr, number, description)
    
34.                 values(param_key, param_org_id, param_period_date_format, current_datestr, 1, 'add by procedure');
    
35.         
    
36.         elseif old_datestr != current_datestr then
    
37.             
    
38.             set result = 1;
    
39.             
    
40.             update sys_serial_number
    
41.                     set number = 1,   
    
42.                             datestr = current_datestr
    
43.             where table_key = param_key
    
44.                     and org_id = param_org_id
    
45.                     and period_date_format = param_period_date_format;
    
46.             
    
47.         end if;
    
48.         
    
49.         update sys_serial_number set number = number + 1
    
50.             where table_key = param_key
    
51.                 and org_id = param_org_id
    
52.                 and period_date_format = param_period_date_format;
    
53.     commit;
    
54. end

复制代码

流水号表

1. DROP TABLE IF EXISTS `sys_serial_number`;
   
2. CREATE TABLE `sys_serial_number` (
   
3.   `table_key` varchar(100) NOT NULL COMMENT '主键（建议用表名）',
   
4.   `org_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '分公司ID',
   
5.   `number` bigint(20) NOT NULL DEFAULT '1' COMMENT '流水号（存储过程控制递增，获取完后+1）',
   
6.   `period_date_format` varchar(20) NOT NULL COMMENT '流水号生成周期日期格式',
   
7.   `datestr` varchar(20) DEFAULT NULL COMMENT '流水号日期值',
   
8.   `description` varchar(100) DEFAULT NULL COMMENT '描述',
   
9.   PRIMARY KEY (`table_key`,`org_id`,`period_date_format`)
   
10. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='流水号生成表';

复制代码

mybatis配置

1. <select id="generateSerialNumber" parameterType="java.util.HashMap" statementType="CALLABLE">
   
2.     <![CDATA[
   
3.            {
   
4.            call generate_serial_number (
   
5.             #{param_key,mode=IN,jdbcType=VARCHAR},
   
6.             #{param_org_id,mode=IN,jdbcType=BIGINT},
   
7.             #{result,mode=OUT,jdbcType=BIGINT}
   
8.             )
   
9.            }
   
10.        ]]>
    
11.   </select>

复制代码

测试代码

1. @Override
   
2.     public Map<String, Object> generateSerialNumber(Map<String, Object> param) {
   
3.         sysSerialNumberMapper.generateSerialNumber(param);
   
4.         return param;
   
5.     }

复制代码

1. final Map<String, Object> param = new HashMap<String, Object>();
   
2.         param.put("param_key","contract");
   
3.         param.put("param_orgId", 84);
   
4.         new Thread(new Runnable() {
   
5.             @Override
   
6.             public void run() {
   
7.                 for(int i =0; i<100; i++) {
   
8.                     Map<String, Object> map = serialNumberProvider.generateSerialNumber(param);
   
9.                     System.out.println("thread-1：" + map.get("result"));
   
10.                 }
    
11.             }
    
12.         }).start();
    
13. 
    
14.         new Thread(new Runnable() {
    
15.             @Override
    
16.             public void run() {
    
17.                 for(int i =0; i<100; i++) {
    
18.                     Map<String, Object> map = serialNumberProvider.generateSerialNumber(param);
    
19.                     System.out.println("thread-2：" + map.get("result"));
    
20.                 }
    
21.             }
    
22.         }).start();
    
23. 
    
24.         new Thread(new Runnable() {
    
25.             @Override
    
26.             public void run() {
    
27.                 for(int i =0; i<100; i++) {
    
28.                     Map<String, Object> map = serialNumberProvider.generateSerialNumber(param);
    
29.                     System.out.println("thread-3：" + map.get("result"));
    
30.                 }
    
31.             }
    
32.         }).start();
    
33. 
    
34.         byte[] b = new byte[0];
    
35.         synchronized(b) {
    
36.             b.wait();
    
37.         }

复制代码

如果运行代码报以下错误

1. ### SQL: {            call generate_serial_number_by_date (             ?,             ?,             ?,             ?,             ?            )            }### Cause: java.sql.SQLException: Parameter number 4 is not an OUT parameter; SQL []; Parameter number 4 is not an OUT parameter; nested exception is java.sql.SQLException: Parameter number 4 is not an OUT parameter

复制代码

排查方法：
1、检查存储过程是否正确创建
2、检查数据源连接用户是否有存储过程执行权限
到此这篇关于mysql+mybatis实现存储过程+事务 + 多并发流水号获取的文章就介绍到这了,更多相关mysql mybatis存储过程流水号内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
                                                        
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！