在ASP.NET程序中創建唯一序號
如果在程序中需要創建全局唯一的序號，那么必須對創建序號的過程進行同步處理，防止多個并發訪問時出現相同序號的情況。下面列出幾種方法供大家參考。
利用數據庫的方法
后面的例子都基于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 = isnull(@max_seq,0) set @max_seq = @max_seq+1 print @max_seq insert 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 = ”select * from xtab_i where seq_id isnull”; //szTabName = “xtab_i”; /// ＜summary＞ /// 通過查詢語句 創建DataSet對象，返回的對象用于執行插入操作 /// ＜/summary＞ /// ＜param name="szSelectSql"＞SQL語句＜/param＞ /// ＜param name="szTabName"＞表名稱＜/param＞ /// ＜returns＞用于插入的DataSet對象＜/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＞ /// 處理數據插入的更新事件 /// ＜/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變量中包含的就是當前插入列的自增字段的值 } |
利用程序控制
方法1：利用ASP.NET中的Application對象
利用ASP.NET中的全局HttpApplicationState對象。
C#代碼：
| Application.Lock(); Application[“xlock”]=”locked’; try { //必須捕捉異常，避免無法解鎖對象 //your Code here } catch (Exception e) { } Application[“xlock”]=”unlock”; |
方法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#代碼：
| class CTest { int balance; void Increase() { lock (this) { balance++; } } } |
由于ASP.NET程序在IIS中可能配置不同的線程模式，所以在ASP.NET程序盡可能不要使用這種方法同步線程，而在普通的應用程序中是可以使用這種方法。
附：OleDbWrap.cs ，是一個很簡單的封裝類，封裝了基本的數據庫操作。
| using System; using System.Data; using System.Data.OleDb; namespace Wyy.Wrap { /// ＜summary＞ /// wDbWrap 說明：完成數據庫訪問功能 /// 1 創建Connection，Adapter，管理對象內的Conn和Adapter對象 /// 2 通過Select結果集填充Dataset /// 3 插入 /// 4 更新 /// ＜/summary＞ public class OleDbWrap { //--------公共方法 /// ＜summary＞ /// 在對象被清除時會自動清除 數據庫連接對象 /// ＜/summary＞ public OleDbWrap() { m_dbConn = new OleDbConnection(DbString); m_fAutoDelConn = true; m_dbAdapter = new OleDbDataAdapter(); m_dbConn.Open(); } /// ＜summary＞ /// 通過連接字符串構造內部的數據庫連接對象 /// ＜/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＞ /// 通過現有連接構造對象，在對象被清除時不會自動清除 數據庫連接對象 /// ＜/summary＞ /// ＜param name="conn"＞現存的數據庫連接對象＜/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語句創建DataReader對象 /// ＜/summary＞ /// ＜param name="szSql"＞SQL語句＜/param＞ /// ＜returns＞DataReader對象＜/returns＞ public OleDbDataReader CreateDataReader(string szSql) { OleDbCommand cmd = new OleDbCommand(szSql,m_dbConn); OleDbDataReader dr= cmd.ExecuteReader(); cmd.Dispose(); return dr; } /// ＜summary＞ /// 通過SQL查詢語句，返回第一行結果，可以用于執行類似與Select Count(*)的語句 /// ＜/summary＞ /// ＜param name="szSql"＞SQL語句＜/param＞ /// ＜returns＞返回對象＜/returns＞ public object ExecuteScalar(string szSql) { OleDbCommand idCMD = new OleDbCommand(szSql, m_dbConn); object rObj = idCMD.ExecuteScalar(); idCMD.Dispose(); return rObj; } /// ＜summary＞ /// 調用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＞ /// 創建查詢用DataSet對象 /// ＜/summary＞ /// ＜param name="szSql"＞查詢SQL語句＜/param＞ /// ＜param name="szTabName"＞表名稱＜/param＞ /// ＜returns＞已經被填充的DataSet對象＜/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＞ /// 通過查詢語句 創建DataSet對象，返回的對象用于執行插入操作 /// ＜/summary＞ /// ＜param name="szSelectSql"＞SQL語句＜/param＞ /// ＜param name="szTabName"＞表名稱＜/param＞ /// ＜returns＞用于插入的DataSet對象＜/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＞ /// 通過查詢語句 創建DataSet對象，返回的對象用于執行更新操作 /// ＜/summary＞ /// ＜param name="szSelectSql"＞SQL語句＜/param＞ /// ＜param name="szTabName"＞表名稱＜/param＞ /// ＜returns＞用于更新的DataSet對象＜/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＞ /// 處理數據插入的更新事件 /// ＜/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＞ /// 在插入數據后獲取新數據行中自增字段的值，目前只能支持一個自增字段 /// ＜/summary＞ public Int32 DbIdentity {get{return m_iDbIdentity;} } /// ＜summary＞ /// 數據庫連接字符串,保存在web.config文件中 ＜appSettings＞節 /// ＜/summary＞ public string DbString {get{return System.Configuration.ConfigurationSettings.AppSettings["dbStr"];}} //------------公共變量 /// ＜summary＞ /// 數據庫連接 /// ＜/summary＞ public OleDbConnection m_dbConn; /// ＜summary＞ /// 查詢Adapter /// ＜/summary＞ public OleDbDataAdapter m_dbAdapter; public const String m_szRootUrl ="/copathway/toDo/"; //---------- 私有變量 /// ＜summary＞ /// 保存數據庫插入是自增字段的值 /// ＜/summary＞ protected Int32 m_iDbIdentity =-1; protected bool m_fAutoDelConn = true; } } |