NHibernate - 没有显式更新的意外更新答案

【问题标题】：NHibernate - Unexpected update without explicit updateNHibernate - 没有显式更新的意外更新
【发布时间】：2011-01-17 22:10:20
【问题描述】：

在对父集合执行 SQL 选择时，在其中包含一个项目的子集合被延迟加载后，之后会为此子集合执行更新语句 - 无需显式调用 update.

父映射：

<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
    namespace="ParentEntity" 
    assembly="ParentEntity">

  <class name="ParentEntity" table="ParentEntity">

    <id name="Id" column="ParentEntityId" unsaved-value="-1">
      <generator class="identity"/>
    </id>

    <bag name="addresses" access="field" inverse="true" cascade="all-delete-orphan" where="IsDeleted = 0">
      <key column="ParentEntityId"/>
      <one-to-many class="Address"/>
    </bag>

  </class>

</hibernate-mapping>

实施：

public class ParentEntity : IEntity<ParentEntity>, IAuditableEntity, IDeletableEntity
{

    private ICollection<Address> addresses;


    protected ParentEntity()
    {
        addresses = new List<Address>();

    }



    public virtual ICollection<Address> Addresses
    {
        get
        {
            return new List<Address>(addresses.Where(a => !a.IsDeleted && !a.Validity.IsExpired)).AsReadOnly();
        }
        private set
        {
            addresses = value;
        }
    }

    public virtual ICollection<Address> ExpiredAddresses
    {
        get
        {
            return new List<Address>(addresses.Where(a => !a.IsDeleted && a.Validity.IsExpired)).AsReadOnly();
        }
    }



    #region IAuditableEntity Members

    public virtual EntityTimestamp Timestamp
    {
        get { return timestamp; }
        set { timestamp = value; }
    }

    #endregion


    public virtual bool AddAddress(Address address)
    {
        if (addresses.Contains(address) || ExpiredAddresses.Contains(address) )
            return false;

        address.ParentEntity = this;

        addresses.Add(address);

        return true;
    }

    public virtual bool RemoveAddress(Address address)
    {
        if (!addresses.Contains(address) && !ExpiredAddresses.Contains(address))
            return false;

        address.IsDeleted = true;
        return true;
    }

}

子映射：

<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
    namespace="..." 
    assembly="...">

  <class name="Address" table="Address">

    <id name="Id" column="AddressId" unsaved-value="-1">
      <generator class="identity"/>
    </id>

    <property name="Street" ></property>
    <property name="StreetNumber" ></property>
    <property name="PostOfficeBox" ></property>
    <property name="IsDeleted" not-null="true" ></property>    

    <many-to-one name="City" not-null="true" column="CityId" lazy="false" cascade="none" fetch="join" class="City"></many-to-one>

    <many-to-one name="Type" not-null="true" column="AddressTypeId" lazy="false" cascade="none" fetch="join" class="AddressType"></many-to-one>

    <many-to-one name="ParentEntity" not-null="true" update="false" column="ParentEntityId" lazy="false" cascade="none" fetch="join" class="ParentEntity"></many-to-one>


    <component name="Timestamp" class="EntityTimestamp">
      <property name="CreatedOn" not-null="true" />
      <component name="CreatedBy" class="User">
        <property name="Name" not-null="true" column="CreatedBy" />
      </component>
      <property name="ChangedOn" not-null="true" />
      <component name="ChangedBy" class="User">
        <property name="Name" not-null="true" column="ChangedBy" />
      </component>
    </component>

  </class>

</hibernate-mapping>

子实施：

public class Address : IEntity<Address>, IAuditableEntity, IDeletableEntity
{
    // id etc...

    private EntityTimestamp timestamp;
    private City city;
    private bool isDeleted;
    private string street;
    private string postOfficeBox;
    private string streetNumber;
    private Validity validity;
    private AddressType type;
    private ParentEntity parentEntity;

    public virtual EntityTimestamp Timestamp
    {
        get { return timestamp; }
        set { timestamp = value; }
    }

    public virtual bool IsDeleted
    {
        get { return isDeleted; }
        set { isDeleted = value; }
    }

    public virtual string Street
    {
        get { return street; }
        set { street = value; }
    }

    public virtual string StreetNumber
    {
        get { return streetNumber; }
        set { streetNumber = value; }
    }

    public virtual string PostOfficeBox
    {
        get { return postOfficeBox; }
        set { postOfficeBox = value; }
    }

