Entity Framework（02）：模型优先 ,ObjectContext类

一、ObjectContext对象上下文

Entity SQL 语言 - ADO.NET | Microsoft Docs

ObjectContext提供了管理数据的功能。

1、ObjectContext和DbContext的对比

1、从DbContext访问底层的ObjectContext

AdventureWorks2012Entities ctx = new AdventureWorks2012Entities();
ObjectContext ctxObj = ((IObjectContextAdapter)ctxNew).ObjectContext;

2、创建ObjectSet

AdventureWorks2012Entities ctx = new AdventureWorks2012Entities();//对象上下文
ObjectContext ctxObj = ((IObjectContextAdapter)ctx).ObjectContext;

ObjectSet objectSet = ctxObj.CreateObjectSet("Person");

2、ObjectContext类的实例封装的内容

ObjectContext 封装.NET Framework和数据库之间的连接。此类用作“创建”、“读取”、“更新”和“删除”操作的网关。

ObjectContext是一个类，用于管理所有数据库操作（如数据库连接），并管理实体模型的各种实体。我们可以说ObjectContext是访问或与概念模型中定义的实体一起工作的主要类。

• 到数据库的连接，以 EntityConnection 对象的形式封装。
• 描述该模型的元数据，以 MetadataWorkspace 对象的形式封装。
• 用于管理缓存中持久保存的对象的 ObjectStateManager 对象。

3、类的结构：

ObjectContext类的成员方法

1. Attach(string,object)：将实体对象附加到指定的实体容器中
2. AddObject(string,object)：将实体对象添加到制定的实体容器中
3. Detach(object)：移除指定的实体对象
4. DeleteObject(object)：删除指定的实体对象
5. GetObjectByKey(System.Data.EntityKey key)：通过主键KEY从ObjectStateManager中检索对象（如果存在）；否则从存储区中检索。
6. TryGetObjectByKey(System.Data.EntityKey,out object)：尝试从指定实体主键返回该实体
7. ApplyPropertyChanges(string,object)：将以指派的实体对象属性的更改应用到容器中对应的原对象。
8. AcceptAllChanges()：接受所有对该实体对象的更改
9. SaveChanges(bool)：将所有更新持久保存到存储区中。参数是客户端事务支持所需的参数。参数为true则在更新后自动将更改应用到ObjectStateManager中的实体。如果为false，则在更新后还需要调用AcceptAllChanges（）以便更新ObjectStateManager中的实体。
10. Refresh(System.Data.Objects.RefreshMode refreshMode, object entity)：按指定持久更新模式，使用指定实体的存储区数据更新ObjectStateManager。
11. CreateQuery(string,params ObjectParameter[])：从给定的查询字符串创建ObjectQuery对象。
12. ExecuteFunction(string,params ObjectParameter[])：对默认容器执行给定的函数。

二、实体对象查询：linq to Entities

并非所有的LINQ标准查询运算符都支持 linq to Entities 查询。

1、AddObject ：添加实体

将实体添加到集合中,创建实体时,状态为EntityState.Detached。

当调用AddObject将实体添加到Context时,状态为EntityState.Added

myContext context = new myContext(); 
myTab r = new myTab();
r.ID = 10;
r.a = "wxwinter"; 
Console.WriteLine(r.EntityState); //print:Detached 
context.AddTomyTab(r); 
Console.WriteLine(r.EntityState); //print:Added 
context.SaveChanges();

myContext context = new myContext(); 
myTab newrow = new myTab() { a = "wxd", b = "lzm", c = "wxwinter" }; 
context.AddObject("myTab",newrow); 
context.SaveChanges();

2、DeleteObject： 删除实体

将集合中的实体添标记为删除。

当调用Context.DeleteObject时,并不是将实体移除集合,而是将实体添标记为EntityState.Deleted ,在下次调用SaveChanges()方法时跟新数据库

