NH-3905 - Generate Async

Author: fredericDelaporte

src/NHibernate.DomainModel/Async/CustomPersister.cs

@@ -0,0 +1,197 @@
+//------------------------------------------------------------------------------
+// <auto-generated>
+//     This code was generated by AsyncGenerator.
+//
+//     Changes to this file may cause incorrect behavior and will be lost if
+//     the code is regenerated.
+// </auto-generated>
+//------------------------------------------------------------------------------
+
+
+using System;
+using System.Collections;
+using NHibernate.Cache;
+using NHibernate.Cache.Entry;
+using NHibernate.Engine;
+using NHibernate.Event;
+using NHibernate.Id;
+using NHibernate.Mapping;
+using NHibernate.Metadata;
+using NHibernate.Persister.Entity;
+using NHibernate.Tuple.Entity;
+using NHibernate.Type;
+using NHibernate.Util;
+
+namespace NHibernate.DomainModel
+{
+	using System.Threading.Tasks;
+	using System.Threading;
+	/// <content>
+	/// Contains generated async methods
+	/// </content>
+	public partial class CustomPersister : IEntityPersister
+	{
+
+		#region IEntityPersister Members
+
+		#region IOptimisticCacheSource Members
+
+		public Task<int[]> FindDirtyAsync(object[] currentState, object[] previousState, object entity, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				if (!EqualsHelper.Equals(currentState[0], previousState[0]))
+				{
+					return Task.FromResult<int[]>(new int[] { 0 });
+				}
+				else
+				{
+					return Task.FromResult<int[]>(null);
+				}
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<int[]>(ex);
+			}
+		}
+
+		public Task<int[]> FindModifiedAsync(object[] old, object[] current, object entity, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				if (!EqualsHelper.Equals(old[0], current[0]))
+				{
+					return Task.FromResult<int[]>(new int[] { 0 });
+				}
+				else
+				{
+					return Task.FromResult<int[]>(null);
+				}
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<int[]>(ex);
+			}
+		}
+
+		public Task<object[]> GetNaturalIdentifierSnapshotAsync(object id, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			return Task.FromResult<object[]>(null);
+		}
+
+		public async Task<object> LoadAsync(object id, object optionalObject, LockMode lockMode, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			// fails when optional object is supplied
+			Custom clone = null;
+			Custom obj = (Custom)Instances[id];
+			if (obj != null)
+			{
+				clone = (Custom)obj.Clone();
+				TwoPhaseLoad.AddUninitializedEntity(session.GenerateEntityKey(id, this), clone, this, LockMode.None, false,
+				                                    session);
+				TwoPhaseLoad.PostHydrate(this, id, new String[] {obj.Name}, null, clone, LockMode.None, false, session);
+				await (TwoPhaseLoad.InitializeEntityAsync(clone, false, session, new PreLoadEvent((IEventSource) session),
+				                              new PostLoadEvent((IEventSource) session), cancellationToken));
+			}
+			return clone;
+		}
+
+		public Task LockAsync(object id, object version, object obj, LockMode lockMode, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			throw new NotSupportedException();
+		}
+
+		public Task InsertAsync(object id, object[] fields, object obj, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				Instances[id] = ((Custom)obj).Clone();
+				return Task.CompletedTask;
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<object>(ex);
+			}
+		}
+
+		public Task<object> InsertAsync(object[] fields, object obj, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			throw new NotSupportedException();
+		}
+
+		public Task DeleteAsync(object id, object version, object obj, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				Instances.Remove(id);
+				return Task.CompletedTask;
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<object>(ex);
+			}
+		}
+
+		public Task UpdateAsync(object id, object[] fields, int[] dirtyFields, bool hasDirtyCollection, object[] oldFields,
+		                   object oldVersion, object obj, object rowId, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				Instances[id] = ((Custom)obj).Clone();
+				return Task.CompletedTask;
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<object>(ex);
+			}
+		}
+
+		public Task<object[]> GetDatabaseSnapshotAsync(object id, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			return Task.FromResult<object[]>(null);
+		}
+
+		public Task<object> GetCurrentVersionAsync(object id, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				return Task.FromResult<object>(Instances[id]);
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<object>(ex);
+			}
+		}
+
+		public Task<object> ForceVersionIncrementAsync(object id, object currentVersion, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			return Task.FromResult<object>(null);
+		}
+
+		public Task<bool?> IsTransientAsync(object obj, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			try
+			{
+				return Task.FromResult<bool?>(((Custom) obj).Id == null);
+			}
+			catch (Exception ex)
+			{
+				return Task.FromException<bool?>(ex);
+			}
+		}
+
+		public Task ProcessInsertGeneratedPropertiesAsync(object id, object entity, object[] state, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			return Task.CompletedTask;
+		}
+
+		public Task ProcessUpdateGeneratedPropertiesAsync(object id, object entity, object[] state, ISessionImplementor session, CancellationToken cancellationToken)
+		{
+			return Task.CompletedTask;
+		}
+
+		#endregion
+
+		#endregion
+	}
+}

src/NHibernate.DomainModel/CustomPersister.cs

@@ -17,7 +17,7 @@ namespace NHibernate.DomainModel
 	/// <summary>
 	/// Summary description for CustomPersister.
 	/// </summary>
-	public class CustomPersister : IEntityPersister
+	public partial class CustomPersister : IEntityPersister
 	{
 		private static readonly Hashtable Instances = new Hashtable();
 		private static readonly IIdentifierGenerator Generator = new UUIDHexGenerator();