怎么生成流水号

怎么生成流水号,第1张

目前是在.net中使用的这个方法,使用sqlserver的时间戳来控制并发情况下容易产生重复序列号的问题。

原理类似hibernate的主键生成机制,在系统启动时从数据库中读出最大的流水号,赋给一个类的静态变量,需要时,从该静态变量中取得流水号,加1后,就是你要的值。

代码:

public class testA {

public static Long maxNo

static {

synchronized(maxNo){

maxNo = select max(maxNo) from DB

}

}

public synchronized static long getMaxNo(){

return(++maxNo)

}

}

优点:保证同步,不会取到相同的值,同时避免了数据库的反复读取。

缺点:在cluster环境下

还是用上面的方法,但是只能在一台机器上发布并且绑定到JNDI,别的机器可以通过配置文件得知去哪里产生maxNo(实际上,每台机器都可以发布,但是所有机器只能去访问指定的一台机器),这样的效率虽然低了点,但是还是觉得比每次去数据库里取好点。当然,可以改进,就是再加一个本地类,每次去JNDI那里的类去取数据时,一次取20个回来(就是JNDI上面的类一次要加20),以后本地就用这20个值,用完了,再去JNDI上面的类去取。

当然,前面的这两个例子都比较复杂,甚至还有人提出用单态的方法。而我在.net中用的就比较简单了。方法如下:

在数据库(sqlserver)中新建一张表(sequence_num),专门用来生成流水号。

字段1:s_id,varchar(50),notnull

字段2:tmstmp,timestamp,notnull

代码如下:

public string getOderid()

{

private SqlConnection conn = null

private SqlCommand comm = null

private string s_id = ""

private byte [] tmstmp//时间戳类型在.net中对应为一个byte数组

private int s_idplus = 0

private string orderid = ""

try

{

conn = SqlConn.getConn()

conn.Open()

do

{

string sqlQuery = "select s_id,tmstmp as tmstmp from sequence_num"

comm = conn.CreateCommand()

comm.CommandText = sqlQuery

SqlDataAdapter da = new SqlDataAdapter(comm)

DataTable dt = new DataTable()

dt.Clear()

da.Fill(dt)

comm.Parameters.Clear()

if (!dt.Rows[0]["s_id"].ToString().Substring(0,12).Equals(DateTime.Now.ToString("yyyyMMddHHmm")))//每一分钟重置一次计数,实际上我认为每天重置一次比较好

{

s_id = DateTime.Now.ToString("yyyyMMddHHmm")+"0001"

tmstmp = (byte[])dt.Rows[0]["tmstmp"]

}

else

{

s_id = dt.Rows[0]["s_id"].ToString()

tmstmp = (byte[])dt.Rows[0]["tmstmp"]

s_idplus = Convert.ToInt32(s_id.Substring(12)) + 1

s_id = s_id.Substring(0,12)+Convert.ToString(s_idplus).PadLeft(4,'0')

}

string sqlUpdate = "update sequence_num set s_id = @s_id where tmstmp = @tmstmp"//保证在记录未被修改的情况下更新,如果更新不成功,则重走一遍生成序列号的流程

comm.CommandText = sqlUpdate

comm.Parameters.Clear()

comm.Parameters.Add("@s_id",SqlDbType.VarChar,50)

comm.Parameters["@s_id"].Value = s_id

comm.Parameters.Add("@tmstmp",SqlDbType.Timestamp)

comm.Parameters["@tmstmp"].Value = tmstmp

}

while(comm.ExecuteNonQuery()<=0)

}

catch(SqlException ex)

{

string aaa = ex.Message

}

finally

{

if(conn!=null)

{

conn.Close()

}

}

return s_id

}

这个流程都是在.net里实现的,实际使用中可以通过存储过程来实现。当然,这种方法对数据库的访问会比较频繁,另外,数据库表建立的时候必须插入一条初始值,这是代码不完善的地方,有时间的话我会去完善它。只是判断如果表内没有记录的情况下就插入一条初始记录,这个时候如何处理并发问题还没想明白。

这个很简单的,首先你在数据库中查找到你的流水号的最大值

在后面加1

就是啦!select

max(id)

from

table

获取到你数据库中最大的ID

oracle数据库的话可以利用rownum取当前记录的顺序,然后赋值给流水号就可以了。

sqlserver可就没什么好办法了,只能alter table xxx add id nvarchar(10) indentity(1,1)了,然后再将id赋值流水号吧


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/6769905.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-03-28
下一篇 2023-03-28

发表评论

登录后才能评论

评论列表(0条)

保存