@@ -30,8 +30,6 @@ namespace Serilog.Sinks.MSSqlServer
30
30
/// </summary>
31
31
public class MSSqlServerSink : PeriodicBatchingSink
32
32
{
33
- private readonly SinkOptions _sinkOptions ;
34
- private readonly ColumnOptions _columnOptions ;
35
33
private readonly ISqlBulkBatchWriter _sqlBulkBatchWriter ;
36
34
private readonly DataTable _eventTable ;
37
35
@@ -108,14 +106,13 @@ internal MSSqlServerSink(
108
106
SinkDependencies sinkDependencies )
109
107
: base ( sinkOptions ? . BatchPostingLimit ?? DefaultBatchPostingLimit , sinkOptions ? . BatchPeriod ?? DefaultPeriod )
110
108
{
111
- _sinkOptions = sinkOptions ;
112
109
if ( sinkOptions ? . TableName == null )
113
110
{
114
111
throw new InvalidOperationException ( "Table name must be specified!" ) ;
115
112
}
116
113
117
- _columnOptions = columnOptions ?? new ColumnOptions ( ) ;
118
- _columnOptions . FinalizeConfigurationForSinkConstructor ( ) ;
114
+ columnOptions = columnOptions ?? new ColumnOptions ( ) ;
115
+ columnOptions . FinalizeConfigurationForSinkConstructor ( ) ;
119
116
120
117
if ( sinkDependencies == null )
121
118
{
@@ -130,13 +127,13 @@ internal MSSqlServerSink(
130
127
}
131
128
_eventTable = sinkDependencies . DataTableCreator . CreateDataTable ( sinkOptions . TableName , columnOptions ) ;
132
129
133
- if ( _sinkOptions . AutoCreateSqlTable )
130
+ if ( sinkOptions . AutoCreateSqlTable )
134
131
{
135
132
if ( sinkDependencies ? . SqlBulkBatchWriter == null )
136
133
{
137
134
throw new InvalidOperationException ( $ "SqlTableCreator is not initialized!") ;
138
135
}
139
- sinkDependencies . SqlTableCreator . CreateTable ( sinkOptions . SchemaName , sinkOptions . TableName , _eventTable , _columnOptions ) ;
136
+ sinkDependencies . SqlTableCreator . CreateTable ( sinkOptions . SchemaName , sinkOptions . TableName , _eventTable , columnOptions ) ;
140
137
}
141
138
}
142
139
0 commit comments