Chinaunix首页 | 论坛 | 博客

厚德载物peng.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

chengxiaopeng

  • 博客访问： 2538717
  • 博文数量： 308
  • 博客积分： 5547
  • 博客等级： 大校
  • 技术积分： 3782
  • 用 户 组： 普通用户
  • 注册时间： 2009-11-24 09:47
个人简介

hello world.

文章分类

全部博文（308）

最近访客
推荐博文
相关博文
SqlServer数据库，并发运行，获取唯一流水号

分类： SQLServer

2014-08-18 00:10:49

    当我们设计系统时，特别是涉及到主从表的时候，一般都会碰到从表的ID,要和主表的ID一致的情况。还有单据的流水号问题，要保证在并发请求时，流水号不能重复的现象。网上也有很多解决类似问题的代码，参照网上的方法，结合自己的理解，在SqlServer 2005下，设计相关的表，存储过程，实现这样的功能。
    我将一个流水号，分为四部分：头部、中间1、中间2，尾部。其中四部分类型，分成三种类型，固定值(fixed),日期类型（yyyyMMdd... ...）,流水类型(sync)。
    固定值类型，值保持不变；日期类型，根据格式不同，值也就相应的不同；流水类型很容易理解，就是从1一直递增下去。
    其中流水号的中间1，中间2，部分。是为了处理以下的这种情况设计的。比如说，当天的流水号从1，第二天又要从1进行。如果想要这样的流水号，则将中间1类型设置为日期类型，中间2类型设置为流水类型即可。
    另外流水的四部分，中的每个部分，还有长度的定义，该长度用于当该部分为流水类型时，可以设置流水号的长度，不够长度则前面补充0；
     表设计如下：

