在ASP.NET程序中創(chuàng)建唯一序號(hào)

　　如果在程序中需要?jiǎng)?chuàng)建全局唯一的序號(hào)，那么必須對(duì)創(chuàng)建序號(hào)的過程進(jìn)行同步處理，防止多個(gè)并發(fā)訪問時(shí)出現(xiàn)相同序號(hào)的情況。下面列出幾種方法供大家參考。

　　利用數(shù)據(jù)庫(kù)的方法

　　后面的例子都基于MS SQL Server，如果使用Oracle可以直接讀取Sequence對(duì)象，則不需要進(jìn)行如此復(fù)雜的操作。

　　方法1：利用表鎖定

　　表結(jié)構(gòu)：

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

　　存儲(chǔ)過程或SQL語句：

begin tran

declare @max_seq int

--讀出記錄時(shí)鎖定表

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

set @max_seq = isnull(@max_seq,0)

set @max_seq = @max_seq+1

print @max_seq

insert into xtab values(@max_seq,getDate())

commit

--變量@max_seq 中存放的就是當(dāng)前產(chǎn)生的序號(hào)

　　方法2：利用自增字段

　　如果利用自增變量可以通過方法1中鎖定表，然后再插入記錄，并讀取最大值的方法。不過下面講的是通過C#的ADO.NET來插入記錄，并讀取已經(jīng)插入的記錄的自增字段。

　　表結(jié)構(gòu)：

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

　　C#代碼，利用時(shí)間處理函數(shù)在數(shù)據(jù)被更新時(shí)同時(shí)讀取@@IDENTITY變量的值。完整內(nèi)容參考：OleDbWrap.cs 文件。

//參數(shù)內(nèi)容：
//szSelectSql = ”select * from xtab_i where seq_id isnull”;
//szTabName = “xtab_i”;
/// <summary>
/// 通過查詢語句 創(chuàng)建DataSet對(duì)象，返回的對(duì)象用于執(zhí)行插入操作
/// </summary>
/// <param name="szSelectSql">SQL語句</param>
/// <param name="szTabName">表名稱</param>
/// <returns>用于插入的DataSet對(duì)象</returns>

public DataSet CreateInsertDataSet_bySelect(string szSelectSql,string szTabName){ 　　　　
　m_dbAdapter.SelectCommand = new OleDbCommand(szSelectSql, m_dbConn);
　OleDbCommandBuilder cb = new OleDbCommandBuilder(m_dbAdapter);
　DataSet ds = new DataSet();
　m_dbAdapter.Fill(ds, szTabName);
　m_dbAdapter.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated_Inserted);
　return ds;
}
//----------------私有事件處理
/// <summary>
/// 處理數(shù)據(jù)插入的更新事件
/// </summary>
/// <param name="sender"></param>
/// <param name="args"></param>

protected void OnRowUpdated_Inserted(object sender, OleDbRowUpdatedEventArgs args)
{
　OleDbCommand idCMD = new OleDbCommand("SELECT @@IDENTITY", m_dbConn);
　if (args.StatementType == StatementType.Insert)
　{
　　object rObj = idCMD.ExecuteScalar();
　　if(rObj == null) m_iDbIdentity =-1;
　　else if( rObj.ToString() !="")
　　　m_iDbIdentity = Int32.Parse(rObj.ToString());
　　else
　　　m_iDbIdentity =-1;
　}
　idCMD.Dispose();
　//m_iDbIdentity變量中包含的就是當(dāng)前插入列的自增字段的值
}

　　利用程序控制

　　方法1：利用ASP.NET中的Application對(duì)象

　　利用ASP.NET中的全局HttpApplicationState對(duì)象。

　　C#代碼：

Application.Lock();

Application[“xlock”]=”locked’;

try

{ //必須捕捉異常，避免無法解鎖對(duì)象

//your Code here

}

catch (Exception e)

{

}

Application[“xlock”]=”unlock”;

　　方法2：利用操作系統(tǒng)中的同步對(duì)象來實(shí)現(xiàn)同步

　　在dotNet的框架的System.Threading命名空間下定義了多種用于同步的類，例如：Mutex，Semaphore。下面介紹一下利用互斥對(duì)象Mutex來實(shí)現(xiàn)同步的方法。

　　C#代碼：

