日期:2014-05-20  浏览次数:20714 次

Linq调用SubmitChanges方法

?

文章来自:http://developer.51cto.com/art/200909/150713.htm

?

Linq SubmitChanges方法计算要插入、更新或删除的已修改对象的集,并执行相应命令以实现对数据库的更改。

无论对象做了多少项更改,都只是在更改内存中的副本。并未对数据库中的实际数据做任何更改。直到对DataContext显式Linq SubmitChanges,所做的更改才会传输到服务器。调用时,DataContext会设法将我们所做的更改转换为等效的SQL命令。我们也可以使用自己的自定义逻辑来重写这些操作,但提交顺序是由DataContext的一项称作“更改处理器”的服务来协调的。事件的顺序如下:
1. 当Linq SubmitChanges方法时,LINQ to SQL会检查已知对象的集合以确定新实例是否已附加到它们。如果已附加,这些新实例将添加到被跟踪对象的集合。
2. 所有具有挂起更改的对象将按照它们之间的依赖关系排序成一个对象序列。如果一个对象的更改依赖于其他对象,则这个对象将排在其依赖项之后。
3. 在即将传输任何实际更改时,LINQ to SQL会启动一个事务来封装由各条命令组成的系列。
4. 对对象的更改会逐个转换为SQL命令,然后发送到服务器。

如果数据库检测到任何错误,都会造成提交进程停止并引发异常。将回滚对数据库的所有更改,就像未进行过提交一样。DataContext 仍具有所有更改的完整记录。

下面代码说明的是在数据库中查询CustomerID为ALFKI的顾客,然后修改其公司名称,第一次更新并Linq SubmitChanges方法,第二次更新了数据但并未Linq调用SubmitChanges方法。

  1. //查询 ?
  2. Customer?cust?=?db.Customers.First(c?=>?c.CustomerID?==?"ALFKI"); ?
  3. //更新数据并调用SubmitChanges()方法 ?
  4. cust.CompanyName?=?"YJingLee's?Blog"; ?
  5. db.SubmitChanges(); ?
  6. //更新数据没有调用SubmitChanges()方法 ?
  7. cust.CompanyName?=?"http://lyj.cnblogs.com";?

动态查询

使用动态查询,这个例子用CreateQuery()方法创建一个IQueryable类型表达式输出查询的语句。这里给个例子说明一下。有关动态查询具体内容,下一篇介绍。

  1. var?c1?=?Expression.Parameter(typeof(Customer),?"c"); ?
  2. PropertyInfo?City?=?typeof(Customer).GetProperty("City"); ?
  3. ?
  4. var?pred?=?Expression.Lambda<Func<Customer,?bool>>( ?
  5. Expression.Equal( ?
  6. Expression.Property(c1,?City), ?
  7. Expression.Constant("Seattle") ?
  8. } ?
  9. }; ?
  10. IQueryable?custs?=?db.Customers; ?
  11. Expression?expr?=?Expression.Call(typeof(Queryable),?"Where", ?
  12. new?Type[]?{?custs.ElementType?},?custs.Expression,?pred); ?
  13. IQueryable<Customer>?q?=?db.Customers.AsQueryable(). ?
  14. Provider.CreateQuery<Customer>(expr);?

Log属性用于将SQL查询或命令打印到TextReader。此方法对了解 LINQ to SQL 功能和调试特定的问题可能很有用。

下面的示例使用Log属性在SQL代码执行前在控制台窗口中显示此代码。我们可以将此属性与查询、插入、更新和删除命令一起使用。

  1. //关闭日志功能 ?
  2. //db.Log?=?null; ?
  3. //使用日志功能:日志输出到控制台窗口 ?
  4. db.Log?=?Console.Out; ?
  5. var?q?=?from?c?in?db.Customers ?
  6. where?c.City?==?"London" ?
  7. select?c; ?
  8. //日志输出到文件 ?
  9. StreamWriter?sw?=?new?StreamWriter(Server.MapPath("log.txt"),?true); ?
  10. db.Log?=?sw; ?
  11. var?q?=?from?c?in?db.Customers ?
  12. where?c.City?==?"London" ?
  13. select?c; ?
  14. sw.Close();?