在ASP.NET程序中创建唯一序号
2007-09-28 21:53:49   来源:   评论:0 点击:

如果在程序中需要创建全局唯一的序号,那么必须对创建序号的过程进行同步处理,防止多个并发访问时出现相同序号的情况。下面列出几种方法供大家参考。

利用数据库的方法

后面的例子都基于MS SQL Server,如果使用Oracle可以直接读取Sequence对象,则不需要进行如此复杂的操作。

方法1:利用表锁定

表结构:

create table xtab (seq_id int primary key, create_time datetime)

存储过程或SQL语句:


begin tran

declare @max_seq int

--读出记录时锁定表

select @max_seq=max(seq_id) from xtab with (TABLOCKX)

set @max_seq = i ull(@max_seq,0)

set @max_seq = @max_seq+1

print @max_seq

i ert into xtab values(@max_seq,getDate())

commit

--变量@max_seq 中存放的就是当前产生的序号

方法2:利用自增字段

如果利用自增变量可以通过方法1中锁定表,然后再插入记录,并读取最大值的方法。不过下面讲的是通过C#的ADO.NET来插入记录,并读取已经插入的记录的自增字段。

表结构:

create table xtab_i (seq_id int IDENTITY(1,1) primary key, create_time datetime)

C#代码,利用时间处理函数在数据被更新时同时读取@@IDENTITY变量的值。完整内容参考:OleDbWrap.cs 文件。


//参数内容:
//szSelectSql = &rdquo elect * from xtab_i where seq_id i ull&rdquo 
//szTa ame = “xtab_i&rdquo 
/// < ummary>
/// 通过查询语句 创建DataSet对象,返回的对象用于执行插入操作
/// </summary>
/// < aram name=" zSelectSql" gt QL语句</param>
/// < aram name=" zTa ame" gt;表名称</param>
/// <retur gt;用于插入的DataSet对象</retur gt;

public DataSet CreateI ertDataSet_bySelect(string szSelectSql,string szTa ame){     
 m_dbAdapter.SelectCommand = new OleDbCommand(szSelectSql, m_dbCo );
 OleDbCommandBuilder cb = new OleDbCommandBuilder(m_dbAdapter);
 DataSet ds = new DataSet();
 m_dbAdapter.Fill(ds, szTa ame);
 m_dbAdapter.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated_I erted);
 return d 
}
//----------------私有事件处理
/// < ummary>
/// 处理数据插入的更新事件
/// </summary>
/// < aram name=" ender" gt lt;/param>
/// < aram name="arg quot gt lt;/param>

