IT培训 / 新闻资讯 / 编程语言教程 / 惊讶！在ASP.NET程序中创建唯一序号

惊讶！在ASP.NET程序中创建唯一序号

作者：课课家来源： http://www.kokojia.com/点击数：535发布时间： 2015-11-13 22:43:10

不知不觉又来到小编的文章，这次又带来了一点小知识与大家分享，希望大家有所收获。excel2010视频教程

如果在程序中需要创建全局唯一的序号，那么必须对创建序号的过程进行同步处理，防止多个并发访问时出现相同序号的情况。下面列出几种方法供大家参考。
利用数据库的方法
后面的例子都基于MS SQL Server，如果使用Oracle可以直接读取Sequence对象，则不需要进行如此复杂的操作。
方法1：利用表锁定
表结构：
create table xtab (seq_id int primary key, create_time datetime)
存储过程或SQL语句：excel2010教程

以下为引用的内容：
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”;
///
/// 通过查询语句创建DataSet对象，返回的对象用于执行插入操作
///
///SQL语句
///表名称
/// 用于插入的DataSet对象 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;
}
//----------------私有事件处理
///
/// 处理数据插入的更新事件
///
///
///
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”;

高级语言的出现使得计算机程序设计语言不再过度地依赖某种特定的机器或环境。这是因为高级语言在不同的平台上会被编译成不同的机器语言，而不是直接被机器执行。最早出现的编程语言之一FORTRAN的一个主要目标，就是实现平台独立。[1]
虽然大多数的语言可以既可被编译又可被解译，但大多数仅在一种情况下能够良好运行。在一些编程系统中，程序要经过几个阶段的编译，一般而言，后阶段的编译往往更接近机器语言。这种常用的使用技巧最早在1960年代末用于BCPL，编译程序先编译一个叫做“0代码”的转换程序（representation），然后再使用虚拟器转换到可以运行于机器上的真实代码。这种成功的技巧之后又用于Pascal和P-code，以及Smalltalk和二进制码，在很多时候，中间过渡的代码往往是解译，而不是编译的。[1]
如果所使用的翻译的机制是将所要翻译的程序代码作为一个整体翻译，并之后运行内部格式，那么这个翻译过程就被成为编译。因此，一个编译器是一个将人可阅读的程序文本（叫做源代码）作为输入的数据，然后输出可执行文件（object code）。所输出的可执行文件可以是机器语言，由计算机的中央处理器直接运行，或者是某种模拟器的二进制代码。[1]
如果程序代码是在运行时才即时翻译，那么这种翻译机制就被称作直译。经直译的程序运行速度往往比编译的程序慢，但往往更具灵活性，因为它们能够与执行环境互相作用。[1]excel2010

方法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
{
///
/// wDbWrap 说明：完成数据库访问功能
/// 1 创建Connection，Adapter，管理对象内的Conn和Adapter对象
/// 2 通过Select结果集填充Dataset
/// 3 插入
/// 4 更新
///
public class OleDbWrap
{
//--------公共方法
///
/// 在对象被清除时会自动清除数据库连接对象
///
public OleDbWrap()
{
m_dbConn = new OleDbConnection(DbString);
m_fAutoDelConn = true;
m_dbAdapter = new OleDbDataAdapter();
m_dbConn.Open();
}
///
/// 通过连接字符串构造内部的数据库连接对象
///
///ADO连接字符串
public OleDbWrap(string strConnection)
{
m_dbConn = new OleDbConnection(strConnection);
m_fAutoDelConn = true;
m_dbAdapter = new OleDbDataAdapter();
m_dbConn.Open();
}
///
/// 通过现有连接构造对象，在对象被清除时不会自动清除数据库连接对象
///
///现存的数据库连接对象
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();
}
}
///
/// 通过SQL语句创建DataReader对象
///
///SQL语句
/// DataReader对象
public OleDbDataReader CreateDataReader(string szSql)
{
OleDbCommand cmd = new OleDbCommand(szSql,m_dbConn);
OleDbDataReader dr= cmd.ExecuteReader();
cmd.Dispose();
return dr;
}
///
/// 通过SQL查询语句，返回第一行结果，可以用于执行类似与Select Count(*)的语句
///
///SQL语句
/// 返回对象
public object ExecuteScalar(string szSql)
{
OleDbCommand idCMD = new OleDbCommand(szSql, m_dbConn);
object rObj = idCMD.ExecuteScalar();
idCMD.Dispose();
return rObj;
}
///
/// 调用OleDbCommand 的 ExecuteNonQuery
///
///
///
public int ExecuteNonQuery(string szSql)
{
OleDbCommand idCMD = new OleDbCommand(szSql, m_dbConn);
int iRet = idCMD.ExecuteNonQuery();
idCMD.Dispose();
return iRet;
}
///
/// 创建查询用DataSet对象
///
///查询SQL语句
///表名称
/// 已经被填充的DataSet对象
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;
}
///
/// 通过查询语句创建DataSet对象，返回的对象用于执行插入操作
///
///SQL语句
///表名称
/// 用于插入的DataSet对象
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;
}
///
/// 通过查询语句创建DataSet对象，返回的对象用于执行更新操作
///
///SQL语句
///表名称
/// 用于更新的DataSet对象
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);
}
//----------------私有事件处理
///
/// 处理数据插入的更新事件
///
///
///
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();
}
//------------公共属性
///
/// 在插入数据后获取新数据行中自增字段的值，目前只能支持一个自增字段
///
public Int32 DbIdentity {get{return m_iDbIdentity;} }
///
/// 数据库连接字符串,保存在web.config文件中节
///
public string DbString {get{return System.Configuration.ConfigurationSettings.AppSettings["dbStr"];}}
//------------公共变量
///
/// 数据库连接
///
public OleDbConnection m_dbConn;
///
/// 查询Adapter
///
public OleDbDataAdapter m_dbAdapter;
public const String m_szRootUrl ="/copathway/toDo/";
//---------- 私有变量
///
/// 保存数据库插入是自增字段的值
///
protected Int32 m_iDbIdentity =-1;
protected bool m_fAutoDelConn = true;
}
}

如果大家觉得收获很多，那就请大家去课课家官网一起走入知识的天堂。

踩(2)

分享到：

上一篇：教你如何恢复/修复MS SQL数据库的MDF文件

下一篇：详细讲解PHP中缓存技术的应用总结