Dapper сложное отображение Dapper.Extensions Dapper.FluentMap

У меня есть небольшая проблема с моим кодом и с тем, чтобы с ним хорошо играть.

Когда я говорю, что мой код был унаследован, значит, это не мой дизайн.

Я пытаюсь заменить Entity Framework, поскольку вызовы базы данных менее чем эффективны, поэтому я хотел лучше контролировать создаваемый SQL, поэтому Dapper казался очевидным выбором.

Проблема, с которой я сталкиваюсь, заключается в том, что я изо всех сил пытаюсь сопоставить классы poco, которые у меня есть, с dapper multi query.

Проблема у меня следующая:

    public Feed GetFeedDapper(int feedId)
        {
            Feed feed = null;

            var sql =
            @"
            SELECT * FROM Feeds WHERE FeedId= @FeedId
            SELECT * FROM FeedFilterParameters WHERE FeedId = @FeedId
            SELECT * FROM TeamFeeds WHERE FeedId = @FeedId";

            using (var multi = DbConnection.QueryMultiple(sql, new { FeedId = feedId }))
            {
                feed = multi.Read<Feed>().Single();
                feed.Parameters = multi.Read<FeedFilterParameter>().ToList();
                feed.TeamFeeds = multi.Read<TeamFeed>().ToList();
            } 

            return feed;
        }

Это дает мне правильные результаты из базы данных, и это нормально, проблема в том, что не все свойства объекта Feed сопоставляются. Фид имеет свойство InboundProperties типа InboundProperties, как показано ниже, и в базе данных они хранятся как InboundProperties_{PropName}. Эти свойства не сопоставляются, и ничего из того, что я пробовал в DapperExtensions или FluentMap, не работает.

public class InboundProperties
{
    public string ExternalRef { get; set; }
    public string ExternalRefPrevious { get; set; }
    public string ExternalId { get; set; }
    public string ExternalName { get; set; }
    public string ExternalToken { get; set; }
    public int ExternalAPICounts { get; set; }
    public string ExternalLink { get; set; }
    public string ExternalPicture { get; set; }
    public string LastProcessedMessageId { get; set; }
    public long? LastProcessedMessageTime { get; set; }
    public DateTime? MessageCountStartDT { get; set; }
    public Int32 TenancyId { get; set; }
    public virtual int FeedScopeInt { get; set; }
}

Может ли кто-нибудь помочь мне сопоставить эти свойства??


person jimplode    schedule 20.01.2015    source источник
comment
Просто из любопытства, что вы пробовали с Dapper.FluentMap?   -  person Henk Mollema    schedule 21.01.2015
comment
Я попытался сопоставить свойства, но он жаловался на повторяющиеся имена, поскольку в дочерних таблицах существует одно и то же имя столбца.   -  person jimplode    schedule 21.01.2015


Ответы (3)


Вы пробовали что-то вроде этого:

Feed feed = null;

var sql =
@"
SELECT * FROM Feeds WHERE FeedId= @FeedId
SELECT InboundProperties_ExternalRef as ExternalRef, InboundProperties_ExternalRefPrevious as ExternalRefPrevious FROM Feeds as InboundProperties WHERE FeedId= @FeedId
SELECT * FROM FeedFilterParameters WHERE FeedId = @FeedId
SELECT * FROM TeamFeeds WHERE FeedId = @FeedId";

using (var multi = DbConnection.QueryMultiple(sql, new { FeedId = feedId }))
{
    feed = multi.Read<Feed>().Single();
    feed.InboundProperties = multi.Read<InboundProperties>().Single();
    feed.Parameters = multi.Read<FeedFilterParameter>().ToList();
    feed.TeamFeeds = multi.Read<TeamFeed>().ToList();
} 

return feed;

Я сопоставил только 2 первых свойства, но если это сработает, вы будете знать, как сопоставить все свойства.

