在Linq to Sql中管理并发更新时的冲突(1):预…
2008-04-02 11:00:58来源:互联网 阅读 ()
无论和现在的ORM框架相比有没有优势,Linq to Sql在语言和平台的级别上为我们提供了一种新的操作对象和数据的方式,在一定程度上为我们解决了Object != Data的问题。在实际应用中,对于数据库的操作往往有着天生的并发性,因此在更新数据时可能会产生冲突。有些时候,假如没有合理的解决冲突问题,轻则让用户摸不着头脑,重则让系统数据处于一种不一致的状态。Linq to Sql自然考虑到了这一点,本系列讨论的内容,就是在使用Linq to Sql时,如何管理并发更新时产生的冲突。
本文为这个系列的第一篇,将讨论一些预备知识,他们是进行后续研究的基础。
一些定义:
首先,我们来看一些定义:
- 并发(Concurrency):两个或更多的用户尝试同时更新数据库的同一条记录。
- 并发冲突(Concurrency Confilct):两个或更多的用户尝试同时向同一条记录的一个或多个字段提交冲突的值。
- 并发控制(Concurrency Control):解决并发冲突的技术。
- 乐观并发控制(Optimistic Concurrency Control):在提交当前事务之前,首先查看即将更新的记录是否被别的事务所改变的一种技术。
- 悲观并发控制(Pessimistic Concurrency Control):为纪录加锁以阻止其他事务访问某些记录,以避免产生并发冲突的一种技术。
Linq to Sql的对象模型使用乐观并发控制的方式来发现和解决冲突问题。很显然,他假设冲突发生的可能性并不大。假如您需要使用悲观并发控制来解决冲突问题,则能够使用其他方法(例如自定义存储过程供程式调用)。
调试方法:
Linq to Sql的相当部分由编译器来实现,而语言中的Linq语句最终会被转化为Sql,因此假如要理解Linq to Sql的工作,一定要将操作中所执行的Sql语句给挖掘出来。一般来说,要挖掘出操作中所使用的Sql语句,能够使用以下几种方法(以下将使用Sql Server 2005自带的AdventureWorks数据库来作为示例):
1、获取Query所对应的SqlCommand对象:
在研发过程中,我们能够通过Query获得对应的Sql Command对象。请看如下代码:
AdventureWorksDataContext db = new AdventureWorksDataContext(); var products = from p in db.Products where p.ProductID == 3 select new { p.ProductID, p.Name }; foreach (var p in products) { Console.WriteLine(p); } DbCommand cmd = db.GetCommand(products); Console.WriteLine("------------"); Console.WriteLine("Command Text: \n{0}", cmd.CommandText); Console.WriteLine("------------"); Console.WriteLine("Command Type: \n{0}", cmd.CommandType); Console.WriteLine("------------"); Console.WriteLine("Command Parameters:"); foreach (DbParameter p in cmd.Parameters) { Console.WriteLine("{0}: {1}", p.ParameterName, p.Value); } Console.ReadLine(); 输出结果如下: Command Text: SELECT [t0].[ProductID], [t0].[Name] FROM [Production].[Product] AS [t0] WHERE [t0].[ProductID] = @p0 ------------ Command Type: Text ------------ Command Parameters: @p0: 3 |
能够看到,无论是Sql语句或是参数都被打印了出来。事实上,由于我们得到了完整的SqlCommand对象,我们能够获取的信息并不止上述这些。
2、使用LINQ to SQL Debug Visualizer:
使用LINQ to SQL Debug Visiualizer,我们能够在调试程式时直观地获得Query所对应的Sql语句连同参数,而不必获得SqlCommand对象并打印信息。具体使用方法详见Scott Gu的这篇博文。
3、使用DataContext的Log功能:
DataContext自带的Log属性为一个TextWriter类型的对象,假如我们配置了这个属性,则DataContext任何的操作将会通过这个TextWriter对象输出。和比上述两种方法相比,这个方法的优势在于DataContext所执行的任何语句,无论SELECT、INSERT、UPDATE或是DELETE都会被输出;而上面的两种做法只能得到Query的信息,也就是SQL语句的SELECT操作。
请看如下代码,下面的代码将AdventureWorksDataContext对象的任何操作输出至Console:
AdventureWorksDataContext db = new AdventureWorksDataContext(); db.Log = Console.Out; Product product = (from p in db.Products where p.ProductID == 1 select p).First(); product.Name = "Hello World"; db.SubmitChanges(); Console.ReadLine(); |
输出结果如下:
SELECT TOP (1) [t0].[ProductID], [t0].[Name], [t0].[ProductNumber], [t0].[MakeFl ... edDate], [t0].[rowguid], [t0].[ModifiedDate] FROM [Production].[Product] AS [t0] WHERE [t0].[ProductID] = @p0 -- @p0: Input Int (Size = 0; Prec = 0; Scale = 0) [1] -- Context: SqlProvider(Sql2005) Model: AttributedMetaModel Build: 3.5.21004.1 UPDATE [Production].[Product] SET [Name] = @p11 WHERE ([ProductID] = @p0) AND ([Name] = @p1) AND ([ProductNumber] = @p2) AND (NO ... NULL) AND ([rowguid] = @p9) AND ([ModifiedDate] = @p10) -- @p0: Input Int (Size = 0; Prec = 0; Scale = 0) [1] ... -- @p11: Input NVarChar (Size = 11; Prec = 0; Scale = 0) [Hello World] -- Context: SqlProvider(Sql2005) Model: AttributedMetaModel Build: 3.5.21004.1 |