    public virtual City City
    {
        get { return city; }
        set { city = value; }
    }

    public virtual AddressType Type
    {
        get { return type; }
        set { type = value; }
    }

    public virtual Validity Validity
    {
        get { return validity; }
        set { validity = value; }
    }

    protected internal virtual ParentEntity ParentEntity
    {
        get { return parentEntity; }
        set { parentEntity = value; }
    }

    protected Address()
    {
    }

    public Address(Validity validity)
    {
        this.validity = validity;
    }
}

实体时间戳如下：

公共类 EntityTimestamp : IValueObject { private DateTime createdOn;

public virtual DateTime CreatedOn
{
    get { return createdOn; }
    private set { createdOn = value; }
}

private IUser createdBy;


public virtual IUser CreatedBy
{
    get { return createdBy; }
    private set { createdBy = value; }
}

private DateTime changedOn;


public virtual DateTime ChangedOn
{
    get { return changedOn; }
    private set { changedOn = value; }
}

private IUser changedBy;


public virtual IUser ChangedBy
{
    get { return changedBy; }
    private set { changedBy = value; }
}


protected EntityTimestamp()
{
}

private EntityTimestamp(DateTime createdOn, IUser createdBy, DateTime changedOn, IUser changedBy)
{
    if (createdBy == null)
        throw new ArgumentException("Created by user is null.");

    if (changedBy == null)
        throw new ArgumentException("Changed by user is null.");

    this.createdOn = createdOn;
    this.createdBy = createdBy;
    this.changedBy = changedBy;
    this.changedOn = changedOn;
}

public static EntityTimestamp New()
{            
    return new EntityTimestamp(new DateTimePrecise().Now, SecurityService.Current.GetCurrentUser(), new DateTimePrecise().Now, SecurityService.Current.GetCurrentUser());
}

public static EntityTimestamp New(IUser forUser)
{
    return new EntityTimestamp(new DateTimePrecise().Now, forUser, new DateTimePrecise().Now, forUser);
}

public static EntityTimestamp NewUpdated(IUser forUser, EntityTimestamp oldTimestamp)
{
    return new EntityTimestamp(oldTimestamp.CreatedOn, oldTimestamp.CreatedBy, new DateTimePrecise().Now, forUser);
}

public static EntityTimestamp NewUpdated(EntityTimestamp oldTimestamp)
{
    return new EntityTimestamp(oldTimestamp.CreatedOn, oldTimestamp.CreatedBy, new DateTimePrecise().Now, SecurityService.Current.GetCurrentUser());
}

}

时间戳在事件监听器中设置：

public class EntitySaveEventListener : NHibernate.Event.Default.DefaultSaveEventListener
    {
        protected override object PerformSaveOrUpdate(SaveOrUpdateEvent e)
        {
            if (e.Entity is IAuditableEntity)
            {
                var entity = e.Entity as IAuditableEntity;
                //todo: CascadeBeforeSave();
                if (entity != null)
                {             
                        IsDirtyEntity(e.Session, e.Entity);       
                    if (entity.IsNew)
                    {
                        entity.Timestamp = EntityTimestamp.New();
                    }
                    else
                    {
                        entity.Timestamp = EntityTimestamp.NewUpdated(entity.Timestamp);


                    }

                }
            }

            return base.PerformSaveOrUpdate(e);
        }

所以在父节点上执行 SQL 选择时，会执行地址实体的更新。

通过使用另一种方法，我已经检查了在自动更新之前传递给事件侦听器的地址是否脏。但是所有的道具似乎都是一样的。

那会是什么？您需要更多信息吗？

我在更新时检查地址是否脏的方法：

public static Boolean IsDirtyEntity(ISession session, Object entity)
{
    String className = NHibernateProxyHelper.GuessClass(entity).FullName;
    ISessionImplementor sessionImpl = session.GetSessionImplementation();
    IPersistenceContext persistenceContext = sessionImpl.PersistenceContext;
    IEntityPersister persister = sessionImpl.Factory.GetEntityPersister(className);
    EntityEntry oldEntry = sessionImpl.PersistenceContext.GetEntry(entity);


    if ((oldEntry == null) && (entity is INHibernateProxy))
    {
        INHibernateProxy proxy = entity as INHibernateProxy;
        Object obj = sessionImpl.PersistenceContext.Unproxy(proxy);
        oldEntry = sessionImpl.PersistenceContext.GetEntry(obj);
    }

    Object [] oldState = oldEntry.LoadedState;
    Object [] currentState = persister.GetPropertyValues(entity, sessionImpl.EntityMode);
    Int32 [] dirtyProps = persister.FindDirty(currentState, oldState, entity, sessionImpl);

    return (dirtyProps != null);
}

休眠 sql 调试：

//父实体选择

NHibernate.SQL：2010-02-17 16:18:39,357 [21] 调试 NHibernate.SQL [（空值）] - 选择 * 从（选择弹簧*， spft.[排名], ROW_NUMBER() OVER (ORDER BY spft.[Rank] DESC) AS RowNum 从 CONTAINSTABLE（父实体特殊表，计算，'“一些文本”'） AS spft 内部联接 ParentEntity spr ON spr.ParentEntityId = spft.[键]
              ) AS Results 
                WHERE 
                  RowNum BETWEEN (@p0 - 1) * @p1 + 1 AND @p2 * @p3
              ORDER BY 
             [Rank] DESC;@p0 = 1, @p1 = 20, @p2 = 1, @p3 = 20