点击(此处)折叠或打开

  1. /****** 对象: Table [dbo].[sys_sequence_info] 脚本日期: 08/17/2014 23:47:10 ******/
  2. SET ANSI_NULLS ON
  3. GO
  4. SET QUOTED_IDENTIFIER ON
  5. GO
  6. SET ANSI_PADDING ON
  7. GO
  8. CREATE TABLE [dbo].[sys_sequence_info](
  9.     [sync_id] [decimal](8, 0) NOT NULL,
  10.     [sync_code] [varchar](200) COLLATE Chinese_PRC_CI_AS NOT NULL,
  11.     [sync_name] [varchar](200) COLLATE Chinese_PRC_CI_AS NULL,
  12.     [sync_value] [varchar](400) COLLATE Chinese_PRC_CI_AS NULL,
  13.     [sync_head_type] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  14.     [sync_head_value] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  15.     [sync_head_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___07F6335A] DEFAULT ((0)),
  16.     [sync_middle_type1] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  17.     [sync_middle_value1] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  18.     [sync_middle1_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___09DE7BCC] DEFAULT ((0)),
  19.     [sync_middle_type2] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  20.     [sync_middle_value2] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  21.     [sync_middle2_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___0BC6C43E] DEFAULT ((0)),
  22.     [sync_end_type] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  23.     [sync_end_value] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  24.     [sync_end_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___0DAF0CB0] DEFAULT ((0)),
  25.     [sync_split_value] [varchar](10) COLLATE Chinese_PRC_CI_AS NULL,
  26.     [sync_update_time] [datetime] NULL,
  27.     [sync_ctrl] [varchar](1) COLLATE Chinese_PRC_CI_AS NULL,
  28.     [row_id] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  29.     [sync_remark] [varchar](500) COLLATE Chinese_PRC_CI_AS NULL,
  30.  CONSTRAINT [PK_SYS_SEQUENCE_INFO] PRIMARY KEY CLUSTERED
  31. (
  32.     [sync_id] ASC
  33. )WITH (IGNORE_DUP_KEY = OFF) ON [PRIMARY]
  34. ) ON [PRIMARY]

  36. GO
  37. SET ANSI_PADDING OFF
  38. GO
  39. EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'当配置类为sync时，此字段记录流水的长度，如果长度不够，前面补充''0''' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info', @level2type=N'COLUMN', @level2name=N'sync_head_len'

  41. GO
  42. EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'当配置类为sync时，此字段记录流水的长度，如果长度不够，前面补充''0''' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info', @level2type=N'COLUMN', @level2name=N'sync_middle1_len'

  44. GO
  45. EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'当sync_middle_type1为日期类型，而sync_middle_type2为sync类型时，则sync_middle_value2值为当天的序列号' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info', @level2type=N'COLUMN', @level2name=N'sync_middle_type2'

  47. GO
  48. EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'当配置类为sync时，此字段记录流水的长度，如果长度不够，前面补充''0''' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info', @level2type=N'COLUMN', @level2name=N'sync_middle2_len'

  50. GO
  51. EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'当配置类为sync时，此字段记录流水的长度，如果长度不够，前面补充''0''' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info', @level2type=N'COLUMN', @level2name=N'sync_end_len'

  53. GO
  54. EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'流水信息表，方便生成流水编码。' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info'

  56. GO
  57. USE [my_jxc]
  58. GO
  59. ALTER TABLE [dbo].[sys_sequence_info] WITH CHECK ADD CONSTRAINT [CKC_SYNC_END_TYPE_SYS_SEQU] CHECK (([sync_end_type] IS NULL OR ([sync_end_type]='sync' OR [sync_end_type]='yyMMdd' OR [sync_end_type]='yy-MM-dd' OR [sync_end_type]='yyyyMMdd' OR [sync_end_type]='yyyy-MM-dd' OR [sync_end_type]='yyMM' OR [sync_end_type]='yy-MM' OR [sync_end_type]='yyyyMM' OR [sync_end_type]='yyyy-MM' OR [sync_end_type]='fixed')))
  60. GO
  61. ALTER TABLE [dbo].[sys_sequence_info] WITH CHECK ADD CONSTRAINT [CKC_SYNC_HEAD_TYPE_SYS_SEQU] CHECK (([sync_head_type] IS NULL OR ([sync_head_type]='sync' OR [sync_head_type]='yyMMdd' OR [sync_head_type]='yy-MM-dd' OR [sync_head_type]='yyyyMMdd' OR [sync_head_type]='yyyy-MM-dd' OR [sync_head_type]='yyMM' OR [sync_head_type]='yy-MM' OR [sync_head_type]='yyyyMM' OR [sync_head_type]='yyyy-MM' OR [sync_head_type]='fixed')))
  62. GO
  63. ALTER TABLE [dbo].[sys_sequence_info] WITH CHECK ADD CONSTRAINT [CKC_SYNC_MIDDLE_TYPE1_SYS_SEQU] CHECK (([sync_middle_type1] IS NULL OR ([sync_middle_type1]='sync' OR [sync_middle_type1]='yyMMdd' OR [sync_middle_type1]='yy-MM-dd' OR [sync_middle_type1]='yyyyMMdd' OR [sync_middle_type1]='yyyy-MM-dd' OR [sync_middle_type1]='yyMM' OR [sync_middle_type1]='yy-MM' OR [sync_middle_type1]='yyyyMM' OR [sync_middle_type1]='yyyy-MM' OR [sync_middle_type1]='fixed')))
  64. GO
  65. ALTER TABLE [dbo].[sys_sequence_info] WITH CHECK ADD CONSTRAINT [CKC_SYNC_MIDDLE_TYPE2_SYS_SEQU] CHECK (([sync_middle_type2] IS NULL OR ([sync_middle_type2]='sync' OR [sync_middle_type2]='yyMMdd' OR [sync_middle_type2]='yy-MM-dd' OR [sync_middle_type2]='yyyyMMdd' OR [sync_middle_type2]='yyyy-MM-dd' OR [sync_middle_type2]='yyMM' OR [sync_middle_type2]='yy-MM' OR [sync_middle_type2]='yyyyMM' OR [sync_middle_type2]='yyyy-MM' OR [sync_middle_type2]='fixed')))
  66. GO
    而，如果想在并行环境下，获取唯一的流水号，经过思考，采用存储过程完成。
    其原理是：当一个请求过来时，先使用一个guid,判断流水表的数据字段sync_ctrl是否被预占（0：未预占，1：已预占）；如果没有被预占，则当前请求，进行预占操作。然后计算流水号。计算完毕后，将预占位取消。将流水号返回。具体请参考存储过程：P_SeqStr
    相关代码如下：

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO

  6. --获取当前日期的格式化字符串
  7. --author:程晓鹏
  8. --date:2014.8.3
  9. CREATE function [dbo].[FormatDate](@dateType varchar(20))
  10. returns varchar(50)
  11. as
  12. begin;
  13.   declare @result varchar(50); --定义返回值
  14.   declare @strYY varchar(4); --年份yyyy
  15.   declare @strYY2 varchar(2); --年份yy
  16.   declare @strMM varchar(2); --月份MM
  17.   declare @strDD varchar(2); --天数dd
  18.   declare @strDateType varchar(20);
  19.   
  20.   set @strDateType = upper(@dateType); --全部变为大写，进行判断
  21.   set @strYY = dbo.TrimString(year(getdate())); --4位数字的年份字符串
  22.   set @strYY2 = substring(@strYY, 3, 2); --4为年份数字的最后两位
  23.   set @strMM = dbo.FormatString(dbo.TrimString(month(getdate())), 'H', '0', 2); --月份两位数据
  24.   set @strDD = dbo.FormatString(dbo.TrimString(day(getdate())), 'H', '0', 2); --日，两位数表示
  25.   set @result = '';
  26.   
  27.   --根据入参，进行返回值的赋值
  28.   if (@strDateType = 'YYYYMMDD')
  29.     begin;
  30.       set @result = @strYY + @strMM + @strDD;
  31.     end;
  32.   else if (@strDateType = 'YYYY-MM-DD')
  33.     begin;
  34.       set @result = @strYY + '-' + @strMM + '-' + @strDD;
  35.     end;
  36.   else if (@strDateType = 'YYMMDD')
  37.     begin;
  38.       set @result = @strYY2 + @strMM + @strDD;
  39.     end;
  40.   else if (@strDateType = 'YY-MM-DD')
  41.     begin;
  42.       set @result = @strYY2 + '-' + @strMM + '-' + @strDD;
  43.     end;
  44.   else if (@strDateType = 'YYMM')
  45.     begin;
  46.       set @result = @strYY2 + @strMM;
  47.     end;
  48.   else if (@strDateType = 'YY-MM')
  49.     begin;
  50.       set @result = @strYY2 + '-' + @strMM;
  51.     end;
  52.   else if (@strDateType = 'YYYYMM')
  53.     begin;
  54.       set @result = @strYY + @strMM;
  55.     end;
  56.   else if (@strDateType = 'YYYY-MM')
  57.     begin;
  58.       set @result = @strYY + '-' + @strMM;
  59.     end;
  60.   else if (@strDateType = 'YYYY')
  61.     begin;
  62.       set @result = @strYY;
  63.     end;
  64.   else if (@strDateType = 'YY')
  65.     begin;
  66.       set @result = @strYY2;
  67.     end;
  68.   else
  69.     begin;
  70.       set @result = @strYY + '-' + @strMM + '-' + @strDD; --默认值
  71.     end;
  72.  
  73.   return @result; --返回结果
  74. end;

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO

  6. --格式化字符串，如果原字符串str长度，没有达到入参length，规定的长度，则使用fileChar，进行字符填充。
  7. --其中填充位置fillPosition如果为'H',则在原字符串前；若为'E',则在原字符串后。
  8. --author:程晓鹏
  9. --date:2014.8.3
  10. CREATE function [dbo].[FormatString](
  11.   @str varchar(8000), --原始字符串
  12.   @fillPosition varchar(1), --填充位置;H:在原字符串前面；E:在原字符串的后面
  13.   @fillChar varchar(1), --填充的字符串
  14.   @length int --返回结果的字符串长度
  15. )
  16. returns varchar(8000)
  17. as
  18. begin;
  19.   declare @result varchar(8000); --定义返回值
  20.   declare @strFillTmp varchar(8000); --临时填充字符串
  21.   declare @strFileTmpLen int; --临时填充的长度
  22.   declare @strLen int; --输入字符串的长度
  23.   declare @strFillChar varchar(1); --填充字符
  24.   declare @i int; --循环变量
  25.   
  26.   set @strFillChar = ''; --设置默认填充字符为空格
  27.   set @strFillTmp = ''; --临时填充字符串,默认为空
  28.   set @strLen = len(@str);
  29.   set @i = 0;
  30.   
  31.   --判断入参,设置填充字符
  32.   if(len(@fillChar) > 0)
  33.     begin;
  34.       set @strFillChar = @fillChar;
  35.     end;
  36.   else
  37.     begin;
  38.        set @strFillChar = ' ';
  39.     end;
  40.   
  41.   --判断是否需要进行字符串填充
  42.   if(@strLen < @length)
  43.     begin;
  44.       set @strFileTmpLen = @length - @strLen; --计算差异的长度
  45.       while(@i < @strFileTmpLen)
  46.       begin;
  47.         set @strFillTmp = @strFillTmp + @strFillChar; --进行差异字符串填充
  48.         set @i = @i + 1;
  49.       end;
  50.     end;
  51.   else
  52.     begin;
  53.       set @result = @str;
  54.     end;

  56.   --根据填充的位置,进行返回字符串的处理
  57.   if(@fillPosition = 'H')
  58.     begin;
  59.       set @result = @strFillTmp + @str;
  60.     end;
  61.   else if(@fillPosition = 'E')
  62.     begin;
  63.       set @result = @str + @strFillTmp
  64.     end;
  65.   
  66.   --返回结果
  67.   return @result;
  68. end;

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO

  6. --删除字符串左右两侧的空格
  7. --author:程晓鹏
  8. --date:2014.8.3
  9. create function [dbo].[TrimString](@str varchar(8000))
  10. returns varchar(8000)
  11. as
  12. begin;
  13.   declare @result varchar(8000); --定义返回值
  14.   set @result = ltrim(rtrim(@str));

  16.   return @result;
  17. end;

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO
  5. --判断类型是否是日期类型参数
  6. --author:程晓鹏
  7. --date:2014.8.11
  8. create function [dbo].[ValidDate](@strType varchar(20))
  9. returns varchar(1)
  10. as
  11. begin;
  12.   declare @result varchar(1); --定义返回值
  13.   declare @strDateType varchar(20);
  14.   
  15.   set @strDateType = upper(@strType); --全部变为大写，进行判断
  16.   set @result = '0';
  17.   
  18.   --根据入参，进行返回值的赋值
  19.   if (@strDateType = 'YYYYMMDD')
  20.     begin;
  21.       set @result = '1';
  22.     end;
  23.   else if (@strDateType = 'YYYY-MM-DD')
  24.     begin;
  25.       set @result = '1';
  26.     end;
  27.   else if (@strDateType = 'YYMMDD')
  28.     begin;
  29.       set @result = '1';
  30.     end;
  31.   else if (@strDateType = 'YY-MM-DD')
  32.     begin;
  33.       set @result = '1';
  34.     end;
  35.   else if (@strDateType = 'YYMM')
  36.     begin;
  37.       set @result = '1';
  38.     end;
  39.   else if (@strDateType = 'YY-MM')
  40.     begin;
  41.       set @result = '1';
  42.     end;
  43.   else if (@strDateType = 'YYYYMM')
  44.     begin;
  45.       set @result = '1';
  46.     end;
  47.   else if (@strDateType = 'YYYY-MM')
  48.     begin;
  49.       set @result = '1';
  50.     end;
  51.   else if (@strDateType = 'YYYY')
  52.     begin;
  53.       set @result = '1';
  54.     end;
  55.   else if (@strDateType = 'YY')
  56.     begin;
  57.       set @result = '1';
  58.     end;
  59.   else
  60.     begin;
  61.       set @result = '0'; --默认值
  62.     end;
  63.  
  64.   return @result; --返回结果
  65. end;

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO

  6. --获取流水号
  7. --author:程晓鹏
  8. --date:2014.8.14
  9. CREATE proc [dbo].[P_SeqStr](@syncCode varchar(200), @result varchar(400) output)
  10. as
  11. begin;
  12.   --开始事务
  13.   set xact_abort on;
  14.   begin transaction;

  16.   --以下定义的是查询后，各个字段的值
  17.   declare @strHeadType varchar(50);
  18.   declare @strHeadValue varchar(50);
  19.   declare @intHeadLen numeric(2,0);
  20.   
  21.   declare @strMiddleType1 varchar(50);
  22.   declare @strMiddleValue1 varchar(50);
  23.   declare @strMiddleValue1_new varchar(50);
  24.   declare @intMiddleLen1 numeric(2,0);
  25.   
  26.   declare @strMiddleType2 varchar(50);
  27.   declare @strMiddleValue2 varchar(50);
  28.   declare @intMiddleLen2 numeric(2,0);
  29.   
  30.   declare @strEndType varchar(50);
  31.   declare @strEndValue varchar(50);
  32.   declare @intEndLen numeric(2,0);
  33.   
  34.   declare @strSplitValue varchar(10);
  35.   declare @updateTime datetime;

  37.   --最终结果各个节点的数据值
  38.   declare @str_HeadValue varchar(50);
  39.   declare @str_MiddleValue1 varchar(50);
  40.   declare @str_MiddleValue2 varchar(50);
  41.   declare @str_EndValue varchar(50);

  43.   --定义行id,避免存储过程，并发执行，出现返回的流水重复的现象
  44.   declare @strNewID varchar(50);
  45.   declare @intCtrl int;

  47.   --设置返回值为空字符串
  48.   set @result = '';
  49.   set @strNewID = newid();
  50.   
  51.   --当sync_ctrl = '0',用当前的row_id，进行预占操作，这样可以防止并行运行造成流水重复现象
  52.   update dbo.sys_sequence_info set
  53.     row_id = @strNewID,
  54.     sync_ctrl = '1'
  55.   where sync_ctrl = '0' and sync_code = @syncCode;
  56.   commit;
  57.   
  58.   
  59.   --判断当前rowid，是否预占成功，如果没有预占成功，则返回1。否则继续执行，直到计算出流水ID
  60.   select @intCtrl = count(1)
  61.   from dbo.sys_sequence_info
  62.   where row_id = @strNewID and sync_code = @syncCode;

  64.   if (@intCtrl = 0) --当没有占用时，返回值1
  65.     begin;
  66.       return 1;
  67.     end;

  69.   --执行查询操作
  70.   select @strHeadType = upper(isnull(sync_head_type, 'fixed')),
  71.          @strHeadValue = isnull(sync_head_value, ''),
  72.          @intHeadLen = isnull(sync_head_len, 0),
  73.          @strMiddleType1 = upper(isnull(sync_middle_type1, 'fixed')),
  74.          @strMiddleValue1 = isnull(sync_middle_value1, ''),
  75.          @intMiddleLen1 = isnull(sync_middle1_len, 0),
  76.          @strMiddleType2 = upper(isnull(sync_middle_type2, 'fixed')),
  77.          @strMiddleValue2 = isnull(sync_middle_value2, ''),
  78.          @intMiddleLen2 = isnull(sync_middle2_len, 0),
  79.          @strEndType = upper(isnull(sync_end_type, 'fixed')),
  80.          @strEndValue = isnull(sync_end_value, ''),
  81.          @intEndLen = isnull(sync_end_len, 0),
  82.          @strSplitValue = isnull(sync_split_value, ''),
  83.          @updateTime = sync_update_time
  84.   from dbo.sys_sequence_info
  85.   where sync_ctrl = '1' and row_id =@strNewID and sync_code = @syncCode;

  87.   --对headType进行处理，当为日期类型时，将当前日期字符串进行赋值;
  88.   --若为sync类型时，则在原有值得基础上自增1
  89.   if (dbo.ValidDate(@strHeadType) = '1')
  90.     begin;
  91.       set @strHeadValue = dbo.FormatDate(@strHeadType);
  92.     end;
  93.   else if (@strHeadType = upper('sync'))
  94.     begin;
  95.       if (@strHeadValue = '')
  96.         begin;
  97.           set @strHeadValue = '1'; --当为空时，则值为'1'
  98.         end;
  99.       else
  100.         begin;
  101.          set @strHeadValue = convert(varchar, convert(int,@strHeadValue + 1));
  102.         end;
  103.     end;

  105.   --对MiddleType1进行处理，当为日期类型时，将当前日期字符串进行赋值;
  106.   --若为sync类型时，则在原有值得基础上自增1
  107.   if (dbo.ValidDate(@strMiddleType1) = '1')
  108.     begin;
  109.       set @strMiddleValue1_new = dbo.FormatDate(@strMiddleType1);
  110.     end;
  111.   else if (@strMiddleType1 = upper('sync'))
  112.     begin;
  113.       if (@strMiddleValue1 = '')
  114.         begin;
  115.           set @strMiddleValue1_new = '1'; --当为空时，则值为'1'
  116.         end;
  117.       else
  118.         begin;
  119.          set @strMiddleValue1_new = convert(varchar, convert(int,@strMiddleValue1 + 1));
  120.         end;
  121.     end;
  122.   else
  123.     begin;
  124.       set @strMiddleValue1_new = @strMiddleValue1;
  125.     end;

  127.   --对MiddleType2进行处理:
  128.   --当MiddleType1为日期类型，并且MiddleType2为sync类型时，则MiddleValue2的值为当前的流水号，流水号默认从1，进行累加计算
  129.   --若MiddleType2为日期类型时，将当前日期字符串进行赋值;
  130.   if (dbo.ValidDate(@strMiddleType1) = '1' and @strMiddleType2 = upper('sync'))
  131.     begin;
  132.       if (@strMiddleValue1 = dbo.FormatDate(@strMiddleType1))
  133.         begin;
  134.           set @strMiddleValue2 = convert(varchar, convert(int,@strMiddleValue2 + 1));
  135.         end;
  136.       else
  137.         begin;
  138.           set @strMiddleValue2 = '1'; --MiddleType1不是当天，则从'1',进行重新计数
  139.         end;
  140.     end;
  141.   else if (dbo.ValidDate(@strMiddleType2) = '1')
  142.     begin;
  143.       set @strMiddleValue2 = dbo.FormatDate(@strMiddleType2);
  144.     end;

  146.   --对EndType进行处理，当为日期类型时，将当前日期字符串进行赋值;
  147.   --若为sync类型时，则在原有值得基础上自增1
  148.   if (dbo.ValidDate(@strEndType) = '1')
  149.     begin;
  150.       set @strEndValue = dbo.FormatDate(@strEndType);
  151.     end;
  152.   else if (@strEndType = upper('sync'))
  153.     begin;
  154.       if (@strEndValue = '')
  155.         begin;
  156.           set @strEndValue = '1'; --当为空时，则值为'1'
  157.         end;
  158.       else
  159.         begin;
  160.          set @strEndValue = convert(varchar, convert(int,@strEndValue + 1));
  161.         end;
  162.     end;

  164.   --计算各个节点的返回值
  165.   --HeadType
  166.   if (@strHeadType = upper('sync'))
  167.     begin;
  168.       set @str_HeadValue = dbo.FormatString(@strHeadValue, 'H', '0', @intHeadLen);
  169.     end;
  170.   else if (len(@strHeadValue) > 0)
  171.     begin;
  172.       set @str_HeadValue = @strHeadValue;
  173.     end;
  174.   else
  175.     begin;
  176.       set @str_HeadValue = '';
  177.     end;

  179.   --MiddleType1
  180.   if (@strMiddleType1 = upper('sync'))
  181.     begin;
  182.       set @str_MiddleValue1 = dbo.FormatString(@strMiddleValue1_new, 'H', '0', @intMiddleLen1);
  183.     end;
  184.   else if (len(@strMiddleValue1) > 0)
  185.     begin;
  186.       set @str_MiddleValue1 = @strMiddleValue1_new;
  187.     end;
  188.   else
  189.     begin;
  190.       set @str_MiddleValue1 = '';
  191.     end;

  193.   --MiddleType2
  194.   if (@strMiddleType2 = upper('sync'))
  195.     begin;
  196.       set @str_MiddleValue2 = dbo.FormatString(@strMiddleValue2, 'H', '0', @intMiddleLen2);
  197.     end;
  198.   else if (len(@strMiddleValue2) > 0)
  199.     begin;
  200.       set @str_MiddleValue2 = @strMiddleValue2;
  201.     end;
  202.   else
  203.     begin;
  204.       set @str_MiddleValue2 = '';
  205.     end;

  207.   --EndType
  208.   if (@strEndType = upper('sync'))
  209.     begin;
  210.       set @str_EndValue = dbo.FormatString(@strEndValue, 'H', '0', @intEndLen);
  211.     end;
  212.   else if (len(@strEndValue) > 0)
  213.     begin;
  214.       set @str_EndValue = @strEndValue;
  215.     end;
  216.   else
  217.     begin;
  218.       set @str_EndValue = '';
  219.     end;

  221.   --计算，最后要返回的字符串
  222.   if (len(@str_HeadValue) > 0) --当HeadValue含有字符串时，添加进去
  223.     begin;
  224.       set @result = @result + @str_HeadValue;
  225.     end;

  227.   if (len(@str_MiddleValue1) > 0)
  228.     begin;
  229.        if (len(@str_HeadValue) > 0) --当HeadValue有数据时，添加分割字符串
  230.         begin;
  231.           set @result = @result + @strSplitValue;
  232.         end;
  233.        set @result = @result + @str_MiddleValue1;
  234.     end;

  236.   if (len(@str_MiddleValue2) > 0)
  237.     begin;
  238.       if (len(@str_MiddleValue1) > 0) --当MiddleValue1有数据时，添加分割符
  239.         begin;
  240.           set @result = @result + @strSplitValue;
  241.         end;
  242.       else if (len(@str_HeadValue) > 0) --当MiddleValue1为空，而HeadValue不为空，则添加分割字符串
  243.         begin;
  244.           set @result = @result + @strSplitValue;
  245.         end;
  246.       set @result = @result + @str_MiddleValue2;
  247.     end;

  249.   if(len(@str_EndValue) > 0)
  250.     begin;
  251.       if (len(@str_MiddleValue2) > 0) --当MiddleValue2有数据时，添加分割符
  252.         begin;
  253.           set @result = @result + @strSplitValue;
  254.         end;
  255.       else if (len(@str_HeadValue) > 0 or len(@str_MiddleValue1) > 0) --当MiddleValue2没有数据，而HeadValue或者MiddleValue有数据，则添加分割字符串
  256.         begin;
  257.           set @result = @result + @strSplitValue;
  258.         end;
  259.       set @result = @result + @str_EndValue;
  260.     end;

  262.   --更新数据库中的数据,为下次计算做准备
  263.   update dbo.sys_sequence_info set
  264.     sync_value = @result,
  265.     sync_head_value = @strHeadValue,
  266.     sync_middle_value1 = @strMiddleValue1_new,
  267.     sync_middle_value2 = @strMiddleValue2,
  268.     sync_end_value = @strEndValue,
  269.     sync_update_time = getdate(),
  270.     sync_ctrl = '0'
  271.   where sync_ctrl = '1' and row_id =@strNewID and sync_code = @syncCode;

  273.   return 0; --正常返回
  274.   commit transaction; --提交事务
  275. end;

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO

  6. --获取流水号
  7. --author:程晓鹏
  8. --date:2014.8.15
  9. CREATE proc [dbo].[P_Get_SeqStr](@syncCode varchar(200), @syncStr varchar(400) output)
  10. as
  11. begin;
  12.   declare @i int;
  13.   declare @p_return_value int; --定义存储过程返回值
  14.   declare @maxcount int; --定义获取流水号时，如果失败，重试的次数
  15.   declare @strResult varchar(400); --返回的字符串
  16.   declare @intCount int; --记录syncCode是否存在
  17.   
  18.   --状态值； 0：正常返回流水号；1:获取流水号超时；2:入参在配置流水表不存在
  19.   declare @state int;
  20.   set @state = 0;
  21.   set @i = 0;
  22.   set @maxcount = 500;
  23.   set @SyncStr = '';
  24.   set @strResult = ''; --要返回的字符串


  27.   --判断入参@syncCode，在数据库，是否配置的有
  28.   select @intCount = count(1)
  29.   from dbo.sys_sequence_info
  30.   where sync_code = @syncCode;

  32.   if (@intCount = 0) --当入参@syncCode，在数据库不存在时，返回值2
  33.     begin;
  34.       set @state = 2;
  35.       set @SyncStr = '错误:入参在配置表sys_sequence_info不存在。[@syncCode = ' + dbo.TrimString(@syncCode) + ']';
  36.       return @state;
  37.     end;

  39. while (@i<@maxcount)
  40.   begin;
  41.     EXEC @p_return_value = [dbo].[P_SeqStr]
  42.          @syncCode = @syncCode,
  43.          @result = @strResult OUTPUT;
  44.         set @i = @i + 1; --自加一
  45.         if (@p_return_value = 0)
  46.           begin;
  47.             set @state = 0;
  48.             set @syncStr = @strResult; --对返回的字符串进行赋值
  49.             break;
  50.           end;
  51.         else if (@i + 1 = @maxcount and @p_return_value = 1)
  52.           begin;
  53.             set @state = 1;
  54.             set @syncStr = '错误:获取流水号超时。[共尝试了' + dbo.TrimString(str(@maxcount)) + '次]';
  55.           end;
  56.   end;
  57.   return @state;
  58. end;
