diff --git a/src/NHibernate/AdoNet/GenericBatchingBatcher.cs b/src/NHibernate/AdoNet/GenericBatchingBatcher.cs
index eac197df446..f6f7de4e4b7 100644
--- a/src/NHibernate/AdoNet/GenericBatchingBatcher.cs
+++ b/src/NHibernate/AdoNet/GenericBatchingBatcher.cs
@@ -1,5 +1,4 @@
-using System;
-using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
 using System.Text;
@@ -215,23 +214,24 @@ public int ExecuteNonQuery()
 					return 0;
 				}
 
-				var batcherCommand = _batcher.Driver.GenerateCommand(
+				using (var batcherCommand = _batcher.Driver.GenerateCommand(
 					_commandType,
 					_sql.ToSqlString(),
-					_sqlTypes.ToArray()
-				);
-				for (var i = 0; i < _parameters.Count; i++)
+					_sqlTypes.ToArray()))
 				{
-					var parameter = _parameters[i];
-					var cmdParam = batcherCommand.Parameters[i];
-					cmdParam.Value = parameter.Value;
-					cmdParam.Direction = parameter.Direction;
-					cmdParam.Precision = parameter.Precision;
-					cmdParam.Scale = parameter.Scale;
-					cmdParam.Size = parameter.Size;
+					for (var i = 0; i < _parameters.Count; i++)
+					{
+						var parameter = _parameters[i];
+						var cmdParam = batcherCommand.Parameters[i];
+						cmdParam.Value = parameter.Value;
+						cmdParam.Direction = parameter.Direction;
+						cmdParam.Precision = parameter.Precision;
+						cmdParam.Scale = parameter.Scale;
+						cmdParam.Size = parameter.Size;
+					}
+					_batcher.Prepare(batcherCommand);
+					return batcherCommand.ExecuteNonQuery();
 				}
-				_batcher.Prepare(batcherCommand);
-				return batcherCommand.ExecuteNonQuery();
 			}
 
 			public void Clear()
diff --git a/src/NHibernate/Async/AdoNet/GenericBatchingBatcher.cs b/src/NHibernate/Async/AdoNet/GenericBatchingBatcher.cs
index 549dc3fee4e..0a79e41c520 100644
--- a/src/NHibernate/Async/AdoNet/GenericBatchingBatcher.cs
+++ b/src/NHibernate/Async/AdoNet/GenericBatchingBatcher.cs
@@ -8,7 +8,6 @@
 //------------------------------------------------------------------------------
 
 
-using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
@@ -90,23 +89,24 @@ public async Task<int> ExecuteNonQueryAsync(CancellationToken cancellationToken)
 					return 0;
 				}
 
-				var batcherCommand = _batcher.Driver.GenerateCommand(
+				using (var batcherCommand = _batcher.Driver.GenerateCommand(
 					_commandType,
 					_sql.ToSqlString(),
-					_sqlTypes.ToArray()
-				);
-				for (var i = 0; i < _parameters.Count; i++)
+					_sqlTypes.ToArray()))
 				{
-					var parameter = _parameters[i];
-					var cmdParam = batcherCommand.Parameters[i];
-					cmdParam.Value = parameter.Value;
-					cmdParam.Direction = parameter.Direction;
-					cmdParam.Precision = parameter.Precision;
-					cmdParam.Scale = parameter.Scale;
-					cmdParam.Size = parameter.Size;
+					for (var i = 0; i < _parameters.Count; i++)
+					{
+						var parameter = _parameters[i];
+						var cmdParam = batcherCommand.Parameters[i];
+						cmdParam.Value = parameter.Value;
+						cmdParam.Direction = parameter.Direction;
+						cmdParam.Precision = parameter.Precision;
+						cmdParam.Scale = parameter.Scale;
+						cmdParam.Size = parameter.Size;
+					}
+					await (_batcher.PrepareAsync(batcherCommand, cancellationToken)).ConfigureAwait(false);
+					return await (batcherCommand.ExecuteNonQueryAsync(cancellationToken)).ConfigureAwait(false);
 				}
-				await (_batcher.PrepareAsync(batcherCommand, cancellationToken)).ConfigureAwait(false);
-				return await (batcherCommand.ExecuteNonQueryAsync(cancellationToken)).ConfigureAwait(false);
 			}
 		}
 	}