[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 = [email protected];
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();