myContext context = new myContext(); 
myTab r = context.myTab.First(p=>p.ID==1); 
Console.WriteLine(r.EntityState); //print:Unchanged 
context.DeleteObject(r); 
Console.WriteLine(r.EntityState); //print:Deleted 
context.SaveChanges();

3、Detach： 分离实体

将实体从Context中分离,将状态标记为EntityState.Detached 。

myContext context = new myContext();  
myTab r = myTab.CreatemyTab(22);  
Console.WriteLine(r.EntityState); //print:Detached  
context.AddTomyTab(r);  
Console.WriteLine(r.EntityState); //print:Added  
context.Detach(r); 
Console.WriteLine(r.EntityState); //print: Detached

4、修改实体

可以直接修在实体对象上修改。

当修改在Context中的实体时,会将实体的状态标记为EntityState.Modified

myContext context = new myContext();  
myTab r = context.myTab.First(p=>p.ID==1);
Console.WriteLine(r.EntityState); //print:Unchanged
r.a = "wxwinter";
Console.WriteLine(r.EntityState); //print:Modified  
context.SaveChanges();

5、保存到数据库

int changes = 0;
try
{
    changes += ctx.SaveChanges();
}
catch (OptimisticConcurrencyException ex)
{
    ctx.Refresh(System.Data.Objects.RefreshMode.ClientWins, ex.StateEntries);
    changes += ctx.SaveChanges();
}
Console.WriteLine("实体改变数量" + changes);

三、对象状态管理

1、ObjectStateEntry对象状态实体

ObjectStateEntry维护实体实例或关系实例的状态（已添加、已删除、已分离、已修改或未更改）、键值和原始值。还管理已修改属性的列表。

其包含以下方法：

• AcceptChanges()：接受当前值作为原始值，并将实体标记为Unchanged()。
• Delete()：将实体标记为Deleted()。如果实体处于Added()()()状态，它将为Detached()。
• GetModifiedProperties()：返回标记为Modified()的属性名称。
• SetModified()：将状态设置为Modified()。
• SetModifiedProperty()：将指定的属性标记为Modified()。

2、ObjectStateManager对象状态管理器

ObjectStateManager用于维护对象映射、对象状态/标识管理以及实体实例或关系实例的持久性。

1、GetObjectStateEntries：获取给定EntityState的ObjectStateEntry集合。

IEnumerable<ObjectStateEntry> oseList = ctx.ObjectStateManager.GetObjectStateEntries(EntityState.Added);
foreach (ObjectStateEntry ose in oseList)
{
    Console.WriteLine("{0},{1},{2},{3}", ose.State, ose.CurrentValues["ID"], ose.EntitySet.Name, ose.Entity);
}

2、GetObjectStateEntry：获取给定的EntityKey对应的ObjectStateEntry

myContext ctx = new myContext();
myTab r = ctx.myTab.First(p => p.ID == 1);
r.a = "wxwinter";
ObjectStateEntry ose = context.ObjectStateManager.GetObjectStateEntry(r.EntityKey);

Console.WriteLine(ose.State);
foreach (string pr in ose.GetModifiedProperties())
{
    Console.WriteLine(pr);
    Console.WriteLine("CurrentValues :{0}", ose.CurrentValues[pr]);
    Console.WriteLine("OriginalValues:{0}", ose.OriginalValues[pr]);
}

详细介绍：https://www.cnblogs.com/ejiyuan/archive/2009/05/27/1490786.html

五、ObjectQuery对象查询

1. ObjectQuery 提供了一个管理[实体对象]集合的方法。
2. ObjectQuery对ObjectContext进行了封装。

可以在对象查询中使用esql

• e关键字：“e”出现在 ESQL 中, 由 ObjectQuery.Name 属性设定，用于标示源查询对象(ObjectQuery)的名称，可以将这个默认值 "e" 改成其他字符串。
• value关键字：value后只能返回一个成员。
• 查询参数：ObjectParameter v1 = new ObjectParameter("v1", 3);

访问方式

1、Context.CreateQuery("esql")创建ObjectQuery。

