Added implementation which builds SqlBulkCopyOptions.

Master Garrett · Master Garrett · commit 78f45520f4e7 · 2013-02-25T23:51:49.000+01:00
diff --git a/Simple.Data.SqlServer/SqlBulkInserter.cs b/Simple.Data.SqlServer/SqlBulkInserter.cs
@@ -25,16 +25,17 @@ public IEnumerable<IDictionary<string, object>> Insert(AdoAdapter adapter, strin
 
             SqlConnection connection;
             SqlBulkCopy bulkCopy;
+            var sqlBulkCopyOptions = BuildBulkCopyOptions(adapter);
 
             if (transaction != null)
             {
                 connection = (SqlConnection) transaction.Connection;
-                bulkCopy = new SqlBulkCopy(connection, SqlBulkCopyOptions.Default, (SqlTransaction)transaction);
+                bulkCopy = new SqlBulkCopy(connection, sqlBulkCopyOptions, (SqlTransaction)transaction);
             }
             else
             {
                 connection = (SqlConnection) adapter.CreateConnection();
-                bulkCopy = new SqlBulkCopy(connection);
+                bulkCopy = new SqlBulkCopy(connection, sqlBulkCopyOptions, null);
             }
 
             bulkCopy.DestinationTableName = adapter.GetSchema().FindTable(tableName).QualifiedName;
@@ -67,6 +68,20 @@ public IEnumerable<IDictionary<string, object>> Insert(AdoAdapter adapter, strin
             return null;
         }
 
+        private SqlBulkCopyOptions BuildBulkCopyOptions(AdoAdapter adapter)
+        {
+            var options = SqlBulkCopyOptions.Default;
+
+            if (adapter.AdoOptions != null)
+            {
+                options |= (adapter.AdoOptions.FireTriggersOnBulkInserts
+                                ? SqlBulkCopyOptions.FireTriggers
+                                : SqlBulkCopyOptions.Default);
+            }
+
+            return options;
+        }
+
         private DataTable CreateDataTable(AdoAdapter adapter, string tableName, ICollection<string> keys, SqlBulkCopy bulkCopy)
         {
             var table = adapter.GetSchema().FindTable(tableName);
