Issue MikaelEliasson#12: Make SqlBulkCopy reuse connection to avoid credentials problem

MikaelEliasson · MikaelEliasson · commit d30b584f5d5f · 2014-08-31T19:50:33.000+02:00
diff --git a/EntityFramework.Utilities/EntityFramework.Utilities/SqlQueryProvider.cs b/EntityFramework.Utilities/EntityFramework.Utilities/SqlQueryProvider.cs
@@ -50,7 +50,12 @@ public void InsertItems<T>(IEnumerable<T> items, string schema, string tableName
         {
             using (var reader = new EFDataReader<T>(items, properties))
             {
-                using (SqlBulkCopy copy = new SqlBulkCopy(storeConnection.ConnectionString, SqlBulkCopyOptions.Default))
+                var con = storeConnection as SqlConnection;
+                if (con.State != System.Data.ConnectionState.Open)
+                {
+                    con.Open();
+                }
+                using (SqlBulkCopy copy = new SqlBulkCopy(con))
                 {
                     copy.BatchSize = Math.Min(reader.RecordsAffected, 15000); //default batch size
                     if (!string.IsNullOrWhiteSpace(schema))

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,12 @@ public void InsertItems<T>(IEnumerable<T> items, string schema, string tableName`
`50`	`50`	`{`
`51`	`51`	`using (var reader = new EFDataReader<T>(items, properties))`
`52`	`52`	`{`
`53`		`- using (SqlBulkCopy copy = new SqlBulkCopy(storeConnection.ConnectionString, SqlBulkCopyOptions.Default))`
	`53`	`+ var con = storeConnection as SqlConnection;`
	`54`	`+ if (con.State != System.Data.ConnectionState.Open)`
	`55`	`+ {`
	`56`	`+ con.Open();`
	`57`	`+ }`
	`58`	`+ using (SqlBulkCopy copy = new SqlBulkCopy(con))`
`54`	`59`	`{`
`55`	`60`	`copy.BatchSize = Math.Min(reader.RecordsAffected, 15000); //default batch size`
`56`	`61`	`if (!string.IsNullOrWhiteSpace(schema))`