person rraszewski    schedule 20.01.2015
comment
Я думаю, что это может сработать, однако это просто кажется неправильным и неуклюжим... Я посмотрю, сработает ли это, и вернусь к вам. - person jimplode; 20.01.2015
comment
Это сработало бы, но мне не нравится тот факт, что я должен выполнять сопоставление вручную при каждом выборе, и из-за того, что мне нужно заменить более 100 вызовов, это займет немного времени. Я решил использовать расширения dapper, также опубликую это как ответ, так как это позволяет вам немного легче управлять отображением. - person jimplode; 20.01.2015
comment
Соглашусь, что это не лучшее решение. Как насчет чтения типа Feeds в dynamic и создания объекта Feed из динамического объекта? - person rraszewski; 20.01.2015
comment
Это тоже может сработать... Мне нравятся щеголеватые расширения, где я могу сопоставлять объекты на уровне класса. поэтому, предполагая, что он все еще будет более эффективным, чем EF, я собираюсь попробовать и посмотреть, что произойдет. - person jimplode; 20.01.2015
comment
Последняя вещь. Это скорее мой вопрос ;). Вы пробовали github.com/henkmollema/Dapper-FluentMap? - person rraszewski; 20.01.2015
comment
Я посмотрел на FluentMap, но не смог заставить его работать с моей настройкой!! Я мог бы повторно исследовать его только для полноты, и если я получу эту работу, я также поместил бы код здесь. - person jimplode; 20.01.2015

Вот как я решил это, но принял ответ #rraszewski, поскольку он также работает, но просто означает, что мне нужно позаботиться обо всех выборах очень ручным способом.

public Feed GetFeedDapper(int feedId)
{
    Feed feed = null;

    var multiPredicate = new GetMultiplePredicate();
    multiPredicate.Add<Feed>(Predicates.Field<Feed>(x => x.FeedId, Operator.Eq, feedId));
    multiPredicate.Add<InboundProperties>(Predicates.Field<InboundProperties>(x => x.FeedId, Operator.Eq, feedId));
    multiPredicate.Add<OutboundProperties>(Predicates.Field<OutboundProperties>(x => x.FeedId, Operator.Eq, feedId));
    multiPredicate.Add<FeedFilterParameter>(Predicates.Field<FeedFilterParameter>(x => x.FeedId, Operator.Eq, feedId));
    multiPredicate.Add<TeamFeed>(Predicates.Field<TeamFeed>(x => x.FeedId, Operator.Eq, feedId));

    var result = DbConnection.GetMultiple(multiPredicate);

    feed = result.Read<Feed>().Single();
    feed.InboundProperties = result.Read<InboundProperties>().Single();
    feed.OutboundProperties = result.Read<OutboundProperties>().Single();
    feed.Parameters = result.Read<FeedFilterParameter>().ToList();
    feed.TeamFeeds = result.Read<TeamFeed>().ToList();

    return feed;
}

Затем я сопоставляю классы:

public class FeedMapper : ClassMapper<Feed>
{
    public FeedMapper()
    {
        base.Table("Feeds");
        Map(f => f.FeedId).Key(KeyType.Identity);

        Map(f => f.Owner).Ignore();
        Map(f => f.TeamFeeds).Ignore();
        Map(f => f.FeedDirection).Ignore();
        Map(f => f.InboundProperties).Ignore();
        Map(f => f.Parameters).Ignore();
        Map(f => f.OutboundProperties).Ignore();
        Map(f => f.RelatedTeams).Ignore();

        AutoMap();
    }
}

