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是訪問或與概念模型中定義的實體一起工作的主要類。
- 到數據庫的連接,以 EntityConnection 對象的形式封裝。
- 描述該模型的元數據,以 MetadataWorkspace 對象的形式封裝。
- 用於管理緩存中持久保存的對象的 ObjectStateManager 對象。
3、類的結構:
ObjectContext類的成員方法
- Attach(string,object):將實體對象附加到指定的實體容器中
- AddObject(string,object):將實體對象添加到制定的實體容器中
- Detach(object):移除指定的實體對象
- DeleteObject(object):刪除指定的實體對象
- GetObjectByKey(System.Data.EntityKey key):通過主鍵KEY從ObjectStateManager中檢索對象(如果存在);否則從存儲區中檢索。
- TryGetObjectByKey(System.Data.EntityKey,out object):嘗試從指定實體主鍵返回該實體
- ApplyPropertyChanges(string,object):將以指派的實體對象屬性的更改應用到容器中對應的原對象。
- AcceptAllChanges():接受所有對該實體對象的更改
- SaveChanges(bool):將所有更新持久保存到存儲區中。參數是客戶端事務支持所需的參數。參數為true則在更新後自動將更改應用到ObjectStateManager中的實體。如果為false,則在更新後還需要調用AcceptAllChanges()以便更新ObjectStateManager中的實體。
- Refresh(System.Data.Objects.RefreshMode refreshMode, object entity):按指定持久更新模式,使用指定實體的存儲區數據更新ObjectStateManager。
- CreateQuery(string,params ObjectParameter[]):從給定的查詢字符串創建ObjectQuery對象。
- 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]); }
五、ObjectQuery對象查詢
- ObjectQuery 提供瞭一個管理[實體對象]集合的方法。
- 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)); }
到此這篇關於Entity Framework使用ObjectContext類的文章就介紹到這瞭。希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。
推薦閱讀:
- Entity Framework模型優先與實體對象查詢
- Entity Framework使用LINQ操作實體
- C#新特性之可空引用類型
- C#使用CallContext緩存線程數據
- C# 泛型List排序的實現