Entity Framework中的连接管理
EF框架对数据库的连接提供了一系列的默认行为，通常情况下不需要我们太多的关注。但是，这种封装，降低了灵活性，有时我们需要对数据库连接加以控制。
EF提供了两种方案控制数据库连接：
- 传递到Context的连接；
- Database.Connnection.Open()；
下面详解。
传递到Context的连接
EF6之前版本
有两个接受Connection的构造方法：
public DbContext(DbConnection existingConnection, bool contextOwnsConnection)
public DbContext(DbConnection existingConnection, DbCompiledModel model, bool contextOwnsConnection)
使用上面两个方法的时候需要注意的限制：
1、如果使用上面任意一个方法，传递了一个已经打开的连接，则会在首次使用EF操作数据库时抛出一个InvalidOperationException异常，表示不能重复打开一个链接；
2、contextOwnsConnection参数指示在DbContext对象Dispose时候是否Dispose底层的数据库连接。无论参数是否设置，在DbContext.Dispose()时都会关闭底层的Connection。所以，如果你有超过一个DbContext使用同一连接，其中任何一个DbContext对象Dispose时都会关闭该连接（类似的，如果你将ADO.NET 和DbContext对象混合使用，在DbContect对象Dispose时也会关闭连接）。
可以通过传递一个关闭的连接，在创建的上下文中仅打开一次连接，且仅执行代码绕过上面第一条限制。如下：
using System.Collections.Generic;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.Infrastructure;
using System.Data.EntityClient;
using System.Linq; namespace ConnectionManagementExamples
{
class ConnectionManagementExampleEF5
{
public static void TwoDbContextsOneConnection()
{
using (var context1 = new BloggingContext())
{
var conn =
((EntityConnection)
((IObjectContextAdapter)context1).ObjectContext.Connection)
.StoreConnection; using (var context2 = new BloggingContext(conn, contextOwnsConnection: false))
{
context2.Database.ExecuteSqlCommand(
@"UPDATE Blogs SET Rating = 5" +
" WHERE Name LIKE '%Entity Framework%'"); var query = context1.Posts.Where(p => p.Blog.Rating > );
foreach (var post in query)
{
post.Title += "[Cool Blog]";
}
context1.SaveChanges();
}
}
}
}
}
第二个限制仅仅意味着你要确保确实要关闭连接后再调用DbContext.Dispose()。
EF6版本及更新版本
EF6和将来的版本的DbContext有两个与以往版本相同重载的构造方法，但是不在要求传递一个关闭的连接了。所以下面代码在EF6及以后版本是正确的：
using System.Collections.Generic;
using System.Data.Entity;
using System.Data.SqlClient;
using System.Linq;
using System.Transactions; namespace ConnectionManagementExamples
{
class ConnectionManagementExample
{
public static void PassingAnOpenConnection()
{
using (var conn = new SqlConnection("{connectionString}"))
{
conn.Open(); var sqlCommand = new SqlCommand();
sqlCommand.Connection = conn;
sqlCommand.CommandText =
@"UPDATE Blogs SET Rating = 5" +
" WHERE Name LIKE '%Entity Framework%'";
sqlCommand.ExecuteNonQuery(); using (var context = new BloggingContext(conn, contextOwnsConnection: false))
{
var query = context.Posts.Where(p => p.Blog.Rating > );
foreach (var post in query)
{
post.Title += "[Cool Blog]";
}
context.SaveChanges();
} var sqlCommand2 = new SqlCommand();
sqlCommand2.Connection = conn;
sqlCommand2.CommandText =
@"UPDATE Blogs SET Rating = 7" +
" WHERE Name LIKE '%Entity Framework Rocks%'";
sqlCommand2.ExecuteNonQuery();
}
}
}
}
还有，现在contextOwnsConnection参数决定是否要在DbContext对象Dispose时关闭并Dispose连接对象。因此，上面代码，在DbContext对象Dispose时，数据库并未关闭（32行），但在以前的版本在此处会关闭连接。上面代码会在第40行关闭并释放。
当然，如果你仍然可以让DbContext对象控制连接，把contextOwnsConnection设置为true，或者使用另一个构造方法。
Database.Connnection.Open()
EF6以前的版本
EF5及之前版本ObjectionContext.Connection.State状态更新存在BUG，该值不能正确反映底层连接的状态。例如执行下面代码，获取的状态为Closed，即使其底层确实为Open：
((IObjectContextAdapter)context).ObjectContext.Connection.State
另外，如果你通过调用Database.Connection.Open()打开数据库连接，数据库连接将一直打开，直到执行下次执行一个查询或者任何请求连接的操作（例如SaveChanges）。但是在此之后底层连接将会被关闭。那么Context将会因任意的数据库操作而重新打开连接并在之后重新关闭：
using System;
using System.Data;
using System.Data.Entity;
using System.Data.Entity.Infrastructure;
using System.Data.EntityClient; namespace ConnectionManagementExamples
{
public class DatabaseOpenConnectionBehaviorEF5
{
public static void DatabaseOpenConnectionBehavior()
{
using (var context = new BloggingContext())
{
// At this point the underlying store connection is closed context.Database.Connection.Open(); // Now the underlying store connection is open
// (though ObjectContext.Connection.State will report closed) var blog = new Blog { /* Blog’s properties */ };
context.Blogs.Add(blog); // The underlying store connection is still open context.SaveChanges(); // After SaveChanges() the underlying store connection is closed
// Each SaveChanges() / query etc now opens and immediately closes
// the underlying store connection blog = new Blog { /* Blog’s properties */ };
context.Blogs.Add(blog);
context.SaveChanges();
}
}
}
}
EF6及将来版本
在EF6和将来的版本中，框架采用的方案是如果代码通过context.Database.Connection.Open()打开一个数据库连接，有理由相信代码想要自己控制连接的打开和关闭，框架将不再自动关闭连接。
注意：这一特性可能造成数据库连接长时间打开，所以要特别留意，防止连接未及时关闭。
EF6中修复了ObjectContext.Connection.State状态更新的BUG。
using System;
using System.Data;
using System.Data.Entity;
using System.Data.Entity.Core.EntityClient;
using System.Data.Entity.Infrastructure; namespace ConnectionManagementExamples
{
internal class DatabaseOpenConnectionBehaviorEF6
{
public static void DatabaseOpenConnectionBehavior()
{
using (var context = new BloggingContext())
{
// At this point the underlying store connection is closed context.Database.Connection.Open(); // Now the underlying store connection is open and the
// ObjectContext.Connection.State correctly reports open too var blog = new Blog { /* Blog’s properties */ };
context.Blogs.Add(blog);
context.SaveChanges(); // The underlying store connection remains open for the next operation blog = new Blog { /* Blog’s properties */ };
context.Blogs.Add(blog);
context.SaveChanges(); // The underlying store connection is still open } // The context is disposed – so now the underlying store connection is closed
}
}
}
最新文章
- Spring bean 实现初始化、销毁方法的方式及顺序
- 19.C#逐一介绍IEnumerable和IEnumerable<T>中的扩展方法(10.3-10.5)
- C++ builder的文件操作
- 读书笔记2：HTTP协议
- storm-starter项目概述
- 1.js编程风格。 --- 编写可维护的javascript
- max_%_connection参数详解
- vijos 1942 [AH 2005] 小岛
- shell 批量获取ip 和主机名
- JAVA除法保留小数点后两位的两种方法
- oracle 12c centos 7 安装配置
- Java变成思想--多线程
- 【leetcode】409. Longest Palindrome
- pat--7-11 出栈序列的合法性（25 分）
- CVE-2017-8570漏洞利用
- weka连接mysql数据库
- Linux服务器安全之 fail2ban的安装与配置
- WPF中的动画
- AngularJs 表单提交按钮状态
- webgl学习笔记三-平移旋转缩放