在实体框架中执行存储过程，返回 List<DataTable> 或 DataSet答案

【问题标题】：Execute stored procedure in Entity Framework, return List<DataTable> or DataSet在实体框架中执行存储过程，返回 List<DataTable> 或 DataSet
【发布时间】：2012-05-02 12:19:55
【问题描述】：

如何修改以下方法以返回 List 或 DataSet？我想让它通用，以便它可以从数据库返回多个结果集。

public static DataTable ExecuteStoredProcedure(ObjectContext db, string storedProcedureName, IEnumerable<SqlParameter> parameters)
    {
        var entityConnection = (EntityConnection) db.Connection;
        var conn = entityConnection.StoreConnection;
        var initialState = conn.State;
        var dt = new DataTable();

        try
        {
            if (initialState != ConnectionState.Open)
                conn.Open();
            using (var cmd = conn.CreateCommand())
            {
                cmd.CommandText = storedProcedureName;
                cmd.CommandType = CommandType.StoredProcedure;
                foreach (var parameter in parameters)
                {
                    cmd.Parameters.Add(parameter);
                }

                using (var reader = cmd.ExecuteReader())
                {
                    dt.Load(reader);
                    reader.Close();
                }
            }
        }
        catch (Exception ex)
        {
            throw ex;
        }
        finally
        {
            if (initialState != ConnectionState.Open)
                conn.Close();
        }
        return dt;
    }

【问题讨论】：

我已经在谷歌上搜索了一段时间，我很震惊 EF 不支持这么简单的需求。感谢您的代码。不幸的是，“context.Execute*()”方法并没有真正达到相同的目的，也不会替换您在答案中的代码。如果有人好奇，这里有一篇文章：geekswithblogs.net/rgupta/archive/2010/06/23/… 在这里找到它stackoverflow.com/questions/915329/…

标签： entity-framework datatable dataset sqldatareader

【解决方案1】：

reader.NextResult() 在技术上应该可以工作。这是修改后的版本：

public static DataSet ExecuteStoredProcedure(ObjectContext db, string storedProcedureName, IEnumerable<SqlParameter> parameters)
{
    var entityConnection = (EntityConnection) db.Connection;
        var conn = entityConnection.StoreConnection;
        var initialState = conn.State;

        DataSet dataSet = new DataSet();

        try
        {
            if (initialState != ConnectionState.Open)
                conn.Open();
            using (var cmd = conn.CreateCommand())
            {
                cmd.CommandText = storedProcedureName;
                cmd.CommandType = CommandType.StoredProcedure;
                foreach (var parameter in parameters)
                {
                    cmd.Parameters.Add(parameter);
                }

                using (var reader = cmd.ExecuteReader())
                {
                    do
                    {
                        DataTable dt = new DataTable();
                        dt.Load(reader);
                        dataSet.Tables.Add(dt);
                    }
                    while (reader.NextResult());
                }
            }
        }
        catch (Exception ex)
        {
            throw ex;
        }
        finally
        {
            if (initialState != ConnectionState.Open)
                conn.Close();
        }
        return dataSet;
}

【讨论】：

@davidair：我收到此错误“阅读器关闭时调用 NextResult 的尝试无效。”我的存储过程返回三个结果集。
@davidair：代码返回第一个和第三个结果集。在第一次迭代中，我得到了第一个结果集，在第二次迭代中，我得到了第三个结果集。在第二次迭代后它在while 爆炸。
我刚刚发现，加载数据表后，NextResult 会在后台自动执行！而在while 代码中，由于我们再次指定NextResult，它又跳过了一个结果集。更多信息 - amitchandnz.wordpress.com/2011/09/28/…
来自 MSDN -“Load 方法使用来自加载的 IDataReader 的第一个结果集，并在成功完成后将读取器的位置设置为下一个结果集（如果有）。”我该如何解决这个问题？谢谢！
@enigma，只有在没有下一个结果集的情况下才会关闭阅读器。所以你可以用while (!reader.IsClosed)替换while (reader.NextResult())

【解决方案2】：

我最终这样做了 -

public static DataSet ExecuteStoredProcedure(ObjectContext db, string storedProcedureName, IEnumerable<SqlParameter> parameters)
    {
        var connectionString = ((EntityConnection)db.Connection).StoreConnection.ConnectionString;
        var ds = new DataSet();

        using (var conn = new SqlConnection(connectionString))
        {
            using (var cmd = conn.CreateCommand())
            {
                cmd.CommandText = storedProcedureName;
                cmd.CommandType = CommandType.StoredProcedure;
                foreach (var parameter in parameters)
                {
                    cmd.Parameters.Add(parameter);
                }

                using (var adapter = new SqlDataAdapter(cmd))
                {
                    adapter.Fill(ds);
                }
            }
        }

        return ds;
    }

【讨论】：