日期:2009-10-07  浏览次数:20417 次

持久化操作由与持久对象关联的持久化类来完成,持久化类是实现IClassPersister接口的类,每个持久对象都有一个关联的持久化类,这些持久化类存储在会话工厂的classPersisters集合中,nhibernate允许用户通过自定义的持久化类来持久化数据。


IClassPersister接口定义了基本的CRUD操作,在nhibernate中由AbstractEntityPersister类实现,这是一个抽象类,有两个具体的派生类,分别是:EntityPersister和normalizedEntityPersister,前者用于一个表一个类的情况,后面用于一个表一个子类的情况。

在分析持久化操作之前先来介绍几个辅助类:

1. SqlString: 用于构造IDbCommand对象;
2. SqlStringBuilder: 用于构造SqlString对象;
3. SqlInsertBuilder: 用于构造Insert操作的SqlString对象;
4. SqlUpdateBuilder: 用于构造Update操作的SqlString对象;
5. SqlDeleteBuilder: 用于构造Delete操作的SqlString对象;
6. Parameter: 用于转换到实现IDbParameter接口对象;
7. IPrepare: 用于准备和存储IDbCommand接口,由PrepareImpl实现。

下面以一个有identity符识的对象为例说明其持久化的流程。

一. Insert

因为持久对象有identity标识符,所以执行Save操作时,是立即调用持久对象的持久化类来执行Insert操作,而不是加入到计划集合中(原因请参考 nhibernate源码分析之三)。但最终的处理方式是一致的。

//*** EntityPersister.cs ***

public override void Insert(object[] fields, object obj, ISessionImplementor session) {
   if(UseDynamicInsert) {
      bool[] notNull = GetNotNullInsertableColumns(fields);
      Insert(fields, notNull, GenerateInsertString(false, notNull), obj, session);
   }
   else {
      Insert(fields, PropertyInsertability, SqlInsertString, obj, session);
   }
}Insert方法首先检查是否使用dynamic-insert(动态插入),如使用则只插入非空的字段,dynamic-insert可在映射文件中指定;然后通过GenerateInsertString方法取得insert操作的SqlString。

protected virtual SqlString GenerateInsertString(bool identityInsert, bool[] includeProperty) {
   SqlInsertBuilder builder = new SqlInsertBuilder(factory);
   builder.SetTableName(TableName);

   for(int i = 0 ; i < hydrateSpan; i++) {
      if(includeProperty[i]) builder.AddColumn(propertyColumnNames[i], PropertyTypes[i]);
   }    

   if (IsPolymorphic) builder.AddColumn(DiscriminatorColumnName, DiscriminatorSQLString);

   if(identityInsert==false) {
      builder.AddColumn(IdentifierColumnNames, IdentifierType);
   }
   else {
      if(dialect.IdentityInsertString!=null) {
         builder.AddColumn(IdentifierColumnNames[0], dialect.IdentityInsertString);
      }
   }

   return builder.ToSqlString();
}首先构造一个SqlInsertBuilder对象,然后加入所有要插入的字段,hydrateSpan在AbstractEntityPersister类中定义,是持久对象的属性Count;然后判断持久对象是否为Polymorphic(通过字段值实现多态),如是则加入辨别列,辨别值可通过映射文件中的discriminator-value来指定;接着判断是否要加入标识列,最后返回一个SqlString对象。注意:在ToSqlString方法中,可以看到我们熟悉的INSERT INTO语句。

SqlInsertBuilder类的AddColumn方法有多个重载,这里只列出比较重要的一个(加入参数列)。

//*** SqlInsertBuilder.cs ***
  
public SqlInsertBuilder AddColumn(string[] columnNames, IType propertyType) {
   Parameter[] parameters = Parameter.GenerateParameters(factory, columnNames, propertyType);

   for(int i = 0; i < columnNames.Length; i++) {
      this.columnNames.Add(columnNames[i]);
      columnValues.Add(parameters[i]);
   }
   
   return this;
}通过Parameter的静态方法GenerateParameters创建Parameter,然后加入到集合中。

//*** EntityPersister.cs ***

public object Insert(object[] fields, bool[] notNull, SqlString sql,
      object obj, ISessionImplementor session) {

   IDbCommand statement = null;
   IDbCommand idSelect = null;

   if(dialect.SupportsIdentitySelectInInsert) {
      statement = session.Preparer.PrepareCommand( dialect.AddIdentitySel