protected void OnRowUpdated_I erted(object sender, OleDbRowUpdatedEventArgs args)
{
 OleDbCommand idCMD = new OleDbCommand(" ELECT @@IDENTITY", m_dbCo );
 if (args.StatementType == StatementType.I ert)
 {
  object rObj = idCMD.ExecuteScalar();
  if(rObj == null) m_iDbIdentity =-1;
  else if( rObj.ToString() !=" quot;)
   m_iDbIdentity = Int32.Parse(rObj.ToString());
  else
   m_iDbIdentity =-1;
 }
 idCMD.Di ose();
 //m_iDbIdentity变量中包含的就是当前插入列的自增字段的值
}

利用程序控制

方法1:利用A .NET中的A lication对象

利用A .NET中的全局HttpA licatio tate对象。

C#代码:


A lication.Lock();

A lication[“xlock”]=”locked&rsquo 

try

{ //必须捕捉异常,避免无法解锁对象

//your Code here

}

catch (Exception e)

{

}

A lication[“xlock”]=”unlock&rdquo 

方法2:利用操作系统中的同步对象来实现同步

在dotNet的框架的System.Threading命名空间下定义了多种用于同步的类,例如:Mutex,Semaphore。下面介绍一下利用互斥对象Mutex来实现同步的方法。

C#代码:


void Test()
{ //需要引入 System.Threading;
//创建名为MyMutex的互斥对象,如果OS已经创建过同名对象则只是重新获得句柄

Mutex m = new Mutex(false, "MyMutex");
//在10秒内等待取得访问权
boolean getMutex=m.WaitOne(10*1000,false);
if(getMutex)
{ //已经取得访问权
 try
 {
  //必须捕捉异常,避免无法解锁对象
  //Your code here
 }
 catch(Exception e)
 {
 }
 m.ReleaseMutex();
}
else
{
 //没有取得访问权
}

}

在程序中应该尽量使用Mutex这类可以命名的同步对象以达到创建多个同步对象,对多种资源进行同步的目的。如果要实现多个同入可以使用信号量 Semaphore。

其他方法:利用lock关键字防止线程并发同一段代码执行

C#代码:


cla  CTest
{
 int balance;
 void Increase()
 {
  lock (this)
  {
   balance++;
  }
 }
}

由于A .NET程序在IIS中可能配置不同的线程模式,所以在A .NET程序尽可能不要使用这种方法同步线程,而在普通的应用程序中是可以使用这种方法。

 附:OleDbWrap.cs ,是一个很简单的封装类,封装了基本的数据库操作。


using System;
using System.Data;
using System.Data.OleD 

name ace Wyy.Wrap
{
/// < ummary>
/// wDbWrap 说明:完成数据库访问功能
/// 1 创建Co ection,Adapter,管理对象内的Co 和Adapter对象
/// 2 通过Select结果集填充Dataset
/// 3 插入
/// 4 更新
/// </summary>
public cla  OleDbWrap
{
//--------公共方法
/// < ummary>
/// 在对象被清除时会自动清除 数据库连接对象
/// </summary>
public OleDbWrap()
{
m_dbCo  = new OleDbCo ection(D tring);
m_fAutoDelCo  = true;
m_dbAdapter = new OleDbDataAdapter();
m_dbCo .Open();
}
/// < ummary>
/// 通过连接字符串构造内部的数据库连接对象
/// </summary>
/// < aram name=" trCo ectio quot gt;ADO连接字符串</param>
public OleDbWrap(string strCo ection)
{
m_dbCo  = new OleDbCo ection(strCo ection);
m_fAutoDelCo  = true;
m_dbAdapter = new OleDbDataAdapter();
m_dbCo .Open();
}
/// < ummary>
/// 通过现有连接构造对象,在对象被清除时不会自动清除 数据库连接对象
/// </summary>
/// < aram name="co quot gt;现存的数据库连接对象</param>
public OleDbWrap(OleDbCo ection co )
{
m_dbCo  = co 
m_fAutoDelCo  = false;
m_dbAdapter = new OleDbDataAdapter();
//m_dbCo .Open();
}
public virtual void Di ose()
{
m_dbAdapter.Di ose();
if(m_fAutoDelCo )
{
m_dbCo .Close();
m_dbCo .Di ose();
}
}
/// < ummary>
/// 通过SQL语句创建DataReader对象
/// </summary>
/// < aram name=" zSql" gt QL语句</param>
/// <retur gt;DataReader对象</retur gt;
public OleDbDataReader CreateDataReader(string szSql)
{
OleDbCommand cmd = new OleDbCommand(szSql,m_dbCo );
OleDbDataReader dr= cmd.ExecuteReader();
cmd.Di ose();
return dr;
}
/// < ummary>
/// 通过SQL查询语句,返回第一行结果,可以用于执行类似与Select Count(*)的语句
/// </summary>
/// < aram name=" zSql" gt QL语句</param>
/// <retur gt;返回对象</retur gt;
public object ExecuteScalar(string szSql)
{
OleDbCommand idCMD = new OleDbCommand(szSql, m_dbCo );
object rObj = idCMD.ExecuteScalar();
idCMD.Di ose();
return rObj;
}
/// < ummary>
/// 调用OleDbCommand 的 ExecuteNonQuery
/// </summary>
/// < aram name=" zSql" gt lt;/param>
/// <retur gt lt;/retur gt;
public int ExecuteNonQuery(string szSql)
{
OleDbCommand idCMD = new OleDbCommand(szSql, m_dbCo );
int iRet = idCMD.ExecuteNonQuery();
idCMD.Di ose();
return iRet;
}
/// < ummary>
/// 创建查询用DataSet对象
/// </summary>
/// < aram name=" zSql" gt;查询SQL语句</param>
/// < aram name=" zTa ame" gt;表名称</param>
/// <retur gt;已经被填充的DataSet对象</retur gt;
public DataSet CreateSelectDataSet(string szSql,string szTa ame)
{
m_dbAdapter.SelectCommand = new OleDbCommand(szSql,m_dbCo );
DataSet ds = new DataSet();
m_dbAdapter.Fill(ds,szTa ame);
return d 
}
/// < ummary>
/// 通过查询语句 创建DataSet对象,返回的对象用于执行插入操作
/// </summary>
/// < aram name=" zSelectSql" gt QL语句</param>
/// < aram name=" zTa ame" gt;表名称</param>
/// <retur gt;用于插入的DataSet对象</retur gt;
public DataSet CreateI ertDataSet_bySelect(string szSelectSql,string szTa ame)
{
m_dbAdapter.SelectCommand = new OleDbCommand(szSelectSql, m_dbCo );

OleDbCommandBuilder cb = new OleDbCommandBuilder(m_dbAdapter);

DataSet ds = new DataSet();
m_dbAdapter.Fill(ds, szTa ame);
m_dbAdapter.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated_I erted);
return d 
}
/// < ummary>
/// 通过查询语句 创建DataSet对象,返回的对象用于执行更新操作
/// </summary>
/// < aram name=" zSelectSql" gt QL语句</param>
/// < aram name=" zTa ame" gt;表名称</param>
/// <retur gt;用于更新的DataSet对象</retur gt;
public DataSet CreateUpdateDataSet_bySelect(string szSelectSql,string szTa ame)
{
m_dbAdapter.SelectCommand = new OleDbCommand(szSelectSql, m_dbCo );

OleDbCommandBuilder cb = new OleDbCommandBuilder(m_dbAdapter);

DataSet ds = new DataSet();
m_dbAdapter.Fill(ds, szTa ame);
return d 
//m_dbAdapter.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated_Update);
}
//----------------私有事件处理
/// < ummary>
/// 处理数据插入的更新事件
/// </summary>
/// < aram name=" ender" gt lt;/param>
/// < aram name="arg quot gt lt;/param>
protected void OnRowUpdated_I erted(object sender, OleDbRowUpdatedEventArgs args)
{
OleDbCommand idCMD = new OleDbCommand(" ELECT @@IDENTITY", m_dbCo );

if (args.StatementType == StatementType.I ert)
{
object rObj = idCMD.ExecuteScalar();
if(rObj == null)
m_iDbIdentity =-1;
else if( rObj.ToString() !=" quot;)
m_iDbIdentity = Int32.Parse(rObj.ToString());
else
m_iDbIdentity =-1;
}
idCMD.Di ose();
}
//------------公共属性
/// < ummary>
/// 在插入数据后获取新数据行中自增字段的值,目前只能支持一个自增字段
/// </summary>
public Int32 DbIdentity {get{return m_iDbIdentity;} }
/// < ummary>
/// 数据库连接字符串,保存在web.config文件中 <a etting gt;节
/// </summary>
public string D tring {get{return System.Configuration.Configuratio ettings.A ettings["d tr"];}}

//------------公共变量
/// < ummary>
/// 数据库连接
/// </summary>
public OleDbCo ection m_dbCo 
/// < ummary>
/// 查询Adapter
/// </summary>
public OleDbDataAdapter m_dbAdapter;
public co t String m_szRootUrl ="/copathway/toDo/" 

//---------- 私有变量
/// < ummary>
/// 保存数据库插入是自增字段的值
/// </summary>
protected Int32 m_iDbIdentity =-1;
protected bool m_fAutoDelCo  = true;
}
}

相关热词搜索:在ASP.NET程序中创建唯一序号

上一篇:asp.net 2.0中用GRIDVIEW插入新记录
下一篇:一个功能齐全的DataGrid分页例子

分享到: 收藏
频道总排行
频道本月排行