4

问题：我们广泛使用存储库模式来促进跨多个应用程序和功能子部分的数据存储（使用 LINQ 的 MS SQL）上的读/写操作。我们有一系列方法，它们都做类似的事情。

例如，我们有 ProcessAndSortXXXXXX 类的方法。

private static IEnumerable<ClassErrorEntry> ProcessAndSortClassErrorLog(IQueryable<ClassErrorDb> queryable, string sortOrder)
{
    var dynamic = queryable;
    if (!String.IsNullOrEmpty(sortOrder.Trim()))
    {
        dynamic = dynamic.OrderBy(sortOrder);
    }
    return dynamic
        .Select(l =>
            new ClassErrorEntry(l.Id)
            {
                ClassId = l.ClassId,
                Code = l.Code,
                Message = l.Message,
                Severity = l.Severity,
                Target = l.Target
            }
        );
}

...和...

private static IEnumerable<ClassTimerLogEntry> ProcessAndSortClassTimerLog(IQueryable<ClassTimerDb> queryable, string sortOrder)
{
    var dynamic = queryable;
    if (!String.IsNullOrEmpty(sortOrder.Trim()))
    {
        dynamic = dynamic.OrderBy(sortOrder);
    }
    return dynamic
        .Select(l =>
            new ClassTimerLogEntry(l.Id)
            {
                ClassName = l.ClassName,
                MethodName = l.MethodName,
                StartTime = l.StartTime,
                EndTime = l.EndTime,
                ParentId = l.ParentId,
                ExecutionOrder = l.ExecutionOrder
            }
        );
}

从代码中可以看出，它们都非常相似，直到您查看签名然后进入我们正在构建 ClassErrorEntry 和 ClassTimerLogEntry 实例的 return 语句。

我想构建一个实用方法，我将添加到所有存储库继承的基类中。

我希望能够传入可用于实例化对象的参数并将它们打包到返回的 IEnumerable 中。

我发现了ScottGu的这篇文章，这让我得到了我需要的大部分内容。它看起来像这样（来自文档中的示例）：

var query =
    db.Customers.
    Where("City = @0 and Orders.Count >= @1", "London", 10).
    OrderBy("CompanyName").
    Select("new(CompanyName as Name, Phone)");

不过，这就是我卡住的地方。我需要一个指针或建议，如何以通用方式传入 LINQ 表和 DataContext，以便构建动态查询。

如果我用伪代码模拟签名，我认为它看起来像这样：

protected internal IEnumerable ProcessAndSort(IQueryable source, string selectClause, string whereClause, string orderByClause);

我意识到，当我们弄清楚这一点时，完成的签名可能看起来有所不同。

谢谢！

更新！

我现在有可以生成匿名类型但在转换为具体类型时失败的代码。

public static IEnumerable<TResult> ProcessAndSort<T, TResult>(IQueryable<T> queryable, 
    string selector, Expression<Func<T, bool>> predicate, string sortOrder)
{
    var dynamic = queryable.Where(predicate).AsQueryable();
    if (!String.IsNullOrEmpty(sortOrder.Trim()))
    {
        dynamic = dynamic.OrderBy(sortOrder);
    }
    var result= dynamic.Select(selector).Cast<TResult>();

    return result;
}

下面是调用这个方法的代码：

[TestMethod]
public void TestAnonymousClass()
{
    var loggingContext = new LoggingDbDataContext(DatabaseConnectionString);
    var repo = new LoggingRepository(loggingContext);

    var result = repo.TestGetClassErrorLog(4407, 10, 0, 
        "new ( ClassId as ClassId, " +
        "Code as Code, " +
        "Message as Message, " +
        "Severity as Severity, " +
        "Target as Target )", "Target");
    TestContext.WriteLine(result.ToList().Count.ToString());
}

最后一行TestContext.WriteLine(result.ToList().Count.ToString());抛出异常System.InvalidOperationException: No coercion operator is defined between types 'DynamicClass1' and 'Utilities.Logging.ClassErrorEntry'.

这段代码虽然失败了：

[TestMethod]
public void TestNamedClass()
{
    var loggingContext = new LoggingDbDataContext(DatabaseConnectionString);
    var repo = new LoggingRepository(loggingContext);

    var result = repo.TestGetClassErrorLog(4407, 10, 0,
        "new ClassErrorEntry(Id) { ClassId = ClassId, " +
        "Code = Code, " +
        "Message = Message, " +
        "Severity = Severity, " +
        "Target = Target }", "Target");
    TestContext.WriteLine(result.ToList().Count.ToString());
}

这会因解析错误而失败。Test method eModal.Repositories.Test.RepositoryBaseTest.TestConcreteClass threw exception: System.Linq.Dynamic.ParseException: '(' expected, found 'ClassErrorEntry' ('Identifier') at char 19 in 'new ClassErrorEntry(Id) { ChassisAuthId = ChassisAuthId, Code = Code, Message = Message, Severity = Severity, Target = Target }'

我不确定字符位置是否可疑，因为第 19 个字符位置是 a(并且传递给 Validate 方法的类型指示位置为 4 或第一个'C'.

4

2 回答 2

1

我完全建议您不要仅仅为了代码重用而进行弱类型查询。
代码重用是为了提高可维护性，但如果以错误的方式使用，弱类型会杀死它。通过用纯文本编写查询，您实际上使类很难重构和更改，并引入了许多模糊的依赖项。

我建议您看一下允许 combine s 的LinqKit 。Expression例如，我们编写了一个Paging按页面拆分查询并在项目中以不同类型使用它的方法：

var query = CompiledQuery.Compile(
    BuildFolderExpr( folder, false )
        .Select( msg => selector.Invoke( msg, userId ) ) // re-use selector expression
        .OrderBy( mv => mv.DateCreated, SortDirection.Descending )
        .Paging() // re-use paging expression
        .Expand() // LinqKit method that "injects" referenced expressions
    )

public static Expression<Func<T1, T2, PagingParam, IQueryable<TItem>>> Paging<T1, T2, TItem>(
    this Expression<Func<T1, T2, IQueryable<TItem>>> expr )
{
    return ( T1 v1, T2 v2, PagingParam p ) => expr.Invoke( v1, v2 ).Skip( p.From ).Take( p.Count );
}

在我的示例中，BuildMessageExpr返回一个相对简单的选择表达式（它已经依赖于folder另一个参数），并且不同的方法通过应用过滤、排序、获取计数、进一步选择并将选择器表达式作为参数传递等等来重用这个表达式。创建查询后，当参数相似时，它会被缓存以备将来使用。

于 2011-06-10T22:29:07.217 回答
0

这不是您问题的直接答案。

正如您所说，您有很多看起来相似但返回不同类型的代码。如果你继续寻找这种方法的通用实现，结果可能会有一些技巧，你可能仍然会传递一些不舒服的 SQL 或检查对象的类型或做一些反射功夫。您可能仍然选择此通行证，实际上有人可以有一个看起来不像肮脏的黑客的明智想法。

另一种选择是使用具有通用存储库模式和依赖注入（谷歌链接）的适当 ORM。您的数据访问层将看起来更简单且更易于维护。

于 2011-06-04T16:00:32.417 回答