=========================================================
为了方便，进行并行执行，获取流水号的测试，可以创建如下的测试表，进行测试。

点击(此处)折叠或打开

  1. SET ANSI_NULLS ON
  2. GO
  3. SET QUOTED_IDENTIFIER ON
  4. GO
  5. SET ANSI_PADDING ON
  6. GO
  7. CREATE TABLE [dbo].[sync_test](
  8.     [id] [varchar](500) COLLATE Chinese_PRC_CI_AS NULL,
  9.     [user_name] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
  10.     [write_date] [datetime] NULL
  11. ) ON [PRIMARY]

  13. GO
测试脚本如下：

点击(此处)折叠或打开

  1. declare    @result varchar(400);
  2. declare @i int;
  3. declare @return_value int;
  4. set @i=0;
  5. while @i<10000
  6.   begin
  7.     EXEC @return_value = [dbo].[P_Get_SeqStr]
  8.         @syncCode = N'test_1',
  9.         @syncStr = @result OUTPUT;
  10.         if (@return_value = 0)
  11.         begin;
  12.           insert into sync_test(id,user_name, write_date) values(@result, 'test_2', getdate());
  13.           set @i=@i+1;
  14.         end;
  15.   end;
测试结果，截图如下：

完整的脚本文件如下：
SqlServer流水号管理.rar




阅读(9728) | 评论(0) | 转发(0) |
0

上一篇：文件切割

下一篇：shell与sqlplus的交互

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6