可以通过ObjectContext.CreateQuery("esql")的方式创建ObjectQuery。

AdventureWorks2012Entities ctx = new AdventureWorks2012Entities();//对象上下文
ObjectContext ctxObj = (ctx as IObjectContextAdapter).ObjectContext;
// ObjectQuery query = new ObjectQuery("select * from..", ctxObj);  
ObjectQuery queryTab = ctxObj.CreateQuery("select  value e  from Person as e  where e.FirstName like 'A%'"); 

Console.WriteLine(queryTab .ToTraceString());
foreach (Person r in queryTab )
{
    Console.WriteLine(r.FirstName);
}

2、new ObjectQuery(ObjectContext,"esql")创建ObjectQuery

可以通过new ObjectQuery(ObjectContext,"esql")的方式创建ObjectQuery,会跟据SQL字串的不同，得到具体的ObjectQuery<值类型>，或ObjectQuery或ObjectQuery<实体>

string econString = @"metadata=res://*/Model1.csdl|res://*/Model1.ssdl|res://*/Model1.msl;provider=System.Data.SqlClient;provider connection string=""data source=(LocalDb)v11.0;initial catalog=AdventureWorks2012;integrated security=True;MultipleActiveResultSets=True;App=EntityFramework""";
EntityConnection econ = new EntityConnection(econString);
ObjectContext ctxObj = new ObjectContext(econ);//使用ObjectContext封装EntityConnection 
ObjectQuery queryTab = new ObjectQuery("select  e.FirstName,e.LastName  from AdventureWorks2012Entities.Person as e  where e.FirstName like 'A%'", ctxObj );

foreach (var r in queryTab)
{

    System.Console.WriteLine("{0},{1}", r[0].ToString(), r[1].ToString());

}

3、ObjectQuery<简单类型>

ObjectQuery<int> queryTab = new ObjectQuery<int>("select value Count(e.BusinessEntityID) from AdventureWorks2012Entities.Person as e", ctxObj );
foreach (var r in queryTab)
{
    System.Console.WriteLine("个数:{0}", r.ToString());
}

4、Linq查询

ObjectQuery queryTab = ctxObj.CreateQuery("select  value e  from AdventureWorks2012Entities.Person as e  where e.FirstName like 'A%'");//这以后的linq查询条件可合并为一个SQL
IQueryable queryTab2 = queryTab.Where(p => p.FirstName.StartsWith("A")).OrderBy(p => p.LastName);
foreach (var r in queryTab2)
{
    System.Console.WriteLine("{0},{1}", r.FirstName, r.LastName);
}

5、ToTraceString()：跟踪SQL语句

这个方法用于追踪所执行的SQL语句，通过此方法我们可以获取所执行的SQL语句，以便我们查看、分析具体执行的SQL语句。

6、ObjectQuery.Execute()方法

返回ObjectResult结果集

ObjectQuery queryTab = ctxObj .CreateQuery("select  value e  from AdventureWorks2012Entities.Person as e  where e.FirstName like 'A%'");
ObjectResult resultTab = queryTab.Execute(MergeOption.NoTracking);
foreach (var r in resultTab)
{
    System.Console.WriteLine("{0},{1}", r.FirstName, r.LastName);
}

7、Entity Client方式查询

不需要使用ObjectContext实例！！ Entity Client使用esql。

//不需要使用ObjectContext实例！！

string esql = "select  value e  from AdventureWorks2012Entities.Person as e  where e.FirstName like 'A%'";//获取所有列，不能使用Select * 
 EntityConnection conn = new EntityConnection("name=AdventureWorks2012Entities");
 conn.Open();
 EntityCommand cmd = conn.CreateCommand();
 cmd.CommandText = esql;
 EntityDataReader dr = cmd.ExecuteReader(CommandBehavior.SequentialAccess);
 while (dr.Read())
 {
     MessageBox.Show(dr.GetValue(0) + "," + dr.GetValue(1));
 }