void Test()
{ //需要引入 System.Threading;
//創(chuàng)建名為MyMutex的互斥對(duì)象，如果OS已經(jīng)創(chuàng)建過同名對(duì)象則只是重新獲得句柄

Mutex m = new Mutex(false, "MyMutex");
//在10秒內(nèi)等待取得訪問權(quán)
boolean getMutex=m.WaitOne(10*1000,false);
if(getMutex)
{ //已經(jīng)取得訪問權(quán)
　try
　{
　　//必須捕捉異常，避免無法解鎖對(duì)象
　　//Your code here
　}
　catch(Exception e)
　{
　}
　m.ReleaseMutex();
}
else
{
　//沒有取得訪問權(quán)
}

}

　　在程序中應(yīng)該盡量使用Mutex這類可以命名的同步對(duì)象以達(dá)到創(chuàng)建多個(gè)同步對(duì)象，對(duì)多種資源進(jìn)行同步的目的。如果要實(shí)現(xiàn)多個(gè)同入可以使用信號(hào)量 Semaphore。

　　其他方法：利用lock關(guān)鍵字防止線程并發(fā)同一段代碼執(zhí)行

　　C#代碼：

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

　　由于ASP.NET程序在IIS中可能配置不同的線程模式，所以在ASP.NET程序盡可能不要使用這種方法同步線程，而在普通的應(yīng)用程序中是可以使用這種方法。

　　 附：OleDbWrap.cs ，是一個(gè)很簡(jiǎn)單的封裝類，封裝了基本的數(shù)據(jù)庫(kù)操作。

using System;
using System.Data;
using System.Data.OleDb;

