Skip to content

Commit

Permalink
Added column mappings for sql bulk copy
Browse files Browse the repository at this point in the history
  • Loading branch information
Engin KIRMACI committed Dec 11, 2015
1 parent 5c820a5 commit 94fb8e9
Showing 1 changed file with 7 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -104,6 +104,13 @@ protected override async Task EmitBatchAsync(IEnumerable<LogEvent> events)
using (var copy = new SqlBulkCopy(cn))
{
copy.DestinationTableName = _tableName;
foreach (var columun in _eventsTable.Columns)
{
var columnName = ((DataColumn)columun).ColumnName;
var mapping = new SqlBulkCopyColumnMapping(columnName, columnName);
copy.ColumnMappings.Add(mapping);
}

await copy.WriteToServerAsync(_eventsTable, _token.Token);

// Processed the items, clear for the next run
Expand Down

0 comments on commit 94fb8e9

Please sign in to comment.