@@ -153,19 +153,19 @@ public virtual async Task<List<T>> BulkInsertReturnEntities<T>(
153153 {
154154 List < T > result ;
155155
156- var connectionInfo = await context . GetConnection ( sync , ctk ) ;
156+ var connection = await context . GetConnection ( sync , ctk ) ;
157157 try
158158 {
159159 var ( tableName , _) = await PerformBulkInsertAsync ( sync , context , tableInfo , entities , options , tempTableRequired : true , ctk : ctk ) ;
160160
161161 result = await CopyFromTempTableAsync < T > ( sync , context , tableInfo , tableName , true , options , onConflict , ctk : ctk ) ;
162162
163163 // Commit the transaction if we own them.
164- await connectionInfo . Commit ( sync , ctk ) ;
164+ await connection . Commit ( sync , ctk ) ;
165165 }
166166 finally
167167 {
168- await connectionInfo . Close ( sync , ctk ) ;
168+ await connection . Close ( sync , ctk ) ;
169169 }
170170
171171 return result ;
@@ -182,19 +182,19 @@ public virtual async Task BulkInsert<T>(
182182 {
183183 if ( onConflict != null )
184184 {
185- var connectionInfo = await context . GetConnection ( sync , ctk ) ;
185+ var connection = await context . GetConnection ( sync , ctk ) ;
186186 try
187187 {
188188 var ( tableName , _) = await PerformBulkInsertAsync ( sync , context , tableInfo , entities , options , tempTableRequired : true , ctk : ctk ) ;
189189
190190 await CopyFromTempTableAsync < T > ( sync , context , tableInfo , tableName , false , options , onConflict , ctk ) ;
191191
192192 // Commit the transaction if we own them.
193- await connectionInfo . Commit ( sync , ctk ) ;
193+ await connection . Commit ( sync , ctk ) ;
194194 }
195195 finally
196196 {
197- await connectionInfo . Close ( sync , ctk ) ;
197+ await connection . Close ( sync , ctk ) ;
198198 }
199199 }
200200 else
@@ -217,7 +217,7 @@ public virtual async Task BulkInsert<T>(
217217 throw new InvalidOperationException ( "No entities to insert." ) ;
218218 }
219219
220- var connectionInfo = await context . GetConnection ( sync , ctk ) ;
220+ var connection = await context . GetConnection ( sync , ctk ) ;
221221
222222 var tableName = tempTableRequired
223223 ? await CreateTableCopyAsync < T > ( sync , context , options , tableInfo , ctk )
@@ -230,14 +230,14 @@ public virtual async Task BulkInsert<T>(
230230 await BulkInsert ( false , context , tableInfo , entities , tableName , properties , options , ctk ) ;
231231
232232 // Commit the transaction if we own them.
233- await connectionInfo . Commit ( sync , ctk ) ;
233+ await connection . Commit ( sync , ctk ) ;
234234 }
235235 finally
236236 {
237- await connectionInfo . Close ( sync , ctk ) ;
237+ await connection . Close ( sync , ctk ) ;
238238 }
239239
240- return ( tableName , connectionInfo . Connection ) ;
240+ return ( tableName , connection . Connection ) ;
241241 }
242242
243243 /// <summary>
0 commit comments