3

Entity Frameworkバージョン4を使用しています。大きな（〜100万レコード）SQL Serverテーブルを、Webサービスから返される長い（〜2000）複雑なオブジェクトの配列と比較する必要があります。複雑なオブジェクトのインスタンスがすでにデータベースにあるかどうかを判断するには、5つの異なるプロパティを比較する必要があります。

.Whereメソッドと.Anyメソッドで使用する式を返す関数を作成しました。次のようになります（Aは複雑なオブジェクト、tblAはEFクラス）。

function Expression<tblA, bool> GetSearchPredicate(A a)
{
    return ta => ta.Field1.Equals(a.Field1) 
        && ta.Field2.Equals(a.Field2)
        && ta.Field3.Equals(a.Field3)
        && ta.Field4.Equals(a.Field4)
        && ta.Field5.Equals(a.Field5);
}

これは機能します。そして、これを行うことで、Aの2000個のインスタンスすべてを比較できます。

IEnumerable<A> objects = [web service call]; 
var result = objects.Select(a => !db.tblA.Any(GetSearchPredicate(a)));

それもうまくいきます。しかし、それは遅いです。そこで、EFを介してデータベースに直接送信できる式を作成できるユーティリティメソッドの作成を検討しました。

この質問のコードを、そのユーティリティメソッドを構築するための基礎として使用しました。その質問の例は、単一のプロパティを一連の定数と比較することを示していますが、私のバージョンでは、複数のプロパティを複数の定数と比較する必要があります。私の最善の努力は以下の通りです：

    public static IQueryable<TEntity> WhereIn<TEntity>
       (
        this ObjectQuery<TEntity> query,
        IEnumerable<Expression<Func<TEntity, bool>>> predicates
       )
    {
        if (predicates == null) throw new ArgumentNullException("predicates");

        IEnumerable<ParameterExpression> p = predicates.Select(pred => pred.Parameters.Single()).ToArray();

        IEnumerable<Expression> equals = predicates.Select(value =>
            (Expression)value.Body);

        Expression bigEqual = equals.Aggregate((accumulate, equal) =>
            Expression.Or(accumulate, equal));

        var result1 = Expression.Lambda<Func<TEntity, bool>>(bigEqual, p.First());
        var result = query.Where(result1);
        return result;
    }

これは次のように呼び出されます。

IEnumerable<A> objects = [web service call]; 
var result = db.tblA.WhereIn(objects.Select(a => GetSearchPredicate(a)));

「ta」（TEntityオブジェクトのプレースホルダー）がバインドされていないというメッセージが表示されます。これは、複数の式（変数）が組み合わされているためだと思いました。おそらく、 IEnumerablepredicatesの最初のパラメーターのみを渡したために、このメッセージがスローされていました。predicatesただし、これpredicatesは1つの式の長さであっても発生します。

A.Field1リンクしたメソッドに基づいて、5つのプロパティのそれぞれを定数（からの値）と比較する式を作成できると確信しています。既に一連のプロパティにアセンブルされているA.Field5パラメーターを渡すのではありません。predicates式。しかし、私はむしろそうしません。なぜなら、それはタイプAとtblAで動作していることを知るための私のメソッドを必要とし、それは汎用と汎用の反対です。（これも複雑で面倒です。）

私が示した例が私がやりたいことを説明することを願っています。それは一般的な方法で行うことができますか？

4

1 に答える 1

3

述語本体のパラメーターを単一のパラメーターに置き換える必要があります。このようなものが動作するはずです:

public static Expression<Func<T, bool>> BuildOr<T>(
   IEnumerable<Expression<Func<T, bool>>> predicates)
{
    Expression body = null;
    ParameterExpression p = null;
    Expression<Func<T, bool>> first = null;

    foreach (Expression<Func<T, bool>> item in predicates)
    {
        if (first == null)
        {
            first = item;
        }
        else
        {
            if (body == null)
            {
                body = first.Body;
                p = first.Parameters[0];
            }

            var toReplace = item.Parameters[0];
            var itemBody = ReplacementVisitor.Transform(item, toReplace, p);
            body = Expression.OrElse(body, itemBody);
        }
    }

    if (first == null) 
    {
       throw new ArgumentException("Sequence contains no elements.", "predicates");
    }

    return (body == null) ? first : Expression.Lambda<Func<T, bool>>(body, p);
}

private sealed class ReplacementVisitor : ExpressionVisitor
{
    private IList<ParameterExpression> SourceParameters { get; set; }
    private Expression ToFind { get; set; }
    private Expression ReplaceWith { get; set; }

    public static Expression Transform(
       LambdaExpression source, 
       Expression toFind, 
       Expression replaceWith)
    {
        var visitor = new ReplacementVisitor
        {
            SourceParameters = source.Parameters,
            ToFind = toFind,
            ReplaceWith = replaceWith,
        };

        return visitor.Visit(source.Body);
    }

    private Expression ReplaceNode(Expression node)
    {
        return (node == ToFind) ? ReplaceWith : node;
    }

    protected override Expression VisitConstant(ConstantExpression node)
    {
        return ReplaceNode(node);
    }

    protected override Expression VisitBinary(BinaryExpression node)
    {
        var result = ReplaceNode(node);
        if (result == node) result = base.VisitBinary(node);
        return result;
    }

    protected override Expression VisitParameter(ParameterExpression node)
    {
        if (SourceParameters.Contains(node)) return ReplaceNode(node);
        return SourceParameters.FirstOrDefault(p => p.Name == node.Name) ?? node;
    }
}

メソッドは次のWhereInようになります。

public static IQueryable<TEntity> WhereIn<TEntity>(
   this ObjectQuery<TEntity> query, 
   IEnumerable<Expression<Func<TEntity, bool>>> predicates)
{
    if (predicates == null) throw new ArgumentNullException("predicates");

    var predicate = BuildOr(predicates);
    return query.Where(predicate);
}
于 2012-12-19T14:56:13.863 に答える