Initial Async Support

Author: phongnguyend

src/EntityFrameworkCore.SqlServer.SimpleBulks/TempTable/TempTableBuilder.cs

@@ -114,8 +114,28 @@ private void Log(string message)
         _options?.LogTo?.Invoke($"{DateTimeOffset.Now:yyyy-MM-dd HH:mm:ss.fff zzz} [TempTable]: {message}");
     }
 
-    public Task<string> ExecuteAsync(CancellationToken cancellationToken = default)
+    public async Task<string> ExecuteAsync(CancellationToken cancellationToken = default)
     {
-        return Task.FromResult(Execute());
+        var tempTableName = $"[#{GetTableName()}]";
+        var dataTable = await _data.ToDataTableAsync(_columnNames, cancellationToken: cancellationToken);
+        var sqlCreateTempTable = dataTable.GenerateTableDefinition(tempTableName, _columnNameMappings, _columnTypeMappings);
+
+        Log($"Begin creating temp table:{Environment.NewLine}{sqlCreateTempTable}");
+
+        _connection.EnsureOpen();
+        using (var createTempTableCommand = _connection.CreateTextCommand(_transaction, sqlCreateTempTable))
+        {
+            await createTempTableCommand.ExecuteNonQueryAsync(cancellationToken);
+        }
+
+        Log("End creating temp table.");
+
+        Log($"Begin executing SqlBulkCopy. TableName: {tempTableName}");
+
+        await dataTable.SqlBulkCopyAsync(tempTableName, _columnNameMappings, _connection, _transaction, cancellationToken: cancellationToken);
+
+        Log("End executing SqlBulkCopy.");
+
+        return tempTableName;
     }
 }