当前位置:首页>>ASP.NET教程>>Asp.NET综合技巧>>nhibernate源码分析之三: 会话与持久化操作
nhibernate源码分析之三: 会话与持久化操作
2009/11/8 13:19:18
会话是nhibernate中的主要接口,也是我们进行持久化操作和数据加载的主要接口,ISession在IClassPersister、ITransaction、ICriteria和IQuery之间起着协调者的作用。


会话对象通过调用会话工厂的OpenSession方法获得,OpenSession方法有一个参数interceptor,这是一个拦截器,由实现了IInterceptor接口的对象来完成,比较典型的是对会话的操作进行日志记录。

1. 持久对象的状态

持久对象的状态由EntityEntry类来维护。

sealed internal class EntityEntry  {
   private LockMode _lockMode;
   private Status _status;
   private object _id;
   private object[] _loadedState;
   private object[] _deletedState;
   private bool _existsInDatabase;
   private object _version;
   // for convenience to save some lookups
   [NonSerialized] private IClassPersister _persister;
   private string _className;
   // ...
}
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的代码:

public void Flush() {
   if (cascading>0) throw new HibernateException( "..." );
   FlushEverything();
   Execute(); 
   PostFlush();
}Execute执行所有的计划对象。

private void Execute() {
   log.Debug("executing flush");
   try {
      ExecuteAll( insertions );
      insertions.Clear();
      ExecuteAll( updates );
      updates.Clear();

      //...

      ExecuteAll( deletions );
      deletions.Clear();
   }
   catch (Exception e) {
      throw new ADOException("...", e);
   }
}分别执行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(标识符)。

public object Save(object obj) {
   if (obj==null) throw new NullReferenceException("attempted to save null");

   if ( !NHibernate.IsInitialized(obj) )
      throw new PersistentObjectException("uninitialized proxy passed to save()");
   object theObj = UnproxyAndReassociate(obj); 

   EntityEntry e = GetEntry(theObj);
   if ( e!=null ) {
      if ( e.Status==Status.Deleted) {
         Flush();
      }
      else {
        log.Debug( "object already associated with session" );
        return e.Id;
      }
   }

   object id;
   try {
      id = GetPersister(theObj).IdentifierGenerator.Generate(this, theObj);
      if( id == (object) IdentifierGeneratorFactory.ShortCircuitIndicator)
         return GetIdentifier(theObj); //TODO: yick!
   }
   catch (Exception ex) {
      throw new ADOException("Could not save object", ex);
   }

   return DoSave(theObj, id);
}先取得持久对象的状态,如为删除则flush;然后取得持久对象的id(标识符),最后调用DoSave方法。
有关持久对象的标识符请参考我的下一篇文章 《持久对象标识符》。

public void Save(object obj, object id) {

   if (obj==null) throw new NullReferenceException("attemted to insert null");
   if (id==null) throw new NullReferenceException("null identifier passed to insert()");

   if ( !NHibernate.IsInitialized(obj) ) throw new PersistentObjectException("uninitialized proxy passed to save()");
   object theObj = UnproxyAndReassociate(obj); 

   EntityEntry e = GetEntry(theObj);
   if ( e!=null ) {
      if ( e.Status==Status.Deleted ) {
         Flush();
      }
      else {
         if ( !id.Equals(e.Id) )
            throw new PersistentObjectException("...");
      }
   }
   DoSave(theObj, id);
}与前一个Save方法不同的是,不用取得持久对象的id,显然这个方法适用于对象标识符已知的情况,这样会提高一些性能。

private object DoSave(object obj, object id) {
   IClassPersister persister = GetPersister(obj);

   Key key = null;
   bool identityCol;

   if (id==null) {
      if ( persister.IsIdentifierAssignedByInsert ) {
         identityCol = true;
      }
      else {
         throw new AssertionFailure("null id");
      }
   }
   else {
      identityCol = false;
   }

   if (!identityCol) {
      // if the id is generated by the db, we assign the key later
      key = new Key(id, persister);
      object old = GetEntity(key);
      if (old!=null) {
         if ( GetEntry(old).Status==Status.Deleted) {
            Flush();
         }
         else {
            throw new HibernateException( "...") );
 &nbs