Menu
▾
▴
[Nhibernate-commit] nhibernate/src/NHibernate/Impl CollectionEntry.cs,NONE,1.1 EntityEntry.cs,NONE,1.1 IExecutable.cs,NONE,1.1 Status.cs,NONE,1.1 ScheduledCollectionAction.cs,1.7,1.8 ScheduledEntityAction.cs,1.6,1.7 SessionImpl.cs,1.55,1.56
Update of /cvsroot/nhibernate/nhibernate/src/NHibernate/Impl In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv20391/NHibernate/Impl Modified Files: ScheduledCollectionAction.cs ScheduledEntityAction.cs SessionImpl.cs Added Files: CollectionEntry.cs EntityEntry.cs IExecutable.cs Status.cs Log Message: Moved some nested classes out from SessionImpl into their own class. Index: SessionImpl.cs =================================================================== RCS file: /cvsroot/nhibernate/nhibernate/src/NHibernate/Impl/SessionImpl.cs,v retrieving revision 1.55 retrieving revision 1.56 diff -C2 -d -r1.55 -r1.56 *** SessionImpl.cs 9 Dec 2004 17:52:15 -0000 1.55 --- SessionImpl.cs 9 Dec 2004 22:08:54 -0000 1.56 *************** *** 104,618 **** [NonSerialized] private IBatcher batcher; - /// <summary> - /// Represents the status of an entity with respect to - /// this session. These statuses are for internal - /// book-keeping only and are not intended to represent - /// any notion that is visible to the <b>application</b>. - /// </summary> - [Serializable] - internal enum Status - { - /// <summary> - /// The Entity is snapshotted in the Session with the same state as the database. - /// </summary> - Loaded, - - /// <summary> - /// The Entity is in the Session and has been marked for deletion but not - /// deleted from the database yet. - /// </summary> - Deleted, - - /// <summary> - /// The Entity has been deleted from database. - /// </summary> - Gone, - - /// <summary> - /// The Entity is in the process of being loaded. - /// </summary> - Loading, - - /// <summary> - /// The Entity is in the process of being saved. - /// </summary> - Saving - } - - /// <summary> - /// An action that <see cref="ISession"/> can Execute during a - /// <c>Flush</c>. - /// </summary> - internal interface IExecutable - { - /// <summary> - /// Execute the action required to write changes to the database. - /// </summary> - void Execute(); - - /// <summary> - /// Called after the Transaction has been completed. - /// </summary> - /// <remarks> - /// Actions should make sure that the Cache is notified about - /// what just happened. - /// </remarks> - void AfterTransactionCompletion(); - - /// <summary> - /// The spaces (tables) that are affectd by this Executable action. - /// </summary> - /// <remarks> - /// This is used to determine if the ISession needs to be flushed before - /// a query is executed so stale data is not returned. - /// </remarks> - object[] PropertySpaces { get; } - } - - /// <summary> - /// We need an entry to tell us all about the current state - /// of an object with respect to its persistent state - /// </summary> - [Serializable] - 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; - - /// <summary> - /// Initializes a new instance of EntityEntry. - /// </summary> - /// <param name="status">The current <see cref="Status"/> of the Entity.</param> - /// <param name="loadedState">The snapshot of the Entity's state when it was loaded.</param> - /// <param name="id">The identifier of the Entity in the database.</param> - /// <param name="version">The version of the Entity.</param> - /// <param name="lockMode">The <see cref="LockMode"/> for the Entity.</param> - /// <param name="existsInDatabase">A boolean indicating if the Entity exists in the database.</param> - /// <param name="persister">The <see cref="IClassPersister"/> that is responsible for this Entity.</param> - public EntityEntry(Status status, object[] loadedState, object id, object version, LockMode lockMode, bool existsInDatabase, IClassPersister persister) - { - _status = status; - _loadedState = loadedState; - _id = id; - _existsInDatabase = existsInDatabase; - _version = version; - _lockMode = lockMode; - _persister = persister; - if (_persister!=null) _className = _persister.ClassName; - } - - /// <summary> - /// Gets or sets the current <see cref="LockMode"/> of the Entity. - /// </summary> - /// <value>The <see cref="LockMode"/> of the Entity.</value> - public LockMode LockMode - { - get { return _lockMode; } - set { _lockMode = value; } - } - - /// <summary> - /// Gets or sets the <see cref="Status"/> of this Entity with respect to its - /// persistence in the database. - /// </summary> - /// <value>The <see cref="Status"/> of this Entity.</value> - public Status Status - { - get { return _status; } - set { _status = value; } - } - - /// <summary> - /// Gets or sets the identifier of the Entity in the database. - /// </summary> - /// <value>The identifier of the Entity in the database if one has been assigned.</value> - /// <remarks>This might be <c>null</c> when the <see cref="EntityEntry.Status"/> is - /// <see cref="Status.Saving"/> and the database generates the id.</remarks> - public object Id - { - get { return _id; } - set { _id = value; } - } - - /// <summary> - /// Gets or sets the snapshot of the Entity when it was loaded from the database. - /// </summary> - /// <value>The snapshot of the Entity.</value> - /// <remarks> - /// There will only be a value when the Entity was loaded in the current Session. - /// </remarks> - public object[] LoadedState - { - get { return _loadedState; } - set { _loadedState = value; } - } - - /// <summary> - /// Gets or sets the snapshot of the Entity when it was marked as being ready for deletion. - /// </summary> - /// <value>The snapshot of the Entity.</value> - /// <remarks>This will be <c>null</c> if the Entity is not being deleted.</remarks> - public object[] DeletedState - { - get { return _deletedState; } - set { _deletedState = value; } - } - - /// <summary> - /// Gets or sets a <see cref="Boolean"/> indicating if this Entity exists in the database. - /// </summary> - /// <value><c>true</c> if it is already in the database.</value> - /// <remarks> - /// It can also be <c>true</c> if it does not exists in the database yet and the - /// <see cref="IClassPersister.IsIdentifierAssignedByInsert"/> is <c>true</c>. - /// </remarks> - public bool ExistsInDatabase - { - get { return _existsInDatabase; } - set { _existsInDatabase = value; } - } - - /// <summary> - /// Gets or sets the version of the Entity. - /// </summary> - /// <value>The version of the Entity.</value> - public object Version - { - get { return _version; } - set { _version = value; } - } - - /// <summary> - /// Gets or sets the <see cref="IClassPersister"/> that is responsible for this Entity. - /// </summary> - /// <value>The <see cref="IClassPersister"/> that is reponsible for this Entity.</value> - public IClassPersister Persister - { - get { return _persister; } - set { _persister = value; } - } - - /// <summary> - /// Gets the Fully Qualified Name of the class this Entity is an instance of. - /// </summary> - /// <value>The Fully Qualified Name of the class this Entity is an instance of.</value> - public string ClassName - { - get { return _className; } - } - - } - - - /// <summary> - /// We need an entry to tell us all about the current state - /// of a collection with respect to its persistent state - /// </summary> - [Serializable] - public class CollectionEntry : ICollectionSnapshot - { - internal bool dirty; - - /// <summary> - /// Indicates that the Collection can still be reached by an Entity - /// that exist in the <see cref="ISession"/>. - /// </summary> - /// <remarks> - /// It is also used to ensure that the Collection is not shared between - /// two Entities. - /// </remarks> - [NonSerialized] internal bool reached; - - /// <summary> - /// Indicates that the Collection has been processed and is ready - /// to have its state synchronized with the database. - /// </summary> - [NonSerialized] internal bool processed; - - /// <summary> - /// Indicates that a Collection needs to be updated. - /// </summary> - /// <remarks> - /// A Collection needs to be updated whenever the contents of the Collection - /// have been changed. - /// </remarks> - [NonSerialized] internal bool doupdate; - - /// <summary> - /// Indicates that a Collection has old elements that need to be removed. - /// </summary> - /// <remarks> - /// A Collection needs to have removals performed whenever its role changes or - /// the key changes and it has a loadedPersister - ie - it was loaded by NHibernate. - /// </remarks> - [NonSerialized] internal bool doremove; - - /// <summary> - /// Indicates that a Collection needs to be recreated. - /// </summary> - /// <remarks> - /// A Collection needs to be recreated whenever its role changes - /// or the owner changes. - /// </remarks> - [NonSerialized] internal bool dorecreate; - - /// <summary> - /// Indicates that the Collection has been fully initialized. - /// </summary> - internal bool initialized; - - /// <summary> - /// The <see cref="CollectionPersister"/> that is currently responsible - /// for the Collection. - /// </summary> - /// <remarks> - /// This is set when NHibernate is updating a reachable or an - /// unreachable collection. - /// </remarks> - [NonSerialized] internal CollectionPersister currentPersister; - - /// <summary> - /// The <see cref="CollectionPersister"/> when the Collection was loaded. - /// </summary> - /// <remarks> - /// This can be <c>null</c> if the Collection was not loaded by NHibernate and - /// was passed in along with a transient object. - /// </remarks> - [NonSerialized] internal CollectionPersister loadedPersister; - [NonSerialized] internal object currentKey; - internal object loadedKey; - internal object snapshot; //session-start/post-flush persistent state - internal string role; - - /// <summary> - /// Initializes a new instance of <see cref="CollectionEntry"/>. - /// </summary> - /// <remarks> - /// The CollectionEntry is for a Collection that is not dirty and - /// has already been initialized. - /// </remarks> - public CollectionEntry() - { - this.dirty = false; - this.initialized = true; - } - - /// <summary> - /// Initializes a new instance of <see cref="CollectionEntry"/>. - /// </summary> - /// <param name="loadedPersister">The <see cref="CollectionPersister"/> that persists this Collection type.</param> - /// <param name="loadedID">The identifier of the Entity that is the owner of this Collection.</param> - /// <param name="initialized">A boolean indicating if the collection has been initialized.</param> - public CollectionEntry(CollectionPersister loadedPersister, object loadedID, bool initialized) - { - this.dirty = false; - this.initialized = initialized; - this.loadedKey = loadedID; - SetLoadedPersister(loadedPersister); - } - - /// <summary> - /// Initializes a new instance of <see cref="CollectionEntry"/>. - /// </summary> - /// <param name="cs">The <see cref="ICollectionSnapshot"/> from another <see cref="ISession"/>.</param> - /// <param name="factory">The <see cref="ISessionFactoryImplementor"/> that created this <see cref="ISession"/>.</param> - /// <remarks> - /// This takes an <see cref="ICollectionSnapshot"/> from another <see cref="ISession"/> and - /// creates an entry for it in this <see cref="ISession"/> by copying the values from the - /// <c>cs</c> parameter. - /// </remarks> - public CollectionEntry(ICollectionSnapshot cs, ISessionFactoryImplementor factory) - { - this.dirty = cs.Dirty; - this.snapshot = cs.Snapshot; - this.loadedKey = cs.Key; - SetLoadedPersister( factory.GetCollectionPersister( cs.Role ) ); - this.initialized = true; - } - - /// <summary> - /// Checks to see if the <see cref="PersistentCollection"/> has had any changes to the - /// collections contents or if any of the elements in the collection have been modified. - /// </summary> - /// <param name="coll"></param> - /// <returns><c>true</c> if the <see cref="PersistentCollection"/> is dirty.</returns> - /// <remarks> - /// default behavior; will be overridden in deep lazy collections - /// </remarks> - public virtual bool IsDirty(PersistentCollection coll) - { - // if this has already been marked as dirty or the collection can not - // be directly accessed (ie- we can guarantee that the NHibernate collection - // wrappers are used) and the elements in the collection are not mutable - // then return the dirty flag. - if ( dirty || ( - !coll.IsDirectlyAccessible && !loadedPersister.ElementType.IsMutable - ) ) - { - return dirty; - } - else - { - // need to have the coll determine if it is the same as the snapshot - // that was last taken. - return !coll.EqualsSnapshot( loadedPersister.ElementType ); - } - } - - /// <summary> - /// Prepares this CollectionEntry for the Flush process. - /// </summary> - /// <param name="collection">The <see cref="PersistentCollection"/> that this CollectionEntry will be responsible for flushing.</param> - public void PreFlush(PersistentCollection collection) - { - // if the collection is initialized and it was previously persistent - // initialize the dirty flag - dirty = ( initialized && loadedPersister!=null && IsDirty(collection) ) || - (!initialized && dirty ); //only need this so collection with queued adds will be removed from JCS cache - - if ( log.IsDebugEnabled && dirty && loadedPersister!=null ) - { - log.Debug("Collection dirty: " + MessageHelper.InfoString(loadedPersister, loadedKey) ); - } - - // reset all of these values so any previous flush status - // information is cleared from this CollectionEntry - doupdate = false; - doremove = false; - dorecreate = false; - reached = false; - processed = false; - } - - /// <summary> - /// Updates the CollectionEntry to reflect that the <see cref="PersistentCollection"/> - /// has been initialized. - /// </summary> - /// <param name="collection">The initialized <see cref="PersistentCollection"/> that this Entry is for.</param> - public void PostInitialize(PersistentCollection collection) - { - initialized = true; - snapshot = collection.GetSnapshot(loadedPersister); - } - - /// <summary> - /// Updates the CollectionEntry to reflect that it is has been successfully flushed to the database. - /// </summary> - /// <param name="collection">The <see cref="PersistentCollection"/> that was flushed.</param> - public void PostFlush(PersistentCollection collection) - { - // the CollectionEntry should be processed if we are in the PostFlush() - if( !processed ) - { - throw new AssertionFailure("Hibernate has a bug processing collections"); - } - - // now that the flush has gone through move everything that is the current - // over to the loaded fields and set dirty to false since the db & collection - // are in synch. - loadedKey = currentKey; - SetLoadedPersister( currentPersister ); - dirty = false; - - // collection needs to know its' representation in memory and with - // the db is now in synch - esp important for collections like a bag - // that can add without initializing the collection. - collection.PostFlush(); - - // if it was initialized or any of the scheduled actions were performed then - // need to resnpashot the contents of the collection. - if ( initialized && ( doremove || dorecreate || doupdate ) ) - { - snapshot = collection.GetSnapshot(loadedPersister); //re-snapshot - } - } - - #region Engine.ICollectionSnapshot Members - - public object Key - { - get { return loadedKey; } - } - - public string Role - { - get { return role; } - } - - public object Snapshot - { - get { return snapshot; } - } - - public bool Dirty - { - get { return dirty; } - } - - public void SetDirty() - { - dirty = true; - } - public bool IsInitialized - { - get { return initialized;} - } - - - #endregion - - /// <summary> - /// Sets the information in this CollectionEntry that is specific to the - /// <see cref="CollectionPersister"/>. - /// </summary> - /// <param name="persister"> - /// The <see cref="CollectionPersister"/> that is - /// responsible for the Collection. - /// </param> - private void SetLoadedPersister(CollectionPersister persister) - { - loadedPersister = persister; - if (persister!=null) - { - role=persister.Role; - } - } - - public bool SnapshotIsEmpty - { - get - { - //TODO: implementation here is non-extensible ... - //should use polymorphism - // return initialized && snapshot!=null && ( - // ( snapshot is IList && ( (IList) snapshot ).Count==0 ) || // if snapshot is a collection - // ( snapshot is Map && ( (Map) snapshot ).Count==0 ) || // if snapshot is a map - // (snapshot.GetType().IsArray && ( (Array) snapshot).Length==0 )// if snapshot is an array - // ); - - // TODO: in .NET an IList, IDictionary, and Array are all collections so we might be able - // to just cast it to a ICollection instead of all the diff collections. - return initialized && snapshot!=null && ( - ( snapshot is IList && ( (IList) snapshot ).Count==0 ) || // if snapshot is a collection - ( snapshot is IDictionary && ( (IDictionary) snapshot ).Count==0 ) || // if snapshot is a map - (snapshot.GetType().IsArray && ( (Array) snapshot).Length==0 )// if snapshot is an array - ); - } - } - public bool IsNew - { - // TODO: is this correct implementation - h2.0.3 - get { return initialized && (snapshot==null); } - } - } - #region System.Runtime.Serialization.ISerializable Members --- 104,107 ---- Index: ScheduledCollectionAction.cs =================================================================== RCS file: /cvsroot/nhibernate/nhibernate/src/NHibernate/Impl/ScheduledCollectionAction.cs,v retrieving revision 1.7 retrieving revision 1.8 diff -C2 -d -r1.7 -r1.8 *** ScheduledCollectionAction.cs 29 Nov 2004 15:31:07 -0000 1.7 --- ScheduledCollectionAction.cs 9 Dec 2004 22:08:54 -0000 1.8 *************** *** 10,14 **** /// flush. /// </summary> ! internal abstract class ScheduledCollectionAction : SessionImpl.IExecutable { private CollectionPersister _persister; --- 10,14 ---- /// flush. /// </summary> ! internal abstract class ScheduledCollectionAction : IExecutable { private CollectionPersister _persister; --- NEW FILE: IExecutable.cs --- using System; namespace NHibernate.Impl { /// <summary> /// An action that <see cref="ISession"/> can Execute during a /// <c>Flush</c>. /// </summary> internal interface IExecutable { /// <summary> /// Execute the action required to write changes to the database. /// </summary> void Execute(); /// <summary> /// Called after the Transaction has been completed. /// </summary> /// <remarks> /// Actions should make sure that the Cache is notified about /// what just happened. /// </remarks> void AfterTransactionCompletion(); /// <summary> /// The spaces (tables) that are affectd by this Executable action. /// </summary> /// <remarks> /// This is used to determine if the ISession needs to be flushed before /// a query is executed so stale data is not returned. /// </remarks> object[] PropertySpaces { get; } } } Index: ScheduledEntityAction.cs =================================================================== RCS file: /cvsroot/nhibernate/nhibernate/src/NHibernate/Impl/ScheduledEntityAction.cs,v retrieving revision 1.6 retrieving revision 1.7 diff -C2 -d -r1.6 -r1.7 *** ScheduledEntityAction.cs 29 Nov 2004 15:31:07 -0000 1.6 --- ScheduledEntityAction.cs 9 Dec 2004 22:08:54 -0000 1.7 *************** *** 10,14 **** /// flush. /// </summary> ! internal abstract class ScheduledEntityAction : SessionImpl.IExecutable { --- 10,14 ---- /// flush. /// </summary> ! internal abstract class ScheduledEntityAction : IExecutable { --- NEW FILE: EntityEntry.cs --- using System; using NHibernate.Persister; namespace NHibernate.Impl { /// <summary> /// We need an entry to tell us all about the current state /// of an object with respect to its persistent state /// </summary> [Serializable] sealed internal class EntityEntry { private static readonly log4net.ILog log = log4net.LogManager.GetLogger( typeof(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; /// <summary> /// Initializes a new instance of EntityEntry. /// </summary> /// <param name="status">The current <see cref="Status"/> of the Entity.</param> /// <param name="loadedState">The snapshot of the Entity's state when it was loaded.</param> /// <param name="id">The identifier of the Entity in the database.</param> /// <param name="version">The version of the Entity.</param> /// <param name="lockMode">The <see cref="LockMode"/> for the Entity.</param> /// <param name="existsInDatabase">A boolean indicating if the Entity exists in the database.</param> /// <param name="persister">The <see cref="IClassPersister"/> that is responsible for this Entity.</param> public EntityEntry(Status status, object[] loadedState, object id, object version, LockMode lockMode, bool existsInDatabase, IClassPersister persister) { _status = status; _loadedState = loadedState; _id = id; _existsInDatabase = existsInDatabase; _version = version; _lockMode = lockMode; _persister = persister; if (_persister!=null) _className = _persister.ClassName; } /// <summary> /// Gets or sets the current <see cref="LockMode"/> of the Entity. /// </summary> /// <value>The <see cref="LockMode"/> of the Entity.</value> public LockMode LockMode { get { return _lockMode; } set { _lockMode = value; } } /// <summary> /// Gets or sets the <see cref="Status"/> of this Entity with respect to its /// persistence in the database. /// </summary> /// <value>The <see cref="Status"/> of this Entity.</value> public Status Status { get { return _status; } set { _status = value; } } /// <summary> /// Gets or sets the identifier of the Entity in the database. /// </summary> /// <value>The identifier of the Entity in the database if one has been assigned.</value> /// <remarks>This might be <c>null</c> when the <see cref="EntityEntry.Status"/> is /// <see cref="Status.Saving"/> and the database generates the id.</remarks> public object Id { get { return _id; } set { _id = value; } } /// <summary> /// Gets or sets the snapshot of the Entity when it was loaded from the database. /// </summary> /// <value>The snapshot of the Entity.</value> /// <remarks> /// There will only be a value when the Entity was loaded in the current Session. /// </remarks> public object[] LoadedState { get { return _loadedState; } set { _loadedState = value; } } /// <summary> /// Gets or sets the snapshot of the Entity when it was marked as being ready for deletion. /// </summary> /// <value>The snapshot of the Entity.</value> /// <remarks>This will be <c>null</c> if the Entity is not being deleted.</remarks> public object[] DeletedState { get { return _deletedState; } set { _deletedState = value; } } /// <summary> /// Gets or sets a <see cref="Boolean"/> indicating if this Entity exists in the database. /// </summary> /// <value><c>true</c> if it is already in the database.</value> /// <remarks> /// It can also be <c>true</c> if it does not exists in the database yet and the /// <see cref="IClassPersister.IsIdentifierAssignedByInsert"/> is <c>true</c>. /// </remarks> public bool ExistsInDatabase { get { return _existsInDatabase; } set { _existsInDatabase = value; } } /// <summary> /// Gets or sets the version of the Entity. /// </summary> /// <value>The version of the Entity.</value> public object Version { get { return _version; } set { _version = value; } } /// <summary> /// Gets or sets the <see cref="IClassPersister"/> that is responsible for this Entity. /// </summary> /// <value>The <see cref="IClassPersister"/> that is reponsible for this Entity.</value> public IClassPersister Persister { get { return _persister; } set { _persister = value; } } /// <summary> /// Gets the Fully Qualified Name of the class this Entity is an instance of. /// </summary> /// <value>The Fully Qualified Name of the class this Entity is an instance of.</value> public string ClassName { get { return _className; } } } } --- NEW FILE: CollectionEntry.cs --- using System; using System.Collections; using NHibernate.Collection; using NHibernate.Engine; namespace NHibernate.Impl { /// <summary> /// We need an entry to tell us all about the current state /// of a collection with respect to its persistent state /// </summary> [Serializable] public class CollectionEntry : ICollectionSnapshot { private static readonly log4net.ILog log = log4net.LogManager.GetLogger( typeof(CollectionEntry) ); internal bool dirty; /// <summary> /// Indicates that the Collection can still be reached by an Entity /// that exist in the <see cref="ISession"/>. /// </summary> /// <remarks> /// It is also used to ensure that the Collection is not shared between /// two Entities. /// </remarks> [NonSerialized] internal bool reached; /// <summary> /// Indicates that the Collection has been processed and is ready /// to have its state synchronized with the database. /// </summary> [NonSerialized] internal bool processed; /// <summary> /// Indicates that a Collection needs to be updated. /// </summary> /// <remarks> /// A Collection needs to be updated whenever the contents of the Collection /// have been changed. /// </remarks> [NonSerialized] internal bool doupdate; /// <summary> /// Indicates that a Collection has old elements that need to be removed. /// </summary> /// <remarks> /// A Collection needs to have removals performed whenever its role changes or /// the key changes and it has a loadedPersister - ie - it was loaded by NHibernate. /// </remarks> [NonSerialized] internal bool doremove; /// <summary> /// Indicates that a Collection needs to be recreated. /// </summary> /// <remarks> /// A Collection needs to be recreated whenever its role changes /// or the owner changes. /// </remarks> [NonSerialized] internal bool dorecreate; /// <summary> /// Indicates that the Collection has been fully initialized. /// </summary> internal bool initialized; /// <summary> /// The <see cref="CollectionPersister"/> that is currently responsible /// for the Collection. /// </summary> /// <remarks> /// This is set when NHibernate is updating a reachable or an /// unreachable collection. /// </remarks> [NonSerialized] internal CollectionPersister currentPersister; /// <summary> /// The <see cref="CollectionPersister"/> when the Collection was loaded. /// </summary> /// <remarks> /// This can be <c>null</c> if the Collection was not loaded by NHibernate and /// was passed in along with a transient object. /// </remarks> [NonSerialized] internal CollectionPersister loadedPersister; [NonSerialized] internal object currentKey; internal object loadedKey; internal object snapshot; //session-start/post-flush persistent state internal string role; /// <summary> /// Initializes a new instance of <see cref="CollectionEntry"/>. /// </summary> /// <remarks> /// The CollectionEntry is for a Collection that is not dirty and /// has already been initialized. /// </remarks> public CollectionEntry() { this.dirty = false; this.initialized = true; } /// <summary> /// Initializes a new instance of <see cref="CollectionEntry"/>. /// </summary> /// <param name="loadedPersister">The <see cref="CollectionPersister"/> that persists this Collection type.</param> /// <param name="loadedID">The identifier of the Entity that is the owner of this Collection.</param> /// <param name="initialized">A boolean indicating if the collection has been initialized.</param> public CollectionEntry(CollectionPersister loadedPersister, object loadedID, bool initialized) { this.dirty = false; this.initialized = initialized; this.loadedKey = loadedID; SetLoadedPersister(loadedPersister); } /// <summary> /// Initializes a new instance of <see cref="CollectionEntry"/>. /// </summary> /// <param name="cs">The <see cref="ICollectionSnapshot"/> from another <see cref="ISession"/>.</param> /// <param name="factory">The <see cref="ISessionFactoryImplementor"/> that created this <see cref="ISession"/>.</param> /// <remarks> /// This takes an <see cref="ICollectionSnapshot"/> from another <see cref="ISession"/> and /// creates an entry for it in this <see cref="ISession"/> by copying the values from the /// <c>cs</c> parameter. /// </remarks> public CollectionEntry(ICollectionSnapshot cs, ISessionFactoryImplementor factory) { this.dirty = cs.Dirty; this.snapshot = cs.Snapshot; this.loadedKey = cs.Key; SetLoadedPersister( factory.GetCollectionPersister( cs.Role ) ); this.initialized = true; } /// <summary> /// Checks to see if the <see cref="PersistentCollection"/> has had any changes to the /// collections contents or if any of the elements in the collection have been modified. /// </summary> /// <param name="coll"></param> /// <returns><c>true</c> if the <see cref="PersistentCollection"/> is dirty.</returns> /// <remarks> /// default behavior; will be overridden in deep lazy collections /// </remarks> public virtual bool IsDirty(PersistentCollection coll) { // if this has already been marked as dirty or the collection can not // be directly accessed (ie- we can guarantee that the NHibernate collection // wrappers are used) and the elements in the collection are not mutable // then return the dirty flag. if ( dirty || ( !coll.IsDirectlyAccessible && !loadedPersister.ElementType.IsMutable ) ) { return dirty; } else { // need to have the coll determine if it is the same as the snapshot // that was last taken. return !coll.EqualsSnapshot( loadedPersister.ElementType ); } } /// <summary> /// Prepares this CollectionEntry for the Flush process. /// </summary> /// <param name="collection">The <see cref="PersistentCollection"/> that this CollectionEntry will be responsible for flushing.</param> public void PreFlush(PersistentCollection collection) { // if the collection is initialized and it was previously persistent // initialize the dirty flag dirty = ( initialized && loadedPersister!=null && IsDirty(collection) ) || (!initialized && dirty ); //only need this so collection with queued adds will be removed from JCS cache if ( log.IsDebugEnabled && dirty && loadedPersister!=null ) { log.Debug("Collection dirty: " + MessageHelper.InfoString(loadedPersister, loadedKey) ); } // reset all of these values so any previous flush status // information is cleared from this CollectionEntry doupdate = false; doremove = false; dorecreate = false; reached = false; processed = false; } /// <summary> /// Updates the CollectionEntry to reflect that the <see cref="PersistentCollection"/> /// has been initialized. /// </summary> /// <param name="collection">The initialized <see cref="PersistentCollection"/> that this Entry is for.</param> public void PostInitialize(PersistentCollection collection) { initialized = true; snapshot = collection.GetSnapshot(loadedPersister); } /// <summary> /// Updates the CollectionEntry to reflect that it is has been successfully flushed to the database. /// </summary> /// <param name="collection">The <see cref="PersistentCollection"/> that was flushed.</param> public void PostFlush(PersistentCollection collection) { // the CollectionEntry should be processed if we are in the PostFlush() if( !processed ) { throw new AssertionFailure("Hibernate has a bug processing collections"); } // now that the flush has gone through move everything that is the current // over to the loaded fields and set dirty to false since the db & collection // are in synch. loadedKey = currentKey; SetLoadedPersister( currentPersister ); dirty = false; // collection needs to know its' representation in memory and with // the db is now in synch - esp important for collections like a bag // that can add without initializing the collection. collection.PostFlush(); // if it was initialized or any of the scheduled actions were performed then // need to resnpashot the contents of the collection. if ( initialized && ( doremove || dorecreate || doupdate ) ) { snapshot = collection.GetSnapshot(loadedPersister); //re-snapshot } } #region Engine.ICollectionSnapshot Members public object Key { get { return loadedKey; } } public string Role { get { return role; } } public object Snapshot { get { return snapshot; } } public bool Dirty { get { return dirty; } } public void SetDirty() { dirty = true; } public bool IsInitialized { get { return initialized;} } #endregion /// <summary> /// Sets the information in this CollectionEntry that is specific to the /// <see cref="CollectionPersister"/>. /// </summary> /// <param name="persister"> /// The <see cref="CollectionPersister"/> that is /// responsible for the Collection. /// </param> private void SetLoadedPersister(CollectionPersister persister) { loadedPersister = persister; if (persister!=null) { role=persister.Role; } } public bool SnapshotIsEmpty { get { //TODO: implementation here is non-extensible ... //should use polymorphism // return initialized && snapshot!=null && ( // ( snapshot is IList && ( (IList) snapshot ).Count==0 ) || // if snapshot is a collection // ( snapshot is Map && ( (Map) snapshot ).Count==0 ) || // if snapshot is a map // (snapshot.GetType().IsArray && ( (Array) snapshot).Length==0 )// if snapshot is an array // ); // TODO: in .NET an IList, IDictionary, and Array are all collections so we might be able // to just cast it to a ICollection instead of all the diff collections. return initialized && snapshot!=null && ( ( snapshot is IList && ( (IList) snapshot ).Count==0 ) || // if snapshot is a collection ( snapshot is IDictionary && ( (IDictionary) snapshot ).Count==0 ) || // if snapshot is a map (snapshot.GetType().IsArray && ( (Array) snapshot).Length==0 )// if snapshot is an array ); } } public bool IsNew { // TODO: is this correct implementation - h2.0.3 get { return initialized && (snapshot==null); } } } } --- NEW FILE: Status.cs --- using System; namespace NHibernate.Impl { /// <summary> /// Represents the status of an entity with respect to /// this session. These statuses are for internal /// book-keeping only and are not intended to represent /// any notion that is visible to the <b>application</b>. /// </summary> [Serializable] internal enum Status { /// <summary> /// The Entity is snapshotted in the Session with the same state as the database. /// </summary> Loaded, /// <summary> /// The Entity is in the Session and has been marked for deletion but not /// deleted from the database yet. /// </summary> Deleted, /// <summary> /// The Entity has been deleted from database. /// </summary> Gone, /// <summary> /// The Entity is in the process of being loaded. /// </summary> Loading, /// <summary> /// The Entity is in the process of being saved. /// </summary> Saving } } |
