Windows · 2010-05-25

NHibernate查询、更新、删除

[TestFixture]

public class UserFixture {
Configuration cfg;
ISessionFactory factory ;
readonly string userId=”test_user”;

//准备测试前的工作
[SetUp]
public void SetUp() {

//Configuration对象能够解析所有.Net对象和后台数据库中的映射 关系。
cfg = new Configuration();

//Configuration对象会搜索装配件里的任何以hbm.xml 结尾的文件,前提是
//*.hbm.xml要编译为“嵌套的资源”
cfg.AddAssembly(”NHibernate.Examples”);
factory = cfg.BuildSessionFactory();
}

[TearDown]

public void TearDown() {
//清除一些操作中生成的临时数据
}

///<summary>
///清除数据库中 Users表中的所有数据,提供一个干净的测试数据环境
///</summary>
[Test]
public void ClearData() {
//ISession对象提供一个到后台数据库的连接,参数由App.config指定
//ITransaction对象提供一个可以被NHibernate管理的事 务。
ISession session = factory.OpenSession();
ITransaction transaction = session.BeginTransaction();

//使用查询删除所有数据
session.Delete(”Select From User Where 1=1″);

transaction.Commit();

session.Close();

}

///<summary>
///测试往数据库中添加一个对象
///</summary>
[Test]
public void AddTest() {
ISession session = factory.OpenSession();
ITransaction transaction = session.BeginTransaction();

User newUser = new User();
newUser.Id = userId;
newUser.UserName = “SkyDev”;
newUser.Password = “abc123″;
newUser.EmailAddress = skydev@pyp.edu.cn;
newUser.LastLogon = DateTime.Now;
session.Save(newUser);

transaction.Commit();
session.Close();
}

///<summary>
///更新数据库中的对象
///</summary>
[Test]
public void UpdateTest() {
ISession session = factory.OpenSession();
ITransaction transaction = session.BeginTransaction();

User aUser;

try {

//当userId指定的数据在数据库中不存在时会抛出异常
aUser= (User)session.Load(typeof(User), userId);

// set Joe Cool’s Last Login property
aUser.LastLogon = DateTime.Now;

// flush the changes from the Session to the Database
session.Flush();

transaction.Commit();
}               catch {  transaction.Rollback(); }

finally {  session.Close(); }
}

///<summary>
///删除指定的对象
///</summary>
[Test]
public void DeleteTest() {
ISession session = factory.OpenSession();
ITransaction transaction = session.BeginTransaction();

User aUser;

try {
//当userId指定的数据在数据库中不存在时会抛出异常
aUser = session.Load(typeof(User), userId) as User;

if (aUser!=null) { session.Delete(aUser); }

transaction.Commit();
}

catch { transaction.Rollback();  }

finally { session.Close();  }

}

}

}

正如你所看到的,关于NHiberante重要的事情是如此简单。继续并且查询你的数据库,验证一下User表里的新记录。 现在重要的事情就是你去操心业务对象并在进行处理的时候告诉NHibernate就可以了。

让我们来告诉你,当你有一个UserID的时候如何获取对象(举 例说,登陆你的网站的时候)。仅仅一句话就可以打开Session,传入key就可以了

// open another session to retrieve the just inserted user
session = factory.OpenSession();
User joeCool = (User)session.Load(typeof(User), “joe_cool”);

你所获取的User对象还在生存周期内!改变它的属性,并通过Flush()持久化到数据库。

// set Joe Cool’s Last Login property
joeCool.LastLogon = DateTime.Now;

// flush the changes from the Session to the Database
session.Flush();

你所要做的就是通过NHibernate来进行你需要的改变,并调用Session的Flush()方法提 交。验证一下数据库,查查用户ID为”joe_cool”的记录中”LastLogon”的更改。

还有更好的,你可以以System.Collections.IList的方式来获取从表中的对象。如下
IList userList = session.CreateCriteria(typeof(User)).List();
foreach(User user in userList)
{
System.Diagnostics.Debug.WriteLine(user.Id + ” last logged in at ” + user.LastLogon);
}

这个查询将会返回所有表记录。往往你需要做更多的控制,比如说获取从March 14, 2004 10:00 PM 以后登陆的用户,如下:

IList recentUsers = session.CreateCriteria(typeof(User))
.Add(Expression.Expression.Gt(”LastLogon”, new DateTime(2004, 03, 14, 20, 0, 0)))
.List();

foreach(User user in recentUsers)
{
System.Diagnostics.Debug.WriteLine(user.Id + ” last logged in at ” + user.LastLogon);
}

文档里还有一堆健壮的查询方式让你调用,这里仅仅让你对NHibernate 所提供的强有力的工具有一定的了解。

最后调用Session对象的Close()方法,释放NHibernate所使用的ADO.Net连接资源
// tell NHibernate to close this Session
session.Close();