Adding a switch to read from the data source without using a transact…

…ion. This is useful for 'downlevel' ADO.NET providers like the OdbcConnection for dBase that does not support transactions.

Rhino.Etl.Core/Operations/InputCommandOperation.cs

@@ -17,6 +17,16 @@ public abstract class InputCommandOperation : AbstractCommandOperation
         public InputCommandOperation(string connectionStringName)
             : base(connectionStringName)
         {
+            UseTransaction = true;
+        }
+
+        ///<summary>
+        /// True, if the input operation should be run in a transaction. Otherwise,false.
+        ///</summary>
+        public bool UseTransaction
+        {
+            get;
+            set;
         }
 
         /// <summary>
@@ -27,7 +37,7 @@ public InputCommandOperation(string connectionStringName)
         public override IEnumerable<Row> Execute(IEnumerable<Row> rows)
         {
             using (IDbConnection connection = Use.Connection(ConnectionStringName))
-            using (IDbTransaction transaction = connection.BeginTransaction())
+            using (IDbTransaction transaction = BeginTransaction(connection))
             {
                 using (currentCommand = connection.CreateCommand())
                 {
@@ -41,8 +51,20 @@ public override IEnumerable<Row> Execute(IEnumerable<Row> rows)
                         }
                     }
                 }
-                transaction.Commit();
+                if (transaction != null)
+                {
+                    transaction.Commit();
+                }
+            }
+        }
+
+        IDbTransaction BeginTransaction(IDbConnection connection)
+        {
+            if (UseTransaction)
+            {
+                return connection.BeginTransaction();
             }
+            return null;
         }
 
         /// <summary>
@@ -58,4 +80,4 @@ public override IEnumerable<Row> Execute(IEnumerable<Row> rows)
         /// <param name="cmd">The command.</param>
         protected abstract void PrepareCommand(IDbCommand cmd);
     }
-}
+}