Add the ConnectionExtensions.Update() method

Author: cedx

src/Sql/CommandBuilder.cs

@@ -120,13 +120,13 @@ SELECT 1
 	public Command GetFindCommand<T>(object id, params string[] columns) where T: new() {
 		var table = Mapper.Instance.GetTable<T>();
 		var identityColumn = table.IdentityColumn ?? throw new InvalidOperationException("The identity column could not be found.");
-		var sql = $"""
+		var text = $"""
 			SELECT {(columns is null || columns.Length == 0 ? "*" : string.Join(", ", columns.Select(QuoteIdentifier)))}
 			FROM {QuoteIdentifier(table.Name)}
 			WHERE {QuoteIdentifier(identityColumn.Name)} = {(UsePositionalParameters ? "?" : GetParameterName(identityColumn.Name))}
 			""";
 
-		return new(sql, new(UsePositionalParameters ? "?1" : GetParameterName(identityColumn.Name), id));
+		return new(text, new(UsePositionalParameters ? "?1" : GetParameterName(identityColumn.Name), id));
 	}
 
 	/// <summary>
@@ -138,12 +138,12 @@ SELECT 1
 	public Command GetInsertCommand<T>(T instance) where T: new() {
 		var table = Mapper.Instance.GetTable<T>();
 		var fields = table.Columns.Values.Where(column => column.CanRead && !column.IsComputed).ToArray();
-		var sql = $"""
+		var text = $"""
 			INSERT INTO {QuoteIdentifier(table.Name)} ({string.Join(", ", fields.Select(field => QuoteIdentifier(field.Name)))})
 			VALUES ({string.Join(", ", fields.Select(field => UsePositionalParameters ? "?" : GetParameterName(field.Name)))})
 			""";
 
-		return new(sql, [.. fields.Select((field, index) => (UsePositionalParameters ? $"?{index}" : GetParameterName(field.Name), field.GetValue(instance)))]);
+		return new(text, [.. fields.Select((field, index) => (UsePositionalParameters ? $"?{index}" : GetParameterName(field.Name), field.GetValue(instance)))]);
 	}
 
 	/// <summary>
@@ -161,13 +161,13 @@ SELECT 1
 			.Where(column => column.CanRead && !column.IsComputed)
 			.ToArray();
 
-		var sql = $"""
+		var text = $"""
 			UPDATE {QuoteIdentifier(table.Name)}
 			SET {string.Join(", ", fields.Select(field => $"{QuoteIdentifier(field.Name)} = {(UsePositionalParameters ? "?" : GetParameterName(field.Name))}"))}
 			WHERE {QuoteIdentifier(identityColumn.Name)} = {(UsePositionalParameters ? "?" : GetParameterName(identityColumn.Name))}
 			""";
 
-		return new(sql, [
+		return new(text, [
 			.. fields.Select((field, index) => (UsePositionalParameters ? $"?{index}" : GetParameterName(field.Name), field.GetValue(instance))),
 			(GetParameterName(identityColumn.Name), identityColumn.GetValue(instance))
 		]);

src/Sql/ConnectionExtensions.Async.cs

@@ -297,4 +297,18 @@ record = Mapper.Instance.CreateInstance<T>(reader);
 
 		return rowCount == 1 ? record : default;
 	}
+
+	/// <summary>
+	/// Updates the specified entity.
+	/// </summary>
+	/// <typeparam name="T">The entity type.</typeparam>
+	/// <param name="connection">The connection to the data source.</param>
+	/// <param name="instance">The entity to update.</param>
+	/// <param name="columns">The list of columns to update. By default, all columns.</param>
+	/// <param name="options">The command options.</param>
+	/// <returns>The number of rows affected.</returns>
+	public static async Task<int> UpdateAsync<T>(this IDbConnection connection, T instance, string[]? columns = null, CommandOptions? options = null) where T: new() {
+		var (text, parameters) = new CommandBuilder(connection).GetUpdateCommand(instance, columns ?? []);
+		return await ExecuteAsync(connection, text, parameters, options);
+	}
 }

src/Sql/ConnectionExtensions.Sync.cs

@@ -281,4 +281,18 @@ record = Mapper.Instance.CreateInstance<T>(reader);
 
 		return rowCount == 1 ? record : default;
 	}
+
+	/// <summary>
+	/// Updates the specified entity.
+	/// </summary>
+	/// <typeparam name="T">The entity type.</typeparam>
+	/// <param name="connection">The connection to the data source.</param>
+	/// <param name="instance">The entity to update.</param>
+	/// <param name="columns">The list of columns to update. By default, all columns.</param>
+	/// <param name="options">The command options.</param>
+	/// <returns>The number of rows affected.</returns>
+	public static int Update<T>(this IDbConnection connection, T instance, string[]? columns = null, CommandOptions? options = null) where T: new() {
+		var (text, parameters) = new CommandBuilder(connection).GetUpdateCommand(instance, columns ?? []);
+		return Execute(connection, text, parameters, options);
+	}
 }

src/Sql/ConnectionExtensions.cs

@@ -18,7 +18,7 @@ public static partial class ConnectionExtensions {
 	/// <returns>The newly created command.</returns>
 	public static IDbCommand CreateCommand(this IDbConnection connection, string text, ParameterCollection? parameters = null, CommandOptions? options = null) {
 		var command = connection.CreateCommand();
-		command.CommandText = sql;
+		command.CommandText = text;
 		command.CommandTimeout = options?.Timeout ?? 30;
 		command.CommandType = options?.Type ?? CommandType.Text;
 		command.Transaction = options?.Transaction;