namespace Wyy.Wrap
{
/// <summary>
/// wDbWrap 說明：完成數(shù)據(jù)庫(kù)訪問功能
/// 1 創(chuàng)建Connection，Adapter，管理對(duì)象內(nèi)的Conn和Adapter對(duì)象
/// 2 通過Select結(jié)果集填充Dataset
/// 3 插入
/// 4 更新
/// </summary>
public class OleDbWrap
{
//--------公共方法
/// <summary>
/// 在對(duì)象被清除時(shí)會(huì)自動(dòng)清除 數(shù)據(jù)庫(kù)連接對(duì)象
/// </summary>
public OleDbWrap()
{
m_dbConn = new OleDbConnection(DbString);
m_fAutoDelConn = true;
m_dbAdapter = new OleDbDataAdapter();
m_dbConn.Open();
}
/// <summary>
/// 通過連接字符串構(gòu)造內(nèi)部的數(shù)據(jù)庫(kù)連接對(duì)象
/// </summary>
/// <param name="strConnection">ADO連接字符串</param>
public OleDbWrap(string strConnection)
{
m_dbConn = new OleDbConnection(strConnection);
m_fAutoDelConn = true;
m_dbAdapter = new OleDbDataAdapter();
m_dbConn.Open();
}
/// <summary>
/// 通過現(xiàn)有連接構(gòu)造對(duì)象，在對(duì)象被清除時(shí)不會(huì)自動(dòng)清除 數(shù)據(jù)庫(kù)連接對(duì)象
/// </summary>
/// <param name="conn">現(xiàn)存的數(shù)據(jù)庫(kù)連接對(duì)象</param>
public OleDbWrap(OleDbConnection conn)
{
m_dbConn = conn;
m_fAutoDelConn = false;
m_dbAdapter = new OleDbDataAdapter();
//m_dbConn.Open();
}
public virtual void Dispose()
{
m_dbAdapter.Dispose();
if(m_fAutoDelConn)
{
m_dbConn.Close();
m_dbConn.Dispose();
}
}
/// <summary>
/// 通過SQL語句創(chuàng)建DataReader對(duì)象
/// </summary>
/// <param name="szSql">SQL語句</param>
/// <returns>DataReader對(duì)象</returns>
public OleDbDataReader CreateDataReader(string szSql)
{
OleDbCommand cmd = new OleDbCommand(szSql,m_dbConn);
OleDbDataReader dr= cmd.ExecuteReader();
cmd.Dispose();
return dr;
}
/// <summary>
/// 通過SQL查詢語句，返回第一行結(jié)果，可以用于執(zhí)行類似與Select Count(*)的語句
/// </summary>
/// <param name="szSql">SQL語句</param>
/// <returns>返回對(duì)象</returns>
public object ExecuteScalar(string szSql)
{
OleDbCommand idCMD = new OleDbCommand(szSql, m_dbConn);
object rObj = idCMD.ExecuteScalar();
idCMD.Dispose();
return rObj;
}
/// <summary>
/// 調(diào)用OleDbCommand 的 ExecuteNonQuery
/// </summary>
/// <param name="szSql"></param>
/// <returns></returns>
public int ExecuteNonQuery(string szSql)
{
OleDbCommand idCMD = new OleDbCommand(szSql, m_dbConn);
int iRet = idCMD.ExecuteNonQuery();
idCMD.Dispose();
return iRet;
}
/// <summary>
/// 創(chuàng)建查詢用DataSet對(duì)象
/// </summary>
/// <param name="szSql">查詢SQL語句</param>
/// <param name="szTabName">表名稱</param>
/// <returns>已經(jīng)被填充的DataSet對(duì)象</returns>
public DataSet CreateSelectDataSet(string szSql,string szTabName)
{
m_dbAdapter.SelectCommand = new OleDbCommand(szSql,m_dbConn);
DataSet ds = new DataSet();
m_dbAdapter.Fill(ds,szTabName);
return ds;
}
/// <summary>
/// 通過查詢語句 創(chuàng)建DataSet對(duì)象，返回的對(duì)象用于執(zhí)行插入操作
/// </summary>
/// <param name="szSelectSql">SQL語句</param>
/// <param name="szTabName">表名稱</param>
/// <returns>用于插入的DataSet對(duì)象</returns>
public DataSet CreateInsertDataSet_bySelect(string szSelectSql,string szTabName)
{
m_dbAdapter.SelectCommand = new OleDbCommand(szSelectSql, m_dbConn);

OleDbCommandBuilder cb = new OleDbCommandBuilder(m_dbAdapter);

DataSet ds = new DataSet();
m_dbAdapter.Fill(ds, szTabName);
m_dbAdapter.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated_Inserted);
return ds;
}
/// <summary>
/// 通過查詢語句 創(chuàng)建DataSet對(duì)象，返回的對(duì)象用于執(zhí)行更新操作
/// </summary>
/// <param name="szSelectSql">SQL語句</param>
/// <param name="szTabName">表名稱</param>
/// <returns>用于更新的DataSet對(duì)象</returns>
public DataSet CreateUpdateDataSet_bySelect(string szSelectSql,string szTabName)
{
m_dbAdapter.SelectCommand = new OleDbCommand(szSelectSql, m_dbConn);

OleDbCommandBuilder cb = new OleDbCommandBuilder(m_dbAdapter);

DataSet ds = new DataSet();
m_dbAdapter.Fill(ds, szTabName);
return ds;
//m_dbAdapter.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated_Update);
}
//----------------私有事件處理
/// <summary>
/// 處理數(shù)據(jù)插入的更新事件
/// </summary>
/// <param name="sender"></param>
/// <param name="args"></param>
protected void OnRowUpdated_Inserted(object sender, OleDbRowUpdatedEventArgs args)
{
OleDbCommand idCMD = new OleDbCommand("SELECT @@IDENTITY", m_dbConn);

if (args.StatementType == StatementType.Insert)
{
object rObj = idCMD.ExecuteScalar();
if(rObj == null)
m_iDbIdentity =-1;
else if( rObj.ToString() !="")
m_iDbIdentity = Int32.Parse(rObj.ToString());
else
m_iDbIdentity =-1;
}
idCMD.Dispose();
}
//------------公共屬性
/// <summary>
/// 在插入數(shù)據(jù)后獲取新數(shù)據(jù)行中自增字段的值，目前只能支持一個(gè)自增字段
/// </summary>
public Int32 DbIdentity {get{return m_iDbIdentity;} }
/// <summary>
/// 數(shù)據(jù)庫(kù)連接字符串,保存在web.config文件中 <appSettings>節(jié)
/// </summary>
public string DbString {get{return System.Configuration.ConfigurationSettings.AppSettings["dbStr"];}}

//------------公共變量
/// <summary>
/// 數(shù)據(jù)庫(kù)連接
/// </summary>
public OleDbConnection m_dbConn;
/// <summary>
/// 查詢Adapter
/// </summary>
public OleDbDataAdapter m_dbAdapter;
public const String m_szRootUrl ="/copathway/toDo/";

//---------- 私有變量
/// <summary>
/// 保存數(shù)據(jù)庫(kù)插入是自增字段的值
/// </summary>
protected Int32 m_iDbIdentity =-1;
protected bool m_fAutoDelConn = true;
}
}