NHibernate.SQL：2010-02-17 16:18:39,513 [21] 调试 NHibernate.SQL [(null)] - 选择地址0_.ParentEntityId 为 ServiceP8_3_,addresses0_.AddressId 为 AddressId3_,addresses0_.AddressId 为 AddressId11_2_,addresses0_.Street 为 Street11_2_,addresses0_.StreetNumber 作为 StreetNu3_11_2_，地址0_.PostOfficeBox 为 PostOffi4_11_2_,addresses0_.IsDeleted 作为 IsDeleted11_2_，addresses0_.CityId 作为 CityId11_2_， address0_.AddressTypeId 为地址T7_11_2_, 地址0_.ParentEntityId 为服务P8_11_2_, 地址0_.ValidityPeriodFrom 为有效期9_11_2_, 地址0_.ValidityPeriodTo 为 Validit10_11_2_,addresses0_.CreatedOn 作为 CreatedOn11_2_，地址0_.CreatedBy 为 CreatedBy11_2_,addresses0_.ChangedOn 作为ChangedOn11_2_，地址0_.ChangedBy 为 ChangedBy11_2_, city1_.CityId 为 CityId9_0_, city1_.IsDeleted 为 IsDeleted9_0_, city1_.Name as Name9_0_, city1_.ZipCode as ZipCode9_0_, city1_.CountryId 为 CountryId9_0_, city1_.CreatedOn 为 CreatedOn9_0_, city1_.CreatedBy as CreatedBy9_0_, city1_.ChangedOn 为 ChangedOn9_0_, city1_.ChangedBy 为由 9_0_ 更改， addresstyp2_.AddressTypeId 为地址T1_6_1_，地址类型2_.IsDeleted 作为 IsDeleted6_1_， addresstyp2_.IsSystemDefault 为 IsSystem3_6_1_, addresstyp2_.Name as Name6_1_, addresstyp2_.[Key] as 列 5_6_1_，地址类型 2_.CreatedOn 作为 CreatedOn6_1_， addresstyp2_.CreatedBy 为 CreatedBy6_1_, addresstyp2_.ChangedOn 作为ChangedOn6_1_， addresstyp2_.ChangedBy 为 ChangedBy6_1_ FROM 地址地址 0_ 内连接 City city1_ on 地址0_.CityId=city1_.CityId 内部加入 AddressType addresstyp2_ on 地址0_.AddressTypeId=addresstyp2_.AddressTypeId WHERE (addresses0_.IsDeleted = 0) 和地址0_.ParentEntityId=@p0;@p0 = 345625 'aspnet_wp.exe'（托管）：加载“CountryProxyAssembly” “aspnet_wp.exe”（托管）：已加载 '国家代理模块'

//地址已更新

NHibernate.SQL：

2010-02-17 16:18:51,607 [21] 调试 NHibernate.SQL [(null)] - 批处理命令：命令 0：更新地址集街道 = @p0，街道编号 = @p1， PostOfficeBox = @p2，IsDeleted = @p3， CityId = @p4，AddressTypeId = @p5， ValidityPeriodFrom = @p6, ValidityPeriodTo = @p7, CreatedOn = @p8, CreatedBy = @p9, ChangedOn = @p10, ChangedBy = @p11 WHERE AddressId = @p12;@p0 = 'fff'，@p1 = ''，@p2 = NULL，@p3 = 假，@p4 = 116644，@p5 = 1，@p6 = 20.01.2010 17:28:15，@p7 = 31.12.9999 00:00:00， @p8 = 20.01.2010 17:29:52，@p9 = 'fff'，@p10 = 17.02.2010 16:18:51， @p11 = 'fff'，@p12 = 117390

