使用 Linq to Entities 的存储过程中的动态表

Question

我有关于实体框架和 Linq to Entities 的问题。我的.NET版本是4.0。我正在重构现有应用程序的数据库访问层，并且计划使用 Linq to Entities（而不是今天的 DataReaders 和 SQL 字符串）。数据库的结构无法更改。

我的问题来自一个存储过程，该过程经过简化，如下所示：

CREATE PROCEDURE getElement @tableid as int, @elementid as int AS
BEGIN
DECLARE @tablename as varchar(50)
SELECT @tablename = tablename FROM tables WHERE tableid = @tableid
EXEC('SELECT * FROM ' + @tablename + ' WHERE elementid = ' + @elementid)
END

我知道返回的行将有一个名为 elementid 的列，并且根据此值，我知道其他什么值得期待的专栏。

如今，这个问题已通过 SqlDataReader 解决，它对 elemendid 元素进行类似字典的查找。

public Element getElement(SqlDataReader dr)
{
    switch((int)dr["elementid"])
    {
        case 1:
            return getTextElement(dr);
        case 2:
            return getImageElement(dr);
        //...
    }
}

Element 是一个抽象基类。 getTextElement 返回一个 TextElement : Element，getImageElement 返回一个 ImageElement : Element。

如何在实体框架中对此进行建模？复杂类型似乎并不能解决这个问题，因为它似乎不支持动态属性。我还研究过 EntityObject Generator，但我在定制 T4 代码方面并不是很有经验（也许我应该学习这个问题？）。对我来说，完美的解决方案是让导入的存储过程返回一个 dynamic 类型的对象，但 Entity Framework 4 似乎不支持这一点。

Answer 1

我认为您遇到的问题是 EF 和 Linq to Sql 设计者根据已知的表结构生成模型。您的 sproc 使用 EXEC 计算结果，因此无法分析该过程以找出结果模型的样子。我不确定可以使用 ORM 工具解决这个问题，您可能需要专门化两个存储过程，一个用于显式返回 TextElement 模型，另一个用于 ImageElement 模型。

Answer 2

我只是想补充一下我是如何解决这个问题的。

我创建了几个模拟 Linq to Entities 行为的帮助程序类，并将它们用于我的特殊存储过程。它远非完美，甚至还不够好，但它使生成的代码看起来与 Linq to Entities 非常相似。这对我来说很重要，因为我的数据库层的其余部分将使用 Linq to Entities。

在完美的世界中，我将能够制定对 Linq to Entities 的查询，然后使用与我现在所做的有点相似的结果。

开始吧...

代码的使用方式如下：

var connectionString = new SqlConnectionStringBuilder
{
    DataSource = @"C:\Temp\Northwind.mdf"
};

var commandText = "select * from Customers";

using (var rows = new SqlCommandHelper(connectionString.ToString(), System.Data.CommandType.Text, commandText))
{
    foreach (dynamic row in rows)
    {
        try
        {
            Console.WriteLine(row.Fax ?? "Emtpy");
        }
        catch (IndexOutOfRangeException)
        {
            Console.WriteLine("Invalid column name");
        }
    }
}

如您所见，行的枚举看起来与我使用 Linq to Entities 而不是 SqlCommandHelper 时的情况类似。

SqlCommandHelper 类的代码如下：

class SqlCommandHelper : IEnumerable<DynamicSqlRow>, IDisposable
{
    private SqlConnection connection;
    private SqlCommand command;

    public SqlCommandHelper(string connectionString, System.Data.CommandType commandType, string commandText, params SqlParameter[] parameters)
    {
        connection = new SqlConnection(connectionString);
        command = new SqlCommand
        {
            CommandText = commandText,
            CommandType = commandType,
            Connection = connection
        };

        command.Parameters.AddRange(parameters);
    }

    public IEnumerator<DynamicSqlRow> GetEnumerator()
    {
        if (connection.State != System.Data.ConnectionState.Open)
        {
            connection.Open();
        }

        using (var reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                yield return new DynamicSqlRow(reader);
            }
        }            
    }

    System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator()
    {
        return GetEnumerator();
    }

    public void Dispose()
    {
        command.Dispose();
        connection.Dispose();
    }
}

如您所见，神奇之处在于DynamicSqlRow。需要注意的是，您需要导入 System.Dynamic 命名空间，以便 DynamicSqlRow 进行编译。

class DynamicSqlRow : DynamicObject
{
    System.Data.IDataReader reader;

    public DynamicSqlRow(System.Data.IDataReader reader)
    {
        this.reader = reader;
    }

    public override bool TryGetMember(GetMemberBinder binder, out object result)
    {
        var row = reader[binder.Name];

        result = row is DBNull ? null : row;

        return true;
    }
}

我希望这段代码对其他人有用，或者它能让某人想到更好的解决方案。

对我来说有用的链接是 演练：创建和使用动态对象（来自 MSDN）。

小心