C#教程

关注公众号 jb51net

关闭
首页 > 软件编程 > C#教程 > EF的ObjectContext类

Entity Framework使用ObjectContext类

作者:springsnow

这篇文章介绍了Entity Framework使用ObjectContext类的方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

一、ObjectContext对象上下文

Entity SQL 语言 - ADO.NET | Microsoft 官当文档

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是访问或与概念模型中定义的实体一起工作的主要类。

3、类的结构:

ObjectContext类的成员方法

二、实体对象查询: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维护实体实例或关系实例的状态(已添加、已删除、已分离、已修改或未更改)、键值和原始值。还管理已修改属性的列表。

其包含以下方法:

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]);
}

五、ObjectQuery对象查询

可以在对象查询中使用esql

访问方式

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));
 }

到此这篇关于Entity Framework使用ObjectContext类的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文