持久化操作由与持久对象关联的持久化类来完成,持久化类是实现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