Commit 1a935bd7 authored by Marc Gravell's avatar Marc Gravell

ConfigureAwait; remove unnecessary async

parent 8741df9f
...@@ -194,7 +194,7 @@ public static bool IsWriteable(PropertyInfo pi) ...@@ -194,7 +194,7 @@ public static bool IsWriteable(PropertyInfo pi)
if (type.IsInterface) if (type.IsInterface)
{ {
var res = (await connection.QueryAsync<dynamic>(sql, dynParms)).FirstOrDefault() as IDictionary<string, object>; var res = (await connection.QueryAsync<dynamic>(sql, dynParms).ConfigureAwait(false)).FirstOrDefault() as IDictionary<string, object>;
if (res == null) if (res == null)
return (T)((object)null); return (T)((object)null);
...@@ -211,7 +211,7 @@ public static bool IsWriteable(PropertyInfo pi) ...@@ -211,7 +211,7 @@ public static bool IsWriteable(PropertyInfo pi)
} }
else else
{ {
obj = (await connection.QueryAsync<T>(sql, dynParms, transaction: transaction, commandTimeout: commandTimeout)).FirstOrDefault(); obj = (await connection.QueryAsync<T>(sql, dynParms, transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false)).FirstOrDefault();
} }
return obj; return obj;
} }
...@@ -282,7 +282,7 @@ private static string GetTableName(Type type) ...@@ -282,7 +282,7 @@ private static string GetTableName(Type type)
/// <param name="connection">Open SqlConnection</param> /// <param name="connection">Open SqlConnection</param>
/// <param name="entityToInsert">Entity to insert</param> /// <param name="entityToInsert">Entity to insert</param>
/// <returns>Identity of inserted entity</returns> /// <returns>Identity of inserted entity</returns>
public static async Task<long> InsertAsync<T>(this IDbConnection connection, T entityToInsert, IDbTransaction transaction = null, int? commandTimeout = null) where T : class public static Task<int> InsertAsync<T>(this IDbConnection connection, T entityToInsert, IDbTransaction transaction = null, int? commandTimeout = null) where T : class
{ {
var type = typeof(T); var type = typeof(T);
...@@ -313,8 +313,7 @@ private static string GetTableName(Type type) ...@@ -313,8 +313,7 @@ private static string GetTableName(Type type)
sbParameterList.Append(", "); sbParameterList.Append(", ");
} }
ISqlAdapter adapter = GetFormatter(connection); ISqlAdapter adapter = GetFormatter(connection);
int id = await adapter.InsertAsync(connection, transaction, commandTimeout, name, sbColumnList.ToString(), sbParameterList.ToString(), keyProperties, entityToInsert); return adapter.InsertAsync(connection, transaction, commandTimeout, name, sbColumnList.ToString(), sbParameterList.ToString(), keyProperties, entityToInsert);
return id;
} }
/// <summary> /// <summary>
...@@ -411,7 +410,7 @@ private static string GetTableName(Type type) ...@@ -411,7 +410,7 @@ private static string GetTableName(Type type)
if (i < keyProperties.Count() - 1) if (i < keyProperties.Count() - 1)
sb.AppendFormat(" and "); sb.AppendFormat(" and ");
} }
var updated = await connection.ExecuteAsync(sb.ToString(), entityToUpdate, commandTimeout: commandTimeout, transaction: transaction); var updated = await connection.ExecuteAsync(sb.ToString(), entityToUpdate, commandTimeout: commandTimeout, transaction: transaction).ConfigureAwait(false);
return updated > 0; return updated > 0;
} }
...@@ -479,7 +478,7 @@ private static string GetTableName(Type type) ...@@ -479,7 +478,7 @@ private static string GetTableName(Type type)
if (i < keyProperties.Count() - 1) if (i < keyProperties.Count() - 1)
sb.AppendFormat(" and "); sb.AppendFormat(" and ");
} }
var deleted = await connection.ExecuteAsync(sb.ToString(), entityToDelete, transaction: transaction, commandTimeout: commandTimeout); var deleted = await connection.ExecuteAsync(sb.ToString(), entityToDelete, transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
return deleted > 0; return deleted > 0;
} }
...@@ -510,7 +509,7 @@ private static string GetTableName(Type type) ...@@ -510,7 +509,7 @@ private static string GetTableName(Type type)
var type = typeof(T); var type = typeof(T);
var name = GetTableName(type); var name = GetTableName(type);
var statement = String.Format("delete from {0}", name); var statement = String.Format("delete from {0}", name);
var deleted = await connection.ExecuteAsync(statement, null, transaction: transaction, commandTimeout: commandTimeout); var deleted = await connection.ExecuteAsync(statement, null, transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
return deleted > 0; return deleted > 0;
} }
...@@ -740,10 +739,10 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran ...@@ -740,10 +739,10 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran
{ {
string cmd = String.Format("insert into {0} ({1}) values ({2})", tableName, columnList, parameterList); string cmd = String.Format("insert into {0} ({1}) values ({2})", tableName, columnList, parameterList);
await connection.ExecuteAsync(cmd, entityToInsert, transaction: transaction, commandTimeout: commandTimeout); await connection.ExecuteAsync(cmd, entityToInsert, transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
//NOTE: would prefer to use IDENT_CURRENT('tablename') or IDENT_SCOPE but these are not available on SQLCE //NOTE: would prefer to use IDENT_CURRENT('tablename') or IDENT_SCOPE but these are not available on SQLCE
var r = await connection.QueryAsync<dynamic>("select @@IDENTITY id", transaction: transaction, commandTimeout: commandTimeout); var r = await connection.QueryAsync<dynamic>("select @@IDENTITY id", transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
int id = (int)r.First().id; int id = (int)r.First().id;
if (keyProperties.Any()) if (keyProperties.Any())
keyProperties.First().SetValue(entityToInsert, id, null); keyProperties.First().SetValue(entityToInsert, id, null);
...@@ -809,7 +808,7 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran ...@@ -809,7 +808,7 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran
} }
} }
var results = await connection.QueryAsync<dynamic>(sb.ToString(), entityToInsert, transaction: transaction, commandTimeout: commandTimeout); var results = await connection.QueryAsync<dynamic>(sb.ToString(), entityToInsert, transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
// Return the key by assinging the corresponding property in the object - by product is that it supports compound primary keys // Return the key by assinging the corresponding property in the object - by product is that it supports compound primary keys
int id = 0; int id = 0;
...@@ -843,9 +842,9 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran ...@@ -843,9 +842,9 @@ public async Task<int> InsertAsync(IDbConnection connection, IDbTransaction tran
{ {
string cmd = String.Format("insert into {0} ({1}) values ({2})", tableName, columnList, parameterList); string cmd = String.Format("insert into {0} ({1}) values ({2})", tableName, columnList, parameterList);
await connection.ExecuteAsync(cmd, entityToInsert, transaction: transaction, commandTimeout: commandTimeout); await connection.ExecuteAsync(cmd, entityToInsert, transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
var r = await connection.QueryAsync<dynamic>("select last_insert_rowid() id", transaction: transaction, commandTimeout: commandTimeout); var r = await connection.QueryAsync<dynamic>("select last_insert_rowid() id", transaction: transaction, commandTimeout: commandTimeout).ConfigureAwait(false);
int id = (int)r.First().id; int id = (int)r.First().id;
if (keyProperties.Any()) if (keyProperties.Any())
keyProperties.First().SetValue(entityToInsert, id, null); keyProperties.First().SetValue(entityToInsert, id, null);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment