连接管理Connection management

本页介绍了在将连接传递到上下文和数据库的功能时,实体框架的行为。

将连接传递到上下文Passing Connections to the Context

EF5 及更早版本的行为Behavior for EF5 and earlier versions

有两个接受连接的构造函数:

  1. public DbContext(DbConnection existingConnection, bool contextOwnsConnection)
  2. public DbContext(DbConnection existingConnection, DbCompiledModel model, bool contextOwnsConnection)

可以使用这些方法,但必须解决几个限制:

  1. 如果将打开的连接传递到其中的任何一个连接,则在框架第一次尝试使用它时,将引发 InvalidOperationException,指出它无法重新打开已打开的连接。
  2. ContextOwnsConnection 标志解释为在释放上下文时是否应释放基础存储连接。 但无论此设置如何,在释放上下文时,存储连接始终关闭。 因此,如果有多个具有相同连接的 DbContext,则在第一次处理上下文时将关闭连接(同样,如果已使用 DbContext 混合了现有的 ADO.NET 连接,DbContext 将始终在其释放时关闭连接).

通过传递关闭的连接并仅执行在创建所有上下文后将打开该连接的代码,可以绕过上述首个限制:

  1. using System.Collections.Generic;
  2. using System.Data.Common;
  3. using System.Data.Entity;
  4. using System.Data.Entity.Infrastructure;
  5. using System.Data.EntityClient;
  6. using System.Linq;
  7. namespace ConnectionManagementExamples
  8. {
  9. class ConnectionManagementExampleEF5
  10. {
  11. public static void TwoDbContextsOneConnection()
  12. {
  13. using (var context1 = new BloggingContext())
  14. {
  15. var conn =
  16. ((EntityConnection)
  17. ((IObjectContextAdapter)context1).ObjectContext.Connection)
  18. .StoreConnection;
  19. using (var context2 = new BloggingContext(conn, contextOwnsConnection: false))
  20. {
  21. context2.Database.ExecuteSqlCommand(
  22. @"UPDATE Blogs SET Rating = 5" +
  23. " WHERE Name LIKE '%Entity Framework%'");
  24. var query = context1.Posts.Where(p => p.Blog.Rating > 5);
  25. foreach (var post in query)
  26. {
  27. post.Title += "[Cool Blog]";
  28. }
  29. context1.SaveChanges();
  30. }
  31. }
  32. }
  33. }
  34. }

第二个限制是指您需要避免释放任何 DbContext 对象,直到您已准备好连接才能关闭。

EF6 和未来版本中的行为Behavior in EF6 and future versions

在 EF6 和未来的版本中,DbContext 具有相同的两个构造函数,但不再要求在收到时传递到构造函数的连接被关闭。 现在可以这样做:

  1. using System.Collections.Generic;
  2. using System.Data.Entity;
  3. using System.Data.SqlClient;
  4. using System.Linq;
  5. using System.Transactions;
  6. namespace ConnectionManagementExamples
  7. {
  8. class ConnectionManagementExample
  9. {
  10. public static void PassingAnOpenConnection()
  11. {
  12. using (var conn = new SqlConnection("{connectionString}"))
  13. {
  14. conn.Open();
  15. var sqlCommand = new SqlCommand();
  16. sqlCommand.Connection = conn;
  17. sqlCommand.CommandText =
  18. @"UPDATE Blogs SET Rating = 5" +
  19. " WHERE Name LIKE '%Entity Framework%'";
  20. sqlCommand.ExecuteNonQuery();
  21. using (var context = new BloggingContext(conn, contextOwnsConnection: false))
  22. {
  23. var query = context.Posts.Where(p => p.Blog.Rating > 5);
  24. foreach (var post in query)
  25. {
  26. post.Title += "[Cool Blog]";
  27. }
  28. context.SaveChanges();
  29. }
  30. var sqlCommand2 = new SqlCommand();
  31. sqlCommand2.Connection = conn;
  32. sqlCommand2.CommandText =
  33. @"UPDATE Blogs SET Rating = 7" +
  34. " WHERE Name LIKE '%Entity Framework Rocks%'";
  35. sqlCommand2.ExecuteNonQuery();
  36. }
  37. }
  38. }
  39. }

