Merge pull request #3 from mullerc/fix-temp-table-name

Fix temporary table naming by removing '.' from name
KostovMartin · Jun 4, 2018 · 1495e2e · 1495e2e
2 parents ce9b57b + c164f84
commit 1495e2e
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/Dapper.Bulk/DapperBulk.cs b/src/Dapper.Bulk/DapperBulk.cs
@@ -31,7 +31,7 @@ public static void BulkInsert<T>(this SqlConnection connection, IEnumerable<T> d
 
             var allPropertiesExceptKeyAndComputed = allProperties.Except(keyProperties.Union(computedProperties)).ToList();
             var allPropertiesExceptKeyAndComputedString = GetColumnsStringSqlServer(allPropertiesExceptKeyAndComputed);
-            var tempToBeInserted = $"#{tableName}_TempInsert";
+            var tempToBeInserted = $"#{tableName}_TempInsert".Replace(".", string.Empty);
 
             connection.Execute($@"SELECT TOP 0 {allPropertiesExceptKeyAndComputedString} INTO {tempToBeInserted} FROM {tableName} target WITH(NOLOCK);", null, transaction);
 
@@ -82,8 +82,8 @@ public static IEnumerable<T> BulkInsertAndSelect<T>(this SqlConnection connectio
             var allPropertiesExceptKeyAndComputedString = GetColumnsStringSqlServer(allPropertiesExceptKeyAndComputed);
             var allPropertiesString = GetColumnsStringSqlServer(allProperties, "target.");
 
-            var tempToBeInserted = $"#{tableName}_TempInsert";
-            var tempInsertedWithIdentity = $"@{tableName}_TempInserted";
+            var tempToBeInserted = $"#{tableName}_TempInsert".Replace(".", string.Empty);
+            var tempInsertedWithIdentity = $"@{tableName}_TempInserted".Replace(".", string.Empty);
 
             connection.Execute($"SELECT TOP 0 {allPropertiesExceptKeyAndComputedString} INTO {tempToBeInserted} FROM {tableName} target WITH(NOLOCK);", null, transaction);
 
@@ -127,7 +127,7 @@ public static async Task BulkInsertAsync<T>(this SqlConnection connection, IEnum
             var computedProperties = PropertiesCache.ComputedPropertiesCache(type);
             var allPropertiesExceptKeyAndComputed = allProperties.Except(keyProperties.Union(computedProperties)).ToList();
             var allPropertiesExceptKeyAndComputedString = GetColumnsStringSqlServer(allPropertiesExceptKeyAndComputed);
-            var tempToBeInserted = $"#{tableName}_TempInsert";
+            var tempToBeInserted = $"#{tableName}_TempInsert".Replace(".", string.Empty);
 
             await connection.ExecuteAsync($@"SELECT TOP 0 {allPropertiesExceptKeyAndComputedString} INTO {tempToBeInserted} FROM {tableName} target WITH(NOLOCK);", null, transaction);
 
@@ -177,8 +177,8 @@ public static async Task<IEnumerable<T>> BulkInsertAndSelectAsync<T>(this SqlCon
             var allPropertiesExceptKeyAndComputedString = GetColumnsStringSqlServer(allPropertiesExceptKeyAndComputed);
             var allPropertiesString = GetColumnsStringSqlServer(allProperties, "target.");
 
-            var tempToBeInserted = $"#{tableName}_TempInsert";
-            var tempInsertedWithIdentity = $"@{tableName}_TempInserted";
+            var tempToBeInserted = $"#{tableName}_TempInsert".Replace(".", string.Empty);
+            var tempInsertedWithIdentity = $"@{tableName}_TempInserted".Replace(".", string.Empty);
 
             await connection.ExecuteAsync($@"SELECT TOP 0 {allPropertiesExceptKeyAndComputedString} INTO {tempToBeInserted} FROM {tableName} target WITH(NOLOCK);", null, transaction);