//地址已更新

NHibernate.SQL：

2010-02-17 16:19:03,748 [21] 调试 NHibernate.SQL [(null)] - 批处理命令：命令 0：更新地址集街道 = @p0，街道编号 = @p1， PostOfficeBox = @p2，IsDeleted = @p3， CityId = @p4，AddressTypeId = @p5， ValidityPeriodFrom = @p6, ValidityPeriodTo = @p7, CreatedOn = @p8, CreatedBy = @p9, ChangedOn = @p10, ChangedBy = @p11 WHERE AddressId = @p12;@p0 = 'fff'，@p1 = ''，@p2 = NULL，@p3 = 假，@p4 = 116644，@p5 = 1，@p6 = 20.01.2010 17:28:15，@p7 = 31.12.9999 00:00:00， @p8 = 20.01.2010 17:29:52，@p9 = 'fff'，@p10 = 17.02.2010 16:19:03， @p11 = 'fff'，@p12 = 117390

【问题讨论】：

如果在 SaveEventListener 中注释掉更新时间戳的部分怎么办。我怀疑这是导致问题的原因......如果是，我会发布我是如何解决这个问题的。
是的，你是对的。如果从地址中删除时间戳内容，或者如果我在事件侦听器中注释时间戳设置，则不会执行意外更新。

标签： c# java .net nhibernate hibernate

【解决方案1】：

我遇到了几乎相同的问题。我创建了非空字段并更新了允许空值的字段。看起来你两者都为非空，所以你可以简单地设置更新的字段，我在下面设置创建的字段。

我混合使用事件侦听器。我无法使用 PreInsert 事件来填充“已创建”字段，因为它发生在处理后期，并且在 PreInsert 触发之前出现空检查错误。我使用 PreUpdate 事件是因为我找不到可靠的方法来判断实体是否真的很脏，如果我在 OnSaveOrUpdate 中设置“last_updated”字段，它肯定会使实体变脏并强制每次发布更新。通过使用 PreUpdate，我让 NHibernate 检查了脏污程度，并且我只是在更新触发之前注入了我的值。

有关 PreUpdate 的更多信息，请参阅ayende blog

public class AuditableEventListener : DefaultSaveOrUpdateEventListener, IPreUpdateEventListener
{
    public override void OnSaveOrUpdate(SaveOrUpdateEvent @event)
    {
        Auditable a = @event.Entity as Auditable;
        if (a != null)
        {
            if (this.GetEntityState(@event.Entity, @event.EntityName, @event.Entry, @event.Session) == EntityState.Transient)
            {
                a.create_dt = DateTime.Now;
                a.create_by = @event.Session.Load<Staff>(CurrentStaff.Id);
            }
        }

        base.OnSaveOrUpdate(@event);
    }

    #region IPreUpdateEventListener Members

    public bool OnPreUpdate(PreUpdateEvent @event)
    {
        var audit = @event.Entity as Auditable;
        if (audit == null) return false;

        var now = DateTime.Now;
        var user = @event.Session.Load<Staff>(CurrentStaff.Id);

        //Very important to keep the State and Entity synced together
        Set(@event.Persister, @event.State, "last_update_dt", now);
        Set(@event.Persister, @event.State, "last_update_by", user);

        audit.last_update_dt = now;
        audit.last_update_by = user;

        return false;
    }

    #endregion


    private void Set(IEntityPersister persister, object[] state, string propertyName, object value)
    {
        var index = Array.IndexOf(persister.PropertyNames, propertyName);
        if (index == -1)
            return;
        state[index] = value;
    }

}

然后确保连接到所需的事件监听器...

ISaveOrUpdateEventListener[] saveUpdateListeners = new ISaveOrUpdateEventListener[] { new AuditableEventListener() };
conf.EventListeners.SaveEventListeners = saveUpdateListeners;
conf.EventListeners.SaveOrUpdateEventListeners = saveUpdateListeners;
conf.EventListeners.UpdateEventListeners = saveUpdateListeners;

conf.EventListeners.PreUpdateEventListeners = new IPreUpdateEventListener[] { new AuditableEventListener() };

【讨论】：