找回密码
 立即注册
首页 业界区 业界 NHibernate之旅(5):探索Insert, Update, Delete操作 ...

NHibernate之旅(5):探索Insert, Update, Delete操作

茅断卉 2025-5-30 01:46:33
本节内容
           
  • 操作数据概述       
  • 1.新建对象       
  • 2.删除对象       
  • 3.更新对象       
  • 4.保存更新对象       
  • 结语
操作数据概述

我们常常所说的一个工作单元,通常是执行1个或多个操作,对这些操作要么提交要么放弃/回滚。想想使用LINQ to SQL,一切的东西都在内存中操作,只有调用了DataContext.SubmitChanges()方法才把这些改变的数据提交到数据库中,LINQ to SQL那么提交要么回滚。
我们使用NHibernate也一样,如果只查询数据,不改变它的值,就不需要提交(或者回滚)到数据库。
注意:这节,我们在上一节源代码的基础上,在数据访问层中新建CRUD.cs类用于编写操作方法,在数据访问的测试层新建一CRUDFixture.cs类用于测试。
1.新建对象

简单描述:新建一个对象;调用ISession.Save();同步ISession。
例子:在数据访问层编写CreateCustomer()方法,把传过来的Customer对象保存在数据库中。
  1. public int CreateCustomer(Customer customer)
  2. {
  3.     int newid = (int)_session.Save(customer);
  4.     _session.Flush();
  5.     return newid;
  6. }
复制代码
我们测试这个方法,新建一个Customer对象,调用CreateCustomer()方法返回新插入的CustomerId,再次根据CustomerId查询数据库是否存在这个对象。
  1. [Test]
  2. public void CreateCustomerTest()
  3. {
  4.     var customer = new Customer() { Firstname = "YJing", Lastname = "Lee" };
  5.     int newIdentity = _crud.CreateCustomer(customer);
  6.     var testCustomer = _crud.GetCustomerById(newIdentity);
  7.     Assert.IsNotNull(testCustomer);
  8. }
复制代码
2.删除对象

简单描述:获取一个对象;调用ISession.Delete();同步ISession。
说明:使用ISession.Delete()会把对象的状态从数据库中移除。当然,你的应用程序可能仍然持有一个指向它的引用。所以,最好这样理解:Delete()的用途是把一个持久化实例变成临时实例。 你也可以通过传递给Delete()一个NHibernate 查询字符串来一次性删除很多对象。删除对象顺序没有要求,不会引发外键约束冲突。当然,有可能引发在外键字段定义的NOT NULL约束冲突。
例子:在数据访问层编写DeleteCustomer()方法,从数据库中删除Customer对象。
  1. public void DeleteCustomer(Customer customer)
  2. {
  3.     _session.Delete(customer);
  4.     _session.Flush();
  5. }
复制代码
我们测试这个方法,在数据库中查询CustomerId为2的Customer对象,调用DeleteCustomer()方法删除,再次根据CustomerId查询数据库是否存在这个对象。
  1. [Test]
  2. public void DeleteCustomerTest()
  3. {
  4.     var coutomer = _crud.GetCustomerById(2);
  5.     _crud.DeleteCustomer(coutomer);
  6.     var testCustomer = _crud.GetCustomerById(2);
  7.     Assert.IsNull(testCustomer);
  8. }
复制代码
3.更新对象

简单描述:获取一个对象;改变它的一些属性;调用ISession.Update();同步ISession。
例子:在数据访问层编写UpdateCustomer()方法,修改Customer对象。
  1. public void UpdateCustomer(Customer customer)
  2. {
  3.     _session.Update(customer);
  4.     _session.Flush();
  5. }
复制代码
测试这个方法,在数据库中查询CustomerId为1的Customer对象并修改它的Firstname属性值,调用UpdateCustomer()方法更新,再次查询数据库中CustomerId为1的Customer对象的Firstname值为修改之后的值。
  1. [Test]
  2. public void UpdateCustomerTest()
  3. {
  4.     var customer = _crud.GetCustomerById(1);
  5.     customer.Firstname = "liyongjing";
  6.     _crud.UpdateCustomer(customer);
  7.     var testCustomer = _crud.GetCustomerById(1);
  8.     Assert.AreEqual("liyongjing", customer.Firstname);
  9. }
复制代码
4.保存更新对象

你会不会想出这个问题?哪些是刚刚创建的对象,哪些是修改过的对象?对于刚刚创建的对象我们需要保存到数据库中,对于修改过的对象我们需要更新到数据库中。
幸好,ISession可以识别出这不同的对象,并为我们提供了ISession.SaveOrUpdate(object)方法
ISession.SaveOrUpdate(object)方法完成如下工作:
           
  • 检查这个对象是否已经存在Session中。       
  • 如果对象不在,调用Save(object)来保存。       
  • 如果对象存在,检查这个对象是否改变了。       
  • 如果对象改变,调用Update(object)来更新。
看看下面例子说明了这种情况,在数据访问层编写SaveOrUpdateCustomer()方法,保存更新Customer对象列表,依次遍历列表中的Customer对象,调用ISession.SaveOrUpdate(object)方法保存更新每个Customer对象。
  1. public void SaveOrUpdateCustomer(IList<Customer> customer)
  2. {
  3.     foreach (var c in customer)
  4.     {
  5.         _session.SaveOrUpdate(c);
  6.     }
  7.     _session.Flush();
  8. }
复制代码
测试这个方法,先在数据库中查询Firstname为YJing的Customer对象并修改它的Lastname属性值,这些对象是数据库中存在的,并改变了,然后新建2个Customer对象,这两个对象在数据库中不存在,是新创建的。调用SaveOrUpdateCustomer()方法保存更新对象,即更新前面修改的对象和保存了后面新创建的2个对象。再次查询数据库中Firstname为YJing,Lastname为YongJing的Customer对象是否一致了。
  1. [Test]
  2. public void SaveOrUpdateCustomerTest()
  3. {
  4.     IList<Customer> customers = _crud.GetCustomersByFirstname("YJing");
  5.     foreach (var c in customers)
  6.     {
  7.         c.Lastname = "YongJing";
  8.     }
  9.     var c1 = new Customer() { Firstname = "YJing", Lastname = "YongJing"};
  10.     var c2 = new Customer() { Firstname = "YJing", Lastname = "YongJing"};
  11.     customers.Add(c1);
  12.     customers.Add(c2);
  13.     int initiaIListCount = customers.Count;
  14.     _crud.SaveOrUpdateCustomer(customers);
  15.     int testListCount = _crud.GetCustomersByFirstnameAndLastname("YJing", "YongJing").Count;
  16.     Assert.AreEqual(initiaIListCount, testListCount);
  17. }
复制代码
结语

当然,这一节操纵对象操作,在NHibernate中涉及了对象的状态,对象对一个特定的ISession来说,有三种状态分别是:瞬时(transient)对象、持久化(persistent)对象、游离(detached)对象。这一节没有说到了,以后在讨论Session的时候再介绍。
本系列链接:NHibernate之旅系列文章导航
NHibernate Q&A
           
  • 欢迎加入NHibernate中文社区,一起讨论NHibernate知识!       
  • 请到NHibernate中文社区下载本系列相关源码。
下次继续分享NHibernate!

来源:程序园用户自行投稿发布,如果侵权,请联系站长删除
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!

相关推荐

您需要登录后才可以回帖 登录 | 立即注册