会话是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=ObjectentitiesByKey集合保存当前会话中的所有持久对象。[NonSerialized] private IdentityMap entries;//key=Object, value=Entryentries集合维护当前会话中所有持久对象的状态,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();}// 未完待续... (内容: 基本的CRUD操作) 中国.Net俱乐部转载此文。让我们一起进步,共享人类技术资源。[www.chinaaspx.com]
|