使用Dapper执行插入和更新

我对使用Dapper很感兴趣，但据我所知，它只支持查询和执行。我没有看到Dapper包含插入和更新对象的方法。

假设我们的项目(大多数项目?)需要进行插入和更新，那么与dapper一起进行插入和更新的最佳实践是什么?

我们最好不要诉诸于ADO。NET参数构建方法等。

在这一点上，我能想到的最佳答案是使用LinqToSQL进行插入和更新。还有更好的答案吗?

当前回答

与其使用任何第三方库进行查询操作，我宁愿建议您自己编写查询。因为使用任何其他第三方包会带走使用dapper的主要优势，即编写查询的灵活性。

现在，为整个对象编写Insert或Update查询有一个问题。为此，你可以简单地创建如下所示的helper:

InsertQueryBuilder:

 public static string InsertQueryBuilder(IEnumerable < string > fields) {


  StringBuilder columns = new StringBuilder();
  StringBuilder values = new StringBuilder();


  foreach(string columnName in fields) {
   columns.Append($ "{columnName}, ");
   values.Append($ "@{columnName}, ");

  }
  string insertQuery = $ "({ columns.ToString().TrimEnd(',', ' ')}) VALUES ({ values.ToString().TrimEnd(',', ' ')}) ";

  return insertQuery;
 }

现在，通过简单地传递要插入的列的名称，整个查询将自动创建，如下所示:

List < string > columns = new List < string > {
 "UserName",
 "City"
}
//QueryBuilder is the class having the InsertQueryBuilder()
string insertQueryValues = QueryBuilderUtil.InsertQueryBuilder(columns);

string insertQuery = $ "INSERT INTO UserDetails {insertQueryValues} RETURNING UserId";

Guid insertedId = await _connection.ExecuteScalarAsync < Guid > (insertQuery, userObj);

您还可以通过传递TableName参数来修改该函数以返回整个INSERT语句。

确保Class属性名称与数据库中的字段名称匹配。然后只有你可以传递整个obj(如userObj在我们的情况下)和值将自动映射。

以同样的方式，你也可以有UPDATE查询的helper函数:

  public static string UpdateQueryBuilder(List < string > fields) {
   StringBuilder updateQueryBuilder = new StringBuilder();

   foreach(string columnName in fields) {
    updateQueryBuilder.AppendFormat("{0}=@{0}, ", columnName);
   }
   return updateQueryBuilder.ToString().TrimEnd(',', ' ');
  }

像这样使用它:

List < string > columns = new List < string > {
 "UserName",
 "City"
}
//QueryBuilder is the class having the UpdateQueryBuilder()
string updateQueryValues = QueryBuilderUtil.UpdateQueryBuilder(columns);

string updateQuery =  $"UPDATE UserDetails SET {updateQueryValues} WHERE UserId=@UserId";

await _connection.ExecuteAsync(updateQuery, userObj);

虽然在这些辅助函数中，您也需要传递您想要插入或更新的字段的名称，但至少您可以完全控制查询，并且还可以在需要时包含不同的WHERE子句。

通过这些helper函数，你将保存以下代码行:

插入查询:

 $ "INSERT INTO UserDetails (UserName,City) VALUES (@UserName,@City) RETURNING UserId";

更新查询:

$"UPDATE UserDetails SET UserName=@UserName, City=@City WHERE UserId=@UserId";

这似乎是几行代码的区别，但是当涉及到对具有超过10个字段的表执行插入或更新操作时，就可以感受到区别。

您可以使用操作符的名称来传递函数中的字段名称，以避免键入错误

而不是:

List < string > columns = new List < string > {
 "UserName",
 "City"
}

你可以这样写:

List < string > columns = new List < string > {
nameof(UserEntity.UserName),
nameof(UserEntity.City),
}

2020-07-06 05:48:35

其他回答

我们正在考虑构建一些助手，仍然决定api，如果这是在核心或不。详见:https://code.google.com/archive/p/dapper-dot-net/issues/6。

与此同时，你可以做以下事情

val = "my value";
cnn.Execute("insert into Table(val) values (@val)", new {val});

cnn.Execute("update Table set val = @val where Id = @id", new {val, id = 1});

等等

请参见我的博客文章:恼人的插入问题

更新

正如评论中指出的，现在在Dapper中有几个可用的扩展。以以下IDbConnection扩展方法的形式贡献项目:

T Get<T>(id);
IEnumerable<T> GetAll<T>();
int Insert<T>(T obj);
int Insert<T>(Enumerable<T> list);
bool Update<T>(T obj);
bool Update<T>(Enumerable<T> list);
bool Delete<T>(T obj);
bool Delete<T>(Enumerable<T> list);
bool DeleteAll<T>();

2011-05-11 12:45:30

你可以这样做:

sqlConnection.Open();

string sqlQuery = "INSERT INTO [dbo].[Customer]([FirstName],[LastName],[Address],[City]) VALUES (@FirstName,@LastName,@Address,@City)";
sqlConnection.Execute(sqlQuery,
    new
    {
        customerEntity.FirstName,
        customerEntity.LastName,
        customerEntity.Address,
        customerEntity.City
    });

Caius补充的编辑:

注意，没有必要以这种“操作之前/之后立即”的方式打开/关闭连接:如果您的连接关闭了，Dapper会打开它。如果你的连接是开放的，Dapper会让它保持开放。

如果你有很多操作要执行/你正在使用一个事务，你可以自己打开连接。如果你要做的只是打开/执行/关闭，就让Dapper来做。

而且，没有必要创建匿名类型;只要使参数名称与保存数据的任何类型的属性名称相匹配，并传递该类型而不是将其解压缩为匿名类型。

上面的代码可以这样写:

string sqlQuery = "INSERT INTO [dbo].[Customer]([FirstName],[LastName],[Address],[City]) VALUES (@FirstName,@LastName,@Address,@City)";

using(var sqlConnection = ...){
  sqlConnection.Execute(sqlQuery, customerEntity);

}

2011-07-05 07:17:57

你可以试试这个:

 string sql = "UPDATE Customer SET City = @City WHERE CustomerId = @CustomerId";             
 conn.Execute(sql, customerEntity);

2018-09-25 16:57:55