2

现在我正在使用 Dapper + Dapper.Extensions。是的，这很容易而且很棒。但我遇到了一个问题：Dapper.Extensions 只有Insert命令，没有 InsertUpdateOnDUplicateKey。我想添加这样的方法，但我看不到这样做的好方法：

  1. 我想让这个方法像插入一样通用
  2. 我无法获取特定类型的缓存属性列表，因为我不想直接使用反射来构建原始 sql

在 github 上 fork 的可能方式，但我只想在我的项目中使用它。有人知道如何扩展它吗？我了解此功能（“插入...更新重复键”）仅在 MySQL 中受支持。但是我在 DapperExtensions 中找不到扩展点来在外面添加这个功能。
更新：这是我的叉子https://github.com/MaximTkachenko/Dapper-Extensions/commits/master

4

2 回答 2

0

实际上我关闭了我的拉取请求并删除了我的叉子，因为：

  1. 我看到 2014 年创建了一些开放的拉取请求
  2. 我找到了一种在 Dapper.Extensions 中“注入”我的代码的方法。

我提醒我的问题：我想为 Dapper.Extensions 创建更多通用查询。这意味着我需要访问实体、SqlGenerator 等的映射缓存。所以这是我的方式。我想增加对 MySQL进行INSERT .. UPDATE ON DUPLICATE KEY的能力。我为ISqlGenerator创建了扩展方法

   public static class SqlGeneratorExt
    {
        public static string InsertUpdateOnDuplicateKey(this ISqlGenerator generator, IClassMapper classMap)
        {
            var columns = classMap.Properties.Where(p => !(p.Ignored || p.IsReadOnly || p.KeyType == KeyType.Identity));
            if (!columns.Any())
            {
                throw new ArgumentException("No columns were mapped.");
            }

            var columnNames = columns.Select(p => generator.GetColumnName(classMap, p, false));
            var parameters = columns.Select(p => generator.Configuration.Dialect.ParameterPrefix + p.Name);
            var valuesSetters = columns.Select(p => string.Format("{0}=VALUES({1})", generator.GetColumnName(classMap, p, false), p.Name));

            string sql = string.Format("INSERT INTO {0} ({1}) VALUES ({2}) ON DUPLICATE KEY UPDATE {3}",
                                       generator.GetTableName(classMap),
                                       columnNames.AppendStrings(),
                                       parameters.AppendStrings(),
                                       valuesSetters.AppendStrings());

            return sql;
        }
    }

IDapperImplementor的另一种扩展方法

public static class DapperImplementorExt
{
    public static void InsertUpdateOnDuplicateKey<T>(this IDapperImplementor implementor, IDbConnection connection, IEnumerable<T> entities, int? commandTimeout = null) where T : class
    {
        IClassMapper classMap = implementor.SqlGenerator.Configuration.GetMap<T>();
        var properties = classMap.Properties.Where(p => p.KeyType != KeyType.NotAKey);
        string emptyGuidString = Guid.Empty.ToString();

        foreach (var e in entities)
        {
            foreach (var column in properties)
            {
                if (column.KeyType == KeyType.Guid)
                {
                    object value = column.PropertyInfo.GetValue(e, null);
                    string stringValue = value.ToString();
                    if (!string.IsNullOrEmpty(stringValue) && stringValue != emptyGuidString)
                    {
                        continue;
                    }

                    Guid comb = implementor.SqlGenerator.Configuration.GetNextGuid();
                    column.PropertyInfo.SetValue(e, comb, null);
                }
            }
        }

        string sql = implementor.SqlGenerator.InsertUpdateOnDuplicateKey(classMap);

        connection.Execute(sql, entities, null, commandTimeout, CommandType.Text);
    }
}

现在我可以创建从数据库类派生的新类来使用我自己的 sql

public class Db : Database
{
    private readonly IDapperImplementor _dapperIml;

    public Db(IDbConnection connection, ISqlGenerator sqlGenerator) : base(connection, sqlGenerator)
    {
        _dapperIml = new DapperImplementor(sqlGenerator);
    }

    public void InsertUpdateOnDuplicateKey<T>(IEnumerable<T> entities, int? commandTimeout) where T : class
    {
        _dapperIml.InsertUpdateOnDuplicateKey(Connection, entities, commandTimeout);
    }
}

是的，需要创建另一个 DapperImplementor 实例，因为来自基类的 DapperImplementor 实例是私有的 :(。所以现在我可以使用我的 Db 类从 Dapper.Extension 调用我自己的通用 sql 查询和本机查询。使用示例数据库类而不是IDbConnection 扩展可以在这里找到。

于 2016-07-05T13:41:37.023 回答
0

这段代码在 MySQL 相关项目中帮助了我很大，我绝对欠你一个。

我在 MySQL 和 MS SQL 上做了很多与数据库相关的开发。我还尝试在我的项目之间共享尽可能多的代码。

MS SQL 没有“ON DUPLICATE KEY UPDATE”的直接等效项，因此我以前在使用 MS SQL 时无法使用此扩展。

在将 Web 应用程序（很大程度上依赖于 Dapper.Extensions 调整）从 MySQL 迁移到 MS SQL 时，我最终决定做点什么。

此代码使用“IF EXISTS => UPDATE ELSE INSERT”方法，该方法与 MySQL 上的“ON DUPLICATE KEY UPDATE”基本相同。

请注意：该片段假定您正在处理此方法之外的事务。或者，您可以将“BEGIN TRAN”附加到生成的 sql 字符串的开头并将“COMMIT”附加到生成的 sql 字符串的末尾。

public static class SqlGeneratorExt
{
    public static string InsertUpdateOnDuplicateKey(this ISqlGenerator generator, IClassMapper classMap, bool hasIdentityKeyWithValue = false)
    {
        var columns = classMap.Properties.Where(p => !(p.Ignored || p.IsReadOnly || (p.KeyType == KeyType.Identity && !hasIdentityKeyWithValue))).ToList();
        var keys = columns.Where(c => c.KeyType != KeyType.NotAKey).Select(p => $"{generator.GetColumnName(classMap, p, false)}=@{p.Name}");
        var nonkeycolumns = classMap.Properties.Where(p => !(p.Ignored || p.IsReadOnly) && p.KeyType == KeyType.NotAKey).ToList();
        if (!columns.Any())
        {
            throw new ArgumentException("No columns were mapped.");
        }
        var tablename = generator.GetTableName(classMap);
        var columnNames = columns.Select(p => generator.GetColumnName(classMap, p, false));
        var parameters = columns.Select(p => generator.Configuration.Dialect.ParameterPrefix + p.Name);
        var valuesSetters = nonkeycolumns.Select(p => $"{generator.GetColumnName(classMap, p, false)}=@{p.Name}").ToList();
        var where = keys.AppendStrings(seperator: " and ");
        var sqlbuilder = new StringBuilder();
        sqlbuilder.AppendLine($"IF EXISTS (select * from {tablename} WITH (UPDLOCK, HOLDLOCK) WHERE ({where})) ");
        sqlbuilder.AppendLine(valuesSetters.Any() ? $"UPDATE {tablename} SET {valuesSetters.AppendStrings()} WHERE ({where}) " : "SELECT 0 ");
        sqlbuilder.AppendLine($"ELSE INSERT INTO {tablename} ({columnNames.AppendStrings()}) VALUES ({parameters.AppendStrings()}) ");
        return sqlbuilder.ToString();
    }
}
于 2017-11-24T16:51:50.007 回答