我将一个流水号,分为四部分:头部、中间1、中间2,尾部。其中四部分类型,分成三种类型,固定值(fixed),日期类型(yyyyMMdd... ...),流水类型(sync)。
固定值类型,值保持不变;日期类型,根据格式不同,值也就相应的不同;流水类型很容易理解,就是从1一直递增下去。
其中流水号的中间1,中间2,部分。是为了处理以下的这种情况设计的。比如说,当天的流水号从1,第二天又要从1进行。如果想要这样的流水号,则将中间1类型设置为日期类型,中间2类型设置为流水类型即可。
另外流水的四部分,中的每个部分,还有长度的定义,该长度用于当该部分为流水类型时,可以设置流水号的长度,不够长度则前面补充0;
表设计如下:
点击(此处)折叠或打开
- /****** 对象: Table [dbo].[sys_sequence_info] 脚本日期: 08/17/2014 23:47:10 ******/
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- SET ANSI_PADDING ON
- GO
- CREATE TABLE [dbo].[sys_sequence_info](
- [sync_id] [decimal](8, 0) NOT NULL,
- [sync_code] [varchar](200) COLLATE Chinese_PRC_CI_AS NOT NULL,
- [sync_name] [varchar](200) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_value] [varchar](400) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_head_type] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_head_value] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_head_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___07F6335A] DEFAULT ((0)),
- [sync_middle_type1] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_middle_value1] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_middle1_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___09DE7BCC] DEFAULT ((0)),
- [sync_middle_type2] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_middle_value2] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_middle2_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___0BC6C43E] DEFAULT ((0)),
- [sync_end_type] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_end_value] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_end_len] [numeric](2, 0) NULL CONSTRAINT [DF__sys_seque__sync___0DAF0CB0] DEFAULT ((0)),
- [sync_split_value] [varchar](10) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_update_time] [datetime] NULL,
- [sync_ctrl] [varchar](1) COLLATE Chinese_PRC_CI_AS NULL,
- [row_id] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [sync_remark] [varchar](500) COLLATE Chinese_PRC_CI_AS NULL,
- CONSTRAINT [PK_SYS_SEQUENCE_INFO] PRIMARY KEY CLUSTERED
- (
- [sync_id] ASC
- )WITH (IGNORE_DUP_KEY = OFF) ON [PRIMARY]
- ) ON [PRIMARY]
- GO
- SET ANSI_PADDING OFF
- GO
- 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'
- GO
- 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'
- GO
- 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'
- GO
- 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'
- GO
- 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'
- GO
- EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'流水信息表,方便生成流水编码。' ,@level0type=N'SCHEMA', @level0name=N'dbo', @level1type=N'TABLE', @level1name=N'sys_sequence_info'
- GO
- USE [my_jxc]
- GO
- 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')))
- GO
- 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')))
- GO
- 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')))
- GO
- 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')))
- GO
其原理是:当一个请求过来时,先使用一个guid,判断流水表的数据字段sync_ctrl是否被预占(0:未预占,1:已预占);如果没有被预占,则当前请求,进行预占操作。然后计算流水号。计算完毕后,将预占位取消。将流水号返回。具体请参考存储过程:P_SeqStr
相关代码如下:
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- --获取当前日期的格式化字符串
- --author:程晓鹏
- --date:2014.8.3
- CREATE function [dbo].[FormatDate](@dateType varchar(20))
- returns varchar(50)
- as
- begin;
- declare @result varchar(50); --定义返回值
- declare @strYY varchar(4); --年份yyyy
- declare @strYY2 varchar(2); --年份yy
- declare @strMM varchar(2); --月份MM
- declare @strDD varchar(2); --天数dd
- declare @strDateType varchar(20);
-
- set @strDateType = upper(@dateType); --全部变为大写,进行判断
- set @strYY = dbo.TrimString(year(getdate())); --4位数字的年份字符串
- set @strYY2 = substring(@strYY, 3, 2); --4为年份数字的最后两位
- set @strMM = dbo.FormatString(dbo.TrimString(month(getdate())), 'H', '0', 2); --月份两位数据
- set @strDD = dbo.FormatString(dbo.TrimString(day(getdate())), 'H', '0', 2); --日,两位数表示
- set @result = '';
-
- --根据入参,进行返回值的赋值
- if (@strDateType = 'YYYYMMDD')
- begin;
- set @result = @strYY + @strMM + @strDD;
- end;
- else if (@strDateType = 'YYYY-MM-DD')
- begin;
- set @result = @strYY + '-' + @strMM + '-' + @strDD;
- end;
- else if (@strDateType = 'YYMMDD')
- begin;
- set @result = @strYY2 + @strMM + @strDD;
- end;
- else if (@strDateType = 'YY-MM-DD')
- begin;
- set @result = @strYY2 + '-' + @strMM + '-' + @strDD;
- end;
- else if (@strDateType = 'YYMM')
- begin;
- set @result = @strYY2 + @strMM;
- end;
- else if (@strDateType = 'YY-MM')
- begin;
- set @result = @strYY2 + '-' + @strMM;
- end;
- else if (@strDateType = 'YYYYMM')
- begin;
- set @result = @strYY + @strMM;
- end;
- else if (@strDateType = 'YYYY-MM')
- begin;
- set @result = @strYY + '-' + @strMM;
- end;
- else if (@strDateType = 'YYYY')
- begin;
- set @result = @strYY;
- end;
- else if (@strDateType = 'YY')
- begin;
- set @result = @strYY2;
- end;
- else
- begin;
- set @result = @strYY + '-' + @strMM + '-' + @strDD; --默认值
- end;
-
- return @result; --返回结果
- end;
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- --格式化字符串,如果原字符串str长度,没有达到入参length,规定的长度,则使用fileChar,进行字符填充。
- --其中填充位置fillPosition如果为'H',则在原字符串前;若为'E',则在原字符串后。
- --author:程晓鹏
- --date:2014.8.3
- CREATE function [dbo].[FormatString](
- @str varchar(8000), --原始字符串
- @fillPosition varchar(1), --填充位置;H:在原字符串前面;E:在原字符串的后面
- @fillChar varchar(1), --填充的字符串
- @length int --返回结果的字符串长度
- )
- returns varchar(8000)
- as
- begin;
- declare @result varchar(8000); --定义返回值
- declare @strFillTmp varchar(8000); --临时填充字符串
- declare @strFileTmpLen int; --临时填充的长度
- declare @strLen int; --输入字符串的长度
- declare @strFillChar varchar(1); --填充字符
- declare @i int; --循环变量
-
- set @strFillChar = ''; --设置默认填充字符为空格
- set @strFillTmp = ''; --临时填充字符串,默认为空
- set @strLen = len(@str);
- set @i = 0;
-
- --判断入参,设置填充字符
- if(len(@fillChar) > 0)
- begin;
- set @strFillChar = @fillChar;
- end;
- else
- begin;
- set @strFillChar = ' ';
- end;
-
- --判断是否需要进行字符串填充
- if(@strLen < @length)
- begin;
- set @strFileTmpLen = @length - @strLen; --计算差异的长度
- while(@i < @strFileTmpLen)
- begin;
- set @strFillTmp = @strFillTmp + @strFillChar; --进行差异字符串填充
- set @i = @i + 1;
- end;
- end;
- else
- begin;
- set @result = @str;
- end;
- --根据填充的位置,进行返回字符串的处理
- if(@fillPosition = 'H')
- begin;
- set @result = @strFillTmp + @str;
- end;
- else if(@fillPosition = 'E')
- begin;
- set @result = @str + @strFillTmp
- end;
-
- --返回结果
- return @result;
- end;
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- --删除字符串左右两侧的空格
- --author:程晓鹏
- --date:2014.8.3
- create function [dbo].[TrimString](@str varchar(8000))
- returns varchar(8000)
- as
- begin;
- declare @result varchar(8000); --定义返回值
- set @result = ltrim(rtrim(@str));
- return @result;
- end;
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- --判断类型是否是日期类型参数
- --author:程晓鹏
- --date:2014.8.11
- create function [dbo].[ValidDate](@strType varchar(20))
- returns varchar(1)
- as
- begin;
- declare @result varchar(1); --定义返回值
- declare @strDateType varchar(20);
-
- set @strDateType = upper(@strType); --全部变为大写,进行判断
- set @result = '0';
-
- --根据入参,进行返回值的赋值
- if (@strDateType = 'YYYYMMDD')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YYYY-MM-DD')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YYMMDD')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YY-MM-DD')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YYMM')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YY-MM')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YYYYMM')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YYYY-MM')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YYYY')
- begin;
- set @result = '1';
- end;
- else if (@strDateType = 'YY')
- begin;
- set @result = '1';
- end;
- else
- begin;
- set @result = '0'; --默认值
- end;
-
- return @result; --返回结果
- end;
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- --获取流水号
- --author:程晓鹏
- --date:2014.8.14
- CREATE proc [dbo].[P_SeqStr](@syncCode varchar(200), @result varchar(400) output)
- as
- begin;
- --开始事务
- set xact_abort on;
- begin transaction;
- --以下定义的是查询后,各个字段的值
- declare @strHeadType varchar(50);
- declare @strHeadValue varchar(50);
- declare @intHeadLen numeric(2,0);
-
- declare @strMiddleType1 varchar(50);
- declare @strMiddleValue1 varchar(50);
- declare @strMiddleValue1_new varchar(50);
- declare @intMiddleLen1 numeric(2,0);
-
- declare @strMiddleType2 varchar(50);
- declare @strMiddleValue2 varchar(50);
- declare @intMiddleLen2 numeric(2,0);
-
- declare @strEndType varchar(50);
- declare @strEndValue varchar(50);
- declare @intEndLen numeric(2,0);
-
- declare @strSplitValue varchar(10);
- declare @updateTime datetime;
- --最终结果各个节点的数据值
- declare @str_HeadValue varchar(50);
- declare @str_MiddleValue1 varchar(50);
- declare @str_MiddleValue2 varchar(50);
- declare @str_EndValue varchar(50);
- --定义行id,避免存储过程,并发执行,出现返回的流水重复的现象
- declare @strNewID varchar(50);
- declare @intCtrl int;
- --设置返回值为空字符串
- set @result = '';
- set @strNewID = newid();
-
- --当sync_ctrl = '0',用当前的row_id,进行预占操作,这样可以防止并行运行造成流水重复现象
- update dbo.sys_sequence_info set
- row_id = @strNewID,
- sync_ctrl = '1'
- where sync_ctrl = '0' and sync_code = @syncCode;
- commit;
-
-
- --判断当前rowid,是否预占成功,如果没有预占成功,则返回1。否则继续执行,直到计算出流水ID
- select @intCtrl = count(1)
- from dbo.sys_sequence_info
- where row_id = @strNewID and sync_code = @syncCode;
- if (@intCtrl = 0) --当没有占用时,返回值1
- begin;
- return 1;
- end;
- --执行查询操作
- select @strHeadType = upper(isnull(sync_head_type, 'fixed')),
- @strHeadValue = isnull(sync_head_value, ''),
- @intHeadLen = isnull(sync_head_len, 0),
- @strMiddleType1 = upper(isnull(sync_middle_type1, 'fixed')),
- @strMiddleValue1 = isnull(sync_middle_value1, ''),
- @intMiddleLen1 = isnull(sync_middle1_len, 0),
- @strMiddleType2 = upper(isnull(sync_middle_type2, 'fixed')),
- @strMiddleValue2 = isnull(sync_middle_value2, ''),
- @intMiddleLen2 = isnull(sync_middle2_len, 0),
- @strEndType = upper(isnull(sync_end_type, 'fixed')),
- @strEndValue = isnull(sync_end_value, ''),
- @intEndLen = isnull(sync_end_len, 0),
- @strSplitValue = isnull(sync_split_value, ''),
- @updateTime = sync_update_time
- from dbo.sys_sequence_info
- where sync_ctrl = '1' and row_id =@strNewID and sync_code = @syncCode;
- --对headType进行处理,当为日期类型时,将当前日期字符串进行赋值;
- --若为sync类型时,则在原有值得基础上自增1
- if (dbo.ValidDate(@strHeadType) = '1')
- begin;
- set @strHeadValue = dbo.FormatDate(@strHeadType);
- end;
- else if (@strHeadType = upper('sync'))
- begin;
- if (@strHeadValue = '')
- begin;
- set @strHeadValue = '1'; --当为空时,则值为'1'
- end;
- else
- begin;
- set @strHeadValue = convert(varchar, convert(int,@strHeadValue + 1));
- end;
- end;
- --对MiddleType1进行处理,当为日期类型时,将当前日期字符串进行赋值;
- --若为sync类型时,则在原有值得基础上自增1
- if (dbo.ValidDate(@strMiddleType1) = '1')
- begin;
- set @strMiddleValue1_new = dbo.FormatDate(@strMiddleType1);
- end;
- else if (@strMiddleType1 = upper('sync'))
- begin;
- if (@strMiddleValue1 = '')
- begin;
- set @strMiddleValue1_new = '1'; --当为空时,则值为'1'
- end;
- else
- begin;
- set @strMiddleValue1_new = convert(varchar, convert(int,@strMiddleValue1 + 1));
- end;
- end;
- else
- begin;
- set @strMiddleValue1_new = @strMiddleValue1;
- end;
- --对MiddleType2进行处理:
- --当MiddleType1为日期类型,并且MiddleType2为sync类型时,则MiddleValue2的值为当前的流水号,流水号默认从1,进行累加计算
- --若MiddleType2为日期类型时,将当前日期字符串进行赋值;
- if (dbo.ValidDate(@strMiddleType1) = '1' and @strMiddleType2 = upper('sync'))
- begin;
- if (@strMiddleValue1 = dbo.FormatDate(@strMiddleType1))
- begin;
- set @strMiddleValue2 = convert(varchar, convert(int,@strMiddleValue2 + 1));
- end;
- else
- begin;
- set @strMiddleValue2 = '1'; --MiddleType1不是当天,则从'1',进行重新计数
- end;
- end;
- else if (dbo.ValidDate(@strMiddleType2) = '1')
- begin;
- set @strMiddleValue2 = dbo.FormatDate(@strMiddleType2);
- end;
- --对EndType进行处理,当为日期类型时,将当前日期字符串进行赋值;
- --若为sync类型时,则在原有值得基础上自增1
- if (dbo.ValidDate(@strEndType) = '1')
- begin;
- set @strEndValue = dbo.FormatDate(@strEndType);
- end;
- else if (@strEndType = upper('sync'))
- begin;
- if (@strEndValue = '')
- begin;
- set @strEndValue = '1'; --当为空时,则值为'1'
- end;
- else
- begin;
- set @strEndValue = convert(varchar, convert(int,@strEndValue + 1));
- end;
- end;
- --计算各个节点的返回值
- --HeadType
- if (@strHeadType = upper('sync'))
- begin;
- set @str_HeadValue = dbo.FormatString(@strHeadValue, 'H', '0', @intHeadLen);
- end;
- else if (len(@strHeadValue) > 0)
- begin;
- set @str_HeadValue = @strHeadValue;
- end;
- else
- begin;
- set @str_HeadValue = '';
- end;
- --MiddleType1
- if (@strMiddleType1 = upper('sync'))
- begin;
- set @str_MiddleValue1 = dbo.FormatString(@strMiddleValue1_new, 'H', '0', @intMiddleLen1);
- end;
- else if (len(@strMiddleValue1) > 0)
- begin;
- set @str_MiddleValue1 = @strMiddleValue1_new;
- end;
- else
- begin;
- set @str_MiddleValue1 = '';
- end;
- --MiddleType2
- if (@strMiddleType2 = upper('sync'))
- begin;
- set @str_MiddleValue2 = dbo.FormatString(@strMiddleValue2, 'H', '0', @intMiddleLen2);
- end;
- else if (len(@strMiddleValue2) > 0)
- begin;
- set @str_MiddleValue2 = @strMiddleValue2;
- end;
- else
- begin;
- set @str_MiddleValue2 = '';
- end;
- --EndType
- if (@strEndType = upper('sync'))
- begin;
- set @str_EndValue = dbo.FormatString(@strEndValue, 'H', '0', @intEndLen);
- end;
- else if (len(@strEndValue) > 0)
- begin;
- set @str_EndValue = @strEndValue;
- end;
- else
- begin;
- set @str_EndValue = '';
- end;
- --计算,最后要返回的字符串
- if (len(@str_HeadValue) > 0) --当HeadValue含有字符串时,添加进去
- begin;
- set @result = @result + @str_HeadValue;
- end;
- if (len(@str_MiddleValue1) > 0)
- begin;
- if (len(@str_HeadValue) > 0) --当HeadValue有数据时,添加分割字符串
- begin;
- set @result = @result + @strSplitValue;
- end;
- set @result = @result + @str_MiddleValue1;
- end;
- if (len(@str_MiddleValue2) > 0)
- begin;
- if (len(@str_MiddleValue1) > 0) --当MiddleValue1有数据时,添加分割符
- begin;
- set @result = @result + @strSplitValue;
- end;
- else if (len(@str_HeadValue) > 0) --当MiddleValue1为空,而HeadValue不为空,则添加分割字符串
- begin;
- set @result = @result + @strSplitValue;
- end;
- set @result = @result + @str_MiddleValue2;
- end;
- if(len(@str_EndValue) > 0)
- begin;
- if (len(@str_MiddleValue2) > 0) --当MiddleValue2有数据时,添加分割符
- begin;
- set @result = @result + @strSplitValue;
- end;
- else if (len(@str_HeadValue) > 0 or len(@str_MiddleValue1) > 0) --当MiddleValue2没有数据,而HeadValue或者MiddleValue有数据,则添加分割字符串
- begin;
- set @result = @result + @strSplitValue;
- end;
- set @result = @result + @str_EndValue;
- end;
- --更新数据库中的数据,为下次计算做准备
- update dbo.sys_sequence_info set
- sync_value = @result,
- sync_head_value = @strHeadValue,
- sync_middle_value1 = @strMiddleValue1_new,
- sync_middle_value2 = @strMiddleValue2,
- sync_end_value = @strEndValue,
- sync_update_time = getdate(),
- sync_ctrl = '0'
- where sync_ctrl = '1' and row_id =@strNewID and sync_code = @syncCode;
- return 0; --正常返回
- commit transaction; --提交事务
- end;
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- --获取流水号
- --author:程晓鹏
- --date:2014.8.15
- CREATE proc [dbo].[P_Get_SeqStr](@syncCode varchar(200), @syncStr varchar(400) output)
- as
- begin;
- declare @i int;
- declare @p_return_value int; --定义存储过程返回值
- declare @maxcount int; --定义获取流水号时,如果失败,重试的次数
- declare @strResult varchar(400); --返回的字符串
- declare @intCount int; --记录syncCode是否存在
-
- --状态值; 0:正常返回流水号;1:获取流水号超时;2:入参在配置流水表不存在
- declare @state int;
- set @state = 0;
- set @i = 0;
- set @maxcount = 500;
- set @SyncStr = '';
- set @strResult = ''; --要返回的字符串
- --判断入参@syncCode,在数据库,是否配置的有
- select @intCount = count(1)
- from dbo.sys_sequence_info
- where sync_code = @syncCode;
- if (@intCount = 0) --当入参@syncCode,在数据库不存在时,返回值2
- begin;
- set @state = 2;
- set @SyncStr = '错误:入参在配置表sys_sequence_info不存在。[@syncCode = ' + dbo.TrimString(@syncCode) + ']';
- return @state;
- end;
- while (@i<@maxcount)
- begin;
- EXEC @p_return_value = [dbo].[P_SeqStr]
- @syncCode = @syncCode,
- @result = @strResult OUTPUT;
- set @i = @i + 1; --自加一
- if (@p_return_value = 0)
- begin;
- set @state = 0;
- set @syncStr = @strResult; --对返回的字符串进行赋值
- break;
- end;
- else if (@i + 1 = @maxcount and @p_return_value = 1)
- begin;
- set @state = 1;
- set @syncStr = '错误:获取流水号超时。[共尝试了' + dbo.TrimString(str(@maxcount)) + '次]';
- end;
- end;
- return @state;
- end;
为了方便,进行并行执行,获取流水号的测试,可以创建如下的测试表,进行测试。
点击(此处)折叠或打开
- SET ANSI_NULLS ON
- GO
- SET QUOTED_IDENTIFIER ON
- GO
- SET ANSI_PADDING ON
- GO
- CREATE TABLE [dbo].[sync_test](
- [id] [varchar](500) COLLATE Chinese_PRC_CI_AS NULL,
- [user_name] [varchar](50) COLLATE Chinese_PRC_CI_AS NULL,
- [write_date] [datetime] NULL
- ) ON [PRIMARY]
- GO
点击(此处)折叠或打开
- declare @result varchar(400);
- declare @i int;
- declare @return_value int;
- set @i=0;
- while @i<10000
- begin
- EXEC @return_value = [dbo].[P_Get_SeqStr]
- @syncCode = N'test_1',
- @syncStr = @result OUTPUT;
- if (@return_value = 0)
- begin;
- insert into sync_test(id,user_name, write_date) values(@result, 'test_2', getdate());
- set @i=@i+1;
- end;
- end;
完整的脚本文件如下: