Reformat

Author: Oren (electricessence)

DbConnectionFactory.cs

@@ -5,44 +5,44 @@
 
 namespace Open.Database.Extensions
 {
-    /// <summary>
-    /// Generic connection factory implementation that accepts a factory function.
-    /// </summary>
-    /// <typeparam name="TConnection"></typeparam>
-    public class DbConnectionFactory<TConnection> : IDbConnectionFactory<TConnection>
-        where TConnection:DbConnection
-    {
-        readonly Func<TConnection> _factory;
+	/// <summary>
+	/// Generic connection factory implementation that accepts a factory function.
+	/// </summary>
+	/// <typeparam name="TConnection"></typeparam>
+	public class DbConnectionFactory<TConnection> : IDbConnectionFactory<TConnection>
+		where TConnection : DbConnection
+	{
+		readonly Func<TConnection> _factory;
 
-        /// <summary>
-        /// Constructs a DbConnectionFactory.
-        /// </summary>
-        /// <param name="factory"></param>
-        public DbConnectionFactory(Func<TConnection> factory)
-        {
-            _factory = factory ?? throw new ArgumentNullException(nameof(factory));
-            Contract.EndContractBlock();
-        }
+		/// <summary>
+		/// Constructs a DbConnectionFactory.
+		/// </summary>
+		/// <param name="factory"></param>
+		public DbConnectionFactory(Func<TConnection> factory)
+		{
+			_factory = factory ?? throw new ArgumentNullException(nameof(factory));
+			Contract.EndContractBlock();
+		}
 
-        /// <summary>
-        /// Creates a connection of from the underlying factory function. 
-        /// </summary>
-        public virtual TConnection Create() => _factory();
+		/// <summary>
+		/// Creates a connection of from the underlying factory function. 
+		/// </summary>
+		public virtual TConnection Create() => _factory();
 
-        IDbConnection IDbConnectionFactory.Create() => Create();
-    }
+		IDbConnection IDbConnectionFactory.Create() => Create();
+	}
 
-    /// <summary>
-    /// DbConnection factory implementation that accepts a factory function.
-    /// </summary>
-    public class DbConnectionFactory : DbConnectionFactory<DbConnection>
-    {
-        /// <summary>
-        /// Constructs a DbConnectionFactory.
-        /// </summary>
-        /// <param name="factory"></param>
-        public DbConnectionFactory(Func<DbConnection> factory) : base(factory)
-        {
-        }
-    }
+	/// <summary>
+	/// DbConnection factory implementation that accepts a factory function.
+	/// </summary>
+	public class DbConnectionFactory : DbConnectionFactory<DbConnection>
+	{
+		/// <summary>
+		/// Constructs a DbConnectionFactory.
+		/// </summary>
+		/// <param name="factory"></param>
+		public DbConnectionFactory(Func<DbConnection> factory) : base(factory)
+		{
+		}
+	}
 }

Documentation.xml

@@ -4,10 +4,10 @@
 namespace Open.Database.Extensions
 {
 
-    public abstract partial class ExpressiveCommandBase<TConnection, TCommand, TDbType, TThis>
+	public abstract partial class ExpressiveCommandBase<TConnection, TCommand, TDbType, TThis>
 		where TConnection : class, IDbConnection
-        where TCommand : class, IDbCommand
-        where TDbType : struct
+		where TCommand : class, IDbCommand
+		where TDbType : struct
 		where TThis : ExpressiveCommandBase<TConnection, TCommand, TDbType, TThis>
 	{
 #pragma warning disable CS0659 // Type overrides Object.Equals(object o) but does not override Object.GetHashCode()
@@ -49,7 +49,7 @@ public override bool Equals(object obj) => obj is Param o
 			/// Equality operator.
 			/// </summary>
 			public static bool operator ==(Param left, Param right) => left.Equals(right);
-			
+
 			/// <summary>
 			/// Inequality operator.
 			/// </summary>

ExpressiveCommandBase.Param.cs

@@ -9,19 +9,19 @@ namespace Open.Database.Extensions
 	/// An abstraction for executing commands on a database using best practices and simplified expressive syntax.
 	/// </summary>
 	public class ExpressiveDbCommand : ExpressiveDbCommandBase<DbConnection, DbCommand, DbType, ExpressiveDbCommand>
-    {
-        /// <param name="connFactory">The factory to generate connections from.</param>
-        /// <param name="type">The command type>.</param>
-        /// <param name="command">The SQL command.</param>
-        /// <param name="params">The list of params</param>
-        public ExpressiveDbCommand(
+	{
+		/// <param name="connFactory">The factory to generate connections from.</param>
+		/// <param name="type">The command type>.</param>
+		/// <param name="command">The SQL command.</param>
+		/// <param name="params">The list of params</param>
+		public ExpressiveDbCommand(
 			IDbConnectionFactory<DbConnection> connFactory,
 			CommandType type,
 			string command,
 			IEnumerable<Param> @params = null)
-            : base(connFactory, type, command, @params)
-        {
-        }
+			: base(connFactory, type, command, @params)
+		{
+		}
 
 		/// <param name="connection">The connection to execute the command on.</param>
 		/// <param name="transaction">The optional transaction to execute the command on.</param>
@@ -34,23 +34,23 @@ public ExpressiveDbCommand(
 			CommandType type,
 			string command,
 			IEnumerable<Param> @params = null)
-            : base(connection, transaction, type, command, @params)
-        {
-        }
+			: base(connection, transaction, type, command, @params)
+		{
+		}
 
-        /// <summary>
-        /// Handles adding the list of parameters to a new command.
-        /// </summary>
-        /// <param name="command"></param>
-        protected override void AddParams(DbCommand command)
-        {
-            foreach (var p in Params)
-            {
-                var np = command.AddParameter(p.Name, p.Value);
-                if (p.Type.HasValue) np.DbType = p.Type.Value;
-            }
-        }
+		/// <summary>
+		/// Handles adding the list of parameters to a new command.
+		/// </summary>
+		/// <param name="command"></param>
+		protected override void AddParams(DbCommand command)
+		{
+			foreach (var p in Params)
+			{
+				var np = command.AddParameter(p.Name, p.Value);
+				if (p.Type.HasValue) np.DbType = p.Type.Value;
+			}
+		}
 
-    }
+	}
 
 }

ExpressiveDbCommand.cs

@@ -230,7 +230,7 @@ public Task<T> ExecuteReaderAsync<T>(Func<DbDataReader, T> transform, CommandBeh
 		/// <returns>The result of the transform.</returns>
 		public Task<T> ExecuteReaderAsync<T>(Func<DbDataReader, Task<T>> transform, CommandBehavior behavior = CommandBehavior.Default)
 		{
-			if (Connection==null || Connection.State == ConnectionState.Closed) behavior = behavior | CommandBehavior.CloseConnection;
+			if (Connection == null || Connection.State == ConnectionState.Closed) behavior = behavior | CommandBehavior.CloseConnection;
 			return ExecuteAsync(async command => await transform(await command.ExecuteReaderAsync(behavior, CancellationToken).ConfigureAwait(false)));
 		}
 
@@ -398,7 +398,8 @@ public ISourceBlock<T> AsSourceBlockAsync<T>(Func<IDataRecord, T> transform)
 
 			var source = new BufferBlock<T>();
 			ToTargetBlockAsync(source, transform)
-				.ContinueWith(t => {
+				.ContinueWith(t =>
+				{
 					if (t.IsFaulted) ((ITargetBlock<T>)source).Fault(t.Exception);
 					else source.Complete();
 				})