nhibernate: 会话与持久化操作
会话是nhibernate中的主要接口,也是我们进行持久化操作和数据加载的主要接口,ISession在IClassPersister、ITransaction、ICriteria和IQuery之间起着协调者的作用。
会话对象通过调用会话工厂的OpenSession方法获得,OpenSession方法有一个参数interceptor,这是一个拦截器,由实现了IInterceptor接口的对象来完成,比较典型的是对会话的操作进行日志记录。
1. 持久对象的状态
持久对象的状态由EntityEntry类来维护。
private IDictionary entitiesByKey; //key=Key, value=Object
entitiesByKey集合保存当前会话中的所有持久对象。
[NonSerialized] private IdentityMap entries;//key=Object, value=Entry
entries集合维护当前会话中所有持久对象的状态,entries中的项目和entitiesByKey中的项目是一一对应的。
2. 持久化操作
当执行持久化操作时(Save/Update/Delete),除了少数情况外,持久化操作并没有立即执行(更新数据源),而是被记录下来,直到会话Flush时才会实际更新到数据源,这样做的原因很容易理解,就是为了避免频烦的数据库连接操作。如果没有调用Flush而关闭了会话,当前会话中的持久对象将不会持久化!
SessionImpl.cs中有三个集合用来记录要持久化的计划对象:
[NonSerialized] private ArrayList insertions;
记录所有的ScheduledInsertion对象,ScheduledInsertion对象是通过要Save的持久对象创建的,如果对象的标识必须从数据库获得(如Identity标识),那么并不会创建ScheduledInsertion对象,而是立即执行Save操作,原因很简单,因为必须取得Identity标识;
[NonSerialized] private ArrayList updates;
记录所有的ScheduledUpdate对象,ScheduledUpdate对象是通过要Update的持久对象创建的;
[NonSerialized] private ArrayList deletions;
记录所有的ScheduledDeletion对象,ScheduledDeletion对象是通过要Delete的持久对象创建的;
以上三个计划对象都从ScheduledEntityAction对象继承,而此对象实现了IExecutable接口,IExecutable接口的Execute方法用于执行执久化操作,此操作由Flush间接调用。
下面来看看Flush的代码:
Execute执行所有的计划对象。
分别执行insert/update/delete计划。
private void ExecuteAll(ICollection coll) {
foreach(IExecutable e in coll) {
executions.Add(e);
e.Execute();
}
if ( batcher!=null ) batcher.ExecuteBatch();
}
3. Save
ISession有两种保存持久对象的方法,区别在于有没有指定对象Id(标识符)。
先取得持久对象的状态,如为删除则flush;然后取得持久对象的id(标识符),最后调用DoSave方法。
有关持久对象的标识符请参考我的下一篇文章 《持久对象标识符》。
与前一个Save方法不同的是,不用取得持久对象的id,显然这个方法适用于对象标识符已知的情况,这样会提高一些性能。
DoSave方法首先判断id是否为赋值的(assign),然后将持久对象加入到当前会话的集合中。
如果id为identity类型的,则直接调用持久对象的持久化类来插入数据,否则将持久对象加入到insertions集合中,直到调用Flush时才插入数据。
4. Update
Update的处理基本上同Create是类似的,但值得注意的是Update方法并没有将持久对象加入到updates集合中,而是在执行Flush的时候通过判断持久对象的属性来决定持久对象是否需要Update。
5. Delete
Delete的处理比较复杂一些,包括处理集合和级联,这里就不贴出代码了。关于集合和级联处理我会在后续文章中进行分析。