在ASP.NET程序中创建唯一序号
2008-04-24 07:54
232 查看
如果在程序中需要创建全局唯一的序号,那么必须对创建序号的过程进行同步处理,防止多个并发访问时出现相同序号的情况。下面列出几种方法供大家参考。
利用数据库的方法
后面的例子都基于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;
}
}
利用数据库的方法
后面的例子都基于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;
}
}
相关文章推荐
- 在ASP.NET程序中创建唯一序号
- 怎样在ASP.NET程序中创建唯一序号
- 在ASP.NET程序中创建唯一序号
- asp.net中需要创建唯一的序号
- MVC中使用EF(1):为ASP.NET MVC程序创建Entity Framework数据模型
- 转载:创建ASP.NET程序时候发生错误 HTTP/1.0 500 Server Error
- asp.net -mvc框架复习(2)-创建ASP.NET MVC 第一个程序以及MVC项目文件夹说明
- 创建ASP.NET程序时候发生错误 HTTP/1.0 500 Server Error
- ASP.NET MVC 企业级实战 —— 创建用户权限管理范例程序(一)
- ASP.NET MVC 企业级实战 —— 创建用户权限管理示例程序(一)
- Asp.Net 利用反射获得委托和事件以及创建委托实例和添加事件处理程序
- 一步一步学习ASP.NET MVC 1.0创建NerdDinner 范例程序
- 【转】通过ASP.net程序创建域帐户故障
- +关于vs2003下创建ASP.NET程序时出现的错误+
- 为ASP.NET 2.0网站生成唯一程序集
- 一步一步学习asp.net mvc 1.0 创建NerdDinner程序Part1(转载)
- 检测到指定的WEB服务器运行的不是ASP.NET 1.1版,您无法运行ASP.NET应用程序或服务和创建ASP.NET程序时候发生错误 HTTP/1.0 500 Server Error的解决方法
- vs.net中创建asp.net程序时,出现:http/1.1 500 internal server error
- ASP.NET MVC 企业级实战 —— 创建用户权限管理范例程序(二)
- ASP.NET MVC 企业级实战 —— 创建用户权限管理范例程序(三)