此外,contextOwnsConnection 标志现在控制在释放 DbContext 时是否关闭并释放连接。 因此,在上述示例中,当上下文被释放(行32)时,连接将不会关闭,因为它已在 EF 的以前版本中,而是在断开连接本身的情况下(第40行)。

当然,DbContext 仍有可能控制连接(只需将 contextOwnsConnection 设置为 true,或者使用其他构造函数之一)。

备注

在此新模型中使用事务时,还有一些其他注意事项。 有关详细信息,请参阅使用事务

Connection. Open ()Database.Connection.Open()

EF5 及更早版本的行为Behavior for EF5 and earlier versions

在 EF5 及更早版本中,存在一个 bug,以便不会更新ObjectContext ,以反映基础存储连接的真实状态。 例如,如果执行了下面的代码,则可以将状态视为已关闭,即使基础存储连接已打开

  1. ((IObjectContextAdapter)context).ObjectContext.Connection.State

另外,如果您通过调用 “数据库连接” 打开数据库连接(),则在下一次执行查询或调用需要数据库连接的任何内容(例如 SaveChanges ())之后但在底层存储区之后,就会打开数据库连接。连接将关闭。 然后,上下文将重新打开并在每次需要另一数据库操作时重新关闭连接:

  1. using System;
  2. using System.Data;
  3. using System.Data.Entity;
  4. using System.Data.Entity.Infrastructure;
  5. using System.Data.EntityClient;
  6. namespace ConnectionManagementExamples
  7. {
  8. public class DatabaseOpenConnectionBehaviorEF5
  9. {
  10. public static void DatabaseOpenConnectionBehavior()
  11. {
  12. using (var context = new BloggingContext())
  13. {
  14. // At this point the underlying store connection is closed
  15. context.Database.Connection.Open();
  16. // Now the underlying store connection is open
  17. // (though ObjectContext.Connection.State will report closed)
  18. var blog = new Blog { /* Blog’s properties */ };
  19. context.Blogs.Add(blog);
  20. // The underlying store connection is still open
  21. context.SaveChanges();
  22. // After SaveChanges() the underlying store connection is closed
  23. // Each SaveChanges() / query etc now opens and immediately closes
  24. // the underlying store connection
  25. blog = new Blog { /* Blog’s properties */ };
  26. context.Blogs.Add(blog);
  27. context.SaveChanges();
  28. }
  29. }
  30. }
  31. }

EF6 和未来版本中的行为Behavior in EF6 and future versions

对于 EF6 和更早的版本,如果调用代码选择通过调用上下文来打开连接,我们采用了这种方法。然后打开(),它有一个很好的理由来完成此操作,框架将假定它要控制连接的打开和关闭,并且将不再自动关闭连接。

备注

这可能会导致连接长时间处于打开状态,因此请谨慎使用。

我们还更新了代码,使 ObjectContext 连接状态立即跟踪基础连接的状态。

  1. using System;
  2. using System.Data;
  3. using System.Data.Entity;
  4. using System.Data.Entity.Core.EntityClient;
  5. using System.Data.Entity.Infrastructure;
  6. namespace ConnectionManagementExamples
  7. {
  8. internal class DatabaseOpenConnectionBehaviorEF6
  9. {
  10. public static void DatabaseOpenConnectionBehavior()
  11. {
  12. using (var context = new BloggingContext())
  13. {
  14. // At this point the underlying store connection is closed
  15. context.Database.Connection.Open();
  16. // Now the underlying store connection is open and the
  17. // ObjectContext.Connection.State correctly reports open too
  18. var blog = new Blog { /* Blog’s properties */ };
  19. context.Blogs.Add(blog);
  20. context.SaveChanges();
  21. // The underlying store connection remains open for the next operation
  22. blog = new Blog { /* Blog’s properties */ };
  23. context.Blogs.Add(blog);
  24. context.SaveChanges();
  25. // The underlying store connection is still open
  26. } // The context is disposed – so now the underlying store connection is closed
  27. }
  28. }
  29. }