扫一扫
分享文章到微信
扫一扫
关注官方公众号
至顶头条
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程序尽可能不要使用这种方法同步线程,而在普通的应用程序中是可以使用这种方法。
如果您非常迫切的想了解IT领域最新产品与技术信息,那么订阅至顶网技术邮件将是您的最佳途径之一。
现场直击|2021世界人工智能大会
直击5G创新地带,就在2021MWC上海
5G已至 转型当时——服务提供商如何把握转型的绝佳时机
寻找自己的Flag
华为开发者大会2020(Cloud)- 科技行者