Início / coding / Perguntas / 78690212
Accepted
chuckd
Asked: 2024-07-01 09:46:04 +0800 CST

Como executo o EF Core ExecuteUpdateAsync e adiciono uma nova entidade como parte dessa atualização?

  • 772

Estou executando o código abaixo, mas recebo uma exceção ao YogabandyFeeexecutá-lo.

var payoutResult = await _dbContext.StripePayouts
    .Where(p => p.StripePayoutId == stripePayoutId)
    .Select(p => new { p.GrossAmount, p.TotalTokens, p.NetAmount, p.ReconciledTransfers, p.EditedDate, p.YogabandyFee })
.ExecuteUpdateAsync(setters => setters
    .SetProperty(p => p.GrossAmount, grossAmount)
    .SetProperty(p => p.TotalTokens, totalTokens)
    .SetProperty(p => p.YogabandyFee, p => new YogabandyFee { TotalFee = (grossAmount - p.NetAmount - platformFee) } )
    .SetProperty(p => p.ReconciledTransfers, true)
    .SetProperty(p => p.EditedDate, DateTime.UtcNow)
);

Isso pode ser feito? Posso criar uma nova entrada neste tipo de atualização?

Aqui está o erro:

System.InvalidOperationException: A expressão LINQ 'DbSet() .Where(s => s.StripePayoutId == __stripePayoutId_0) .LeftJoin( inner: DbSet(), outerKeySelector: s => EF.Property(s, "Id"), innerKeySelector : y => EF.Property(y, "StripePayoutId"), resultSelector: (o, i) => new TransparentIdentifier( Outer = o, Inner = i )) .Select(s => new { GrossAmount = s.Outer. GrossAmount, TotalTokens = s.Outer.TotalTokens, NetAmount = s.Outer.NetAmount, ReconciledTransfers = s.Outer.ReconciledTransfers, EditedDate = s.Outer.EditedDate, YogabandyFee = s.Inner }) .ExecuteUpdate(setters => setters.SetProperty ( propertyExpression: p => p.GrossAmount, valueExpression: __grossAmount_1).SetProperty( propertyExpression: p => p.TotalTokens, valueExpression: __totalTokens_2).SetProperty( propertyExpression: p => p.ReconciledTransfers, valueExpression: True).SetProperty( propertyExpression : p => p.EditedDate, valueExpression: DateTime.UtcNow).SetProperty( propertyExpression: p => p.YogabandyFee, valueExpression: p => new YogabandyFee{ TotalFee = __grossAmount_1 - p.NetAmount - __platformFee_3 } ))' não pôde ser traduzido. Informações adicionais: O seguinte argumento lambda para 'SetProperty' não representa uma propriedade válida a ser definida: 'p => p.YogabandyFee'. Consulte https://go.microsoft.com/fwlink/?linkid=2101038 para obter mais informações. em Microsoft.EntityFrameworkCore.Query.RelationalQueryableMethodTranslatingExpressionVisitor.VisitMethodCall(MethodCallExpression methodCallExpression) em Microsoft.EntityFrameworkCore.Query.QueryableMethodTranslatingExpressionVisitor.Translate(expressão de expressão) em Microsoft.EntityFrameworkCore.Query.RelationalQueryableMethodTranslatingExpressionVisitor.Trans tarde (expressão de expressão) em Microsoft.EntityFrameworkCore.Query.QueryCompilationContext .CreateQueryExecutor[TResult](consulta de expressão) em Microsoft.EntityFrameworkCore.Storage.Database.CompileQuery[TResult](consulta de expressão, booleano assíncrono) em Microsoft.EntityFrameworkCore.Query.Internal.QueryCompiler.CompileQueryCore[TResult](banco de dados IDatabase, consulta de expressão , modelo IModel, booleano assíncrono) em Microsoft.EntityFrameworkCore.Query.Internal.QueryCompiler.<>c__DisplayClass12_0 1.b__0() at Microsoft.EntityFrameworkCore.Query.Internal.CompiledQueryCache.GetOrAddQuery[TResult](Object cacheKey, Func1 compilador) em Microsoft.EntityFrameworkCore.Query.Internal.QueryCompiler.ExecuteAsync[TResult](Expression query, CancellationToken cancelToken) em Microsoft.EntityFrameworkCore .Query.Internal.EntityQueryProvider.ExecuteAsync[TResult](Expressão de expressão, CancellationToken cancelToken) em Microsoft.EntityFrameworkCore.RelationalQueryableExtensions.ExecuteUpdateAsync[TSource](IQueryable 1 source, Expression1 setPropertyCalls, CancellationToken cancellationToken) em Functions.ReconcileTransfers.Run(String myQueueItem) em /Users /charles/yogabandy2020/Functions/ReconcileTransfers.cs:linha 119

c#

2 respostas

  1. Best Answer

    ExecuteUpdateAsync tentará criar uma consulta SQL com base no código c# que você escreve. No código c#, você está tentando atualizar duas tabelas ao mesmo tempo na mesma consulta. Não é possível. Mesmo escrevendo seu próprio SQL, a maioria dos DMBS não permite isso. (com exceção do MySQL)

    Da sua mensagem de erro

    O seguinte argumento lambda para 'SetProperty' não representa uma propriedade válida a ser definida: 'p => p.YogabandyFee'

    parece que o analisador está procurando uma propriedade em vez de um objeto, então, tentei definir o TotalFeede YogabandyFee:

    var payoutResult = await _dbContext.StripePayouts
            .Where(p => p.StripePayoutId == stripePayoutId)
            .Select(p => new { p.GrossAmount, p.TotalTokens, p.NetAmount, p.ReconciledTransfers, p.EditedDate, p.YogabandyFee })
            .ExecuteUpdateAsync(setters => setters
                .SetProperty(p => p.GrossAmount, grossAmount)
                .SetProperty(p => p.TotalTokens, totalTokens)
                .SetProperty(p => p.YogabandyFee.TotalFee, p => grossAmount - p.NetAmount - platformFee )
                .SetProperty(p => p.ReconciledTransfers, true)
                .SetProperty(p => p.EditedDate, DateTime.UtcNow)
            );

    E você verá este erro:

    Várias invocações de 'SetProperty' referem-se a tabelas diferentes ('p => p.YogabandyFee.TotalFee' e 'p => p.EditedDate'). Uma única chamada 'ExecuteUpdate' só pode atualizar as colunas de uma única tabela.

    O que estou tentando dizer é: ExecuteUpdatesó é possível atualizar uma tabela. Acho que a resposta para "Posso criar uma nova entrada neste tipo de atualização?" é não.

    Minhas sugestões:

    1. Use procedimentos armazenados para atualizar ambas as tabelas de uma só vez ( https://stackoverflow.com/a/5154670/17431983 ); ferramentas como o Dapper permitem executar um procedimento armazenado.
    2. Usar UnitOfWork- permite fazer múltiplas _dbContextconsultas na mesma transação

    Você também pode fazer duas atualizações separadas ExecuteUpdateAsync, uma para cada atualização de tabela, se não for um problema de desempenho.

    • 2

  2. A exceção System.InvalidOperationException é lançada porque o método ExecuteUpdateAsync no EF não suporta a criação ou atribuição de novas entidades diretamente na operação de atualização. Portanto, o que você pode fazer é primeiro atualizar a entidade principal e depois atualizar o ‘YogabandyFee’.

    • 0

relate perguntas