public class InboundPropertiesMapper : ClassMapper<InboundProperties>
{
    public InboundPropertiesMapper()
    {
        base.Table("Feeds");
        Map(f => f.FeedId).Key(KeyType.Identity);

        Map(f => f.Channel).Ignore();
        Map(f => f.FeedScope).Ignore();

        Map(f => f.ChannelInt).Column("InboundProperties_ChannelInt");
        Map(f => f.ExternalAPICounts).Column("InboundProperties_ExternalAPICounts");
        Map(f => f.ExternalId).Column("InboundProperties_ExternalId");
        Map(f => f.ExternalLink).Column("InboundProperties_ExternalLink");
        Map(f => f.ExternalName).Column("InboundProperties_ExternalName");
        Map(f => f.ExternalPicture).Column("InboundProperties_ExternalPicture");
        Map(f => f.ExternalRef).Column("InboundProperties_ExternalRef");
        Map(f => f.ExternalRefPrevious).Column("InboundProperties_ExternalRefPrevious");
        Map(f => f.ExternalToken).Column("InboundProperties_ExternalToken");
        Map(f => f.FeedScopeInt).Column("InboundProperties_FeedScopeInt");
        Map(f => f.LastProcessedMessageId).Column("InboundProperties_LastProcessedMessageId");
        Map(f => f.LastProcessedMessageTime).Column("InboundProperties_LastProcessedMessageTime");
        Map(f => f.MessageCountStartDT).Column("InboundProperties_MessageCountStartDT");
        Map(f => f.TenancyId).Column("InboundProperties_TenancyId");
        AutoMap();
    }
}

public class OutboundPropertiesMapper : ClassMapper<OutboundProperties>
{
    public OutboundPropertiesMapper()
    {
        base.Table("Feeds");
        Map(f => f.FeedId).Key(KeyType.Identity);

        Map(f => f.Channel).Ignore();
        Map(f => f.FeedType).Ignore();

        Map(f => f.OutboundFeedTypeInt).Column("OutboundProperties_OutboundFeedTypeInt");
        Map(f => f.TenancyId).Column("OutboundProperties_TenancyId");
        AutoMap();
    }
}
person jimplode    schedule 20.01.2015
comment
Кажется хорошим решением; Но, к сожалению, я не могу найти GetMultiplePredicate. Можете ли вы направить, пожалуйста? Заранее спасибо. - person amiry jd; 18.12.2016
comment
Это часть библиотеки расширений Dapper nuget.org/packages/DapperExtensions. - person jimplode; 19.12.2016

Меня не удовлетворили представленные здесь решения (слишком подверженные ошибкам), поэтому я решил создать метод расширения для сопоставления объектов с использованием отражения.

public static class ConnectionExtensions
{
    public static IEnumerable<T> QueryIncludeNestedObjects<T>(this SqlConnection connection, string sql)
    {
        var queryResults = connection.Query<dynamic>(sql);
        var typeOfTMain = typeof(T);

        foreach(var row in queryResults)
        {
            var mappedObject = Activator.CreateInstance<T>();

            foreach (var col in row)
            {
                var colKey = (string)col.Key;
                var colValue = (object)col.Value;

                if(colKey.Contains("_"))
                {
                    var subObjNameAndProp = colKey.Split('_');

                    var subProperty = typeOfTMain.GetProperty(subObjNameAndProp[0]);

                    if (subProperty == null) continue;

                    var subObj = subProperty.GetValue(mappedObject);

                    if(subObj == null)
                    {
                        subObj = Activator.CreateInstance(subProperty.PropertyType);
                        typeOfTMain.GetProperty(subObjNameAndProp[0]).SetValue(mappedObject, subObj);
                    }

                    subObj.GetType().GetProperty(subObjNameAndProp[1])
                        .SetValue(subObj, colValue);

                }
                else
                    typeOfTMain.GetProperty(colKey)?.SetValue(mappedObject, colValue);

            }

            yield return mappedObject;
        }
    }
}

Затем вы используете его следующим образом:

dbConnection.QueryIncludeNestedObjects<Feed>("SELECT * FROM Feeds");

Если вы хотите использовать его внутри QueryMultiple, как в этом вопросе, просто измените метод следующим образом:

public static IEnumerable<T> ReadIncludeNestedObjects<T>(this GridReader gridReader)
{
    var queryResults = gridReader.Read<dynamic>();
    ...
person Raúl Bojalil    schedule 09.06.2018