Skip to content

Commit f4aec37

Browse files
Replace sync methods calls with async analogs (#1457)
Replace sync methods calls with async analogs
1 parent d403fa5 commit f4aec37

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

Dapper.Contrib/SqlMapperExtensions.Async.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,7 @@ public static async Task<bool> DeleteAsync<T>(this IDbConnection connection, T e
313313
sb.AppendFormat("DELETE FROM {0} WHERE ", name);
314314

315315
var adapter = GetFormatter(connection);
316-
316+
317317
for (var i = 0; i < allKeyProperties.Count; i++)
318318
{
319319
var property = allKeyProperties[i];
@@ -379,7 +379,7 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran
379379
var cmd = $"INSERT INTO {tableName} ({columnList}) values ({parameterList}); SELECT SCOPE_IDENTITY() id";
380380
var multi = await connection.QueryMultipleAsync(cmd, entityToInsert, transaction, commandTimeout).ConfigureAwait(false);
381381

382-
var first = multi.Read().FirstOrDefault();
382+
var first = await multi.ReadFirstOrDefaultAsync().ConfigureAwait(false);
383383
if (first == null || first.id == null) return 0;
384384

385385
var id = (int)first.id;
@@ -531,7 +531,7 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran
531531
var cmd = $"INSERT INTO {tableName} ({columnList}) VALUES ({parameterList}); SELECT last_insert_rowid() id";
532532
var multi = await connection.QueryMultipleAsync(cmd, entityToInsert, transaction, commandTimeout).ConfigureAwait(false);
533533

534-
var id = (int)multi.Read().First().id;
534+
var id = (int)(await multi.ReadFirstAsync().ConfigureAwait(false)).id;
535535
var pi = keyProperties as PropertyInfo[] ?? keyProperties.ToArray();
536536
if (pi.Length == 0) return id;
537537

0 commit comments

Comments
 (0)