使用Entity Framework ExecuteStoreQuery返回DataTable

det*_*pro 14 stored-procedures entity-framework code-first ef-code-first

我正在使用一个系统,该系统有许多需要显示的存储过程.为每个对象创建实体是不实际的.

是否有可能,我将如何退回DataTable使用ExecuteStoreQuery

public ObjectResult<DataTable> MethodName(string fileSetName) {
using (var dataContext = new DataContext(_connectionString))
{
var returnDataTable = ((IObjectContextAdapter)dataContext).ObjectContext.ExecuteStoreQuery<DataTable>("SP_NAME","SP_PARAM");
return returnDataTable;
}
Run Code Online (Sandbox Code Playgroud)

小智 16

是的,它可能,但它应该只用于动态结果集或原始SQL.

public DataTable ExecuteStoreQuery(string commandText, params Object[] parameters)
{
    DataTable retVal = new DataTable();
    retVal = context.ExecuteStoreQuery<DataTable>(commandText, parameters).FirstOrDefault();
    return retVal;
}
Run Code Online (Sandbox Code Playgroud)

编辑:最好使用经典的ADO.NET来获取数据模型而不是使用实体框架,因为DataTable即使您可以运行该方法,也很可能无法使用它:context.ExecuteStoreQuery<DataTable>(commandText, parameters).FirstOrDefault();

ADO.NET示例:

public DataSet GetResultReport(int questionId)
{
    DataSet retVal = new DataSet();
    EntityConnection entityConn = (EntityConnection)context.Connection;
    SqlConnection sqlConn = (SqlConnection)entityConn.StoreConnection;
    SqlCommand cmdReport = new SqlCommand([YourSpName], sqlConn);
    SqlDataAdapter daReport = new SqlDataAdapter(cmdReport);
    using (cmdReport)
    {
        SqlParameter questionIdPrm = new SqlParameter("QuestionId", questionId);
        cmdReport.CommandType = CommandType.StoredProcedure;
        cmdReport.Parameters.Add(questionIdPrm);
        daReport.Fill(retVal);
    }
    return retVal;
}
Run Code Online (Sandbox Code Playgroud)

  • 对于`DbContext`,它是`context.Database.Connection`. (2认同)

mar*_*c_s 10

不,我认为这不会起作用 - 实体框架面向返回实体,并不意味着返回DataTable对象.

如果您需要DataTable对象,请改用直接ADO.NET.


jim*_*415 7

此方法使用实体框架中的连接字符串来建立ADO.NET连接,在此示例中为MySQL数据库.

using MySql.Data.MySqlClient;

public DataSet GetReportSummary( int RecordID )
{
    var context = new catalogEntities();

    DataSet ds = new DataSet();
    using ( MySqlConnection connection = new MySqlConnection( context.Database.Connection.ConnectionString ) )
    {
        using ( MySqlCommand cmd = new MySqlCommand( "ReportSummary", connection ) )
        {
            MySqlDataAdapter adapter = new MySqlDataAdapter( cmd );
            adapter.SelectCommand.CommandType = CommandType.StoredProcedure;
            adapter.SelectCommand.Parameters.Add( new MySqlParameter( "@ID", RecordID ) );
            adapter.Fill( ds );
        }
    }
    return ds;
}
Run Code Online (Sandbox Code Playgroud)


Cod*_*shi 6

是的,可以像这样轻松完成:

var table = new DataTable();
using (var ctx = new SomeContext())
{
    var cmd = ctx.Database.Connection.CreateCommand();
    cmd.CommandText = "Select Col1, Col2 from SomeTable"; 

    cmd.Connection.Open();
    table.Load(cmd.ExecuteReader());
}
Run Code Online (Sandbox Code Playgroud)

  • @jakotheshadows `cmd` 是一个 `SqlCommand` 对象,因此您可以像常规那样执行它,例如 `cmd.Parameters.AddWithValue("@param", another);` (2认同)

Dan*_*lho 5

根据规则,您不应在 EF 应用程序中使用 DataSet。但是,如果您确实需要(例如,提供报告),该解决方案应该可以工作(它是 EF 6 代码):

    DataSet GetDataSet(string sql, CommandType commandType, Dictionary<string, Object> parameters)
    {
        // creates resulting dataset
        var result = new DataSet();

        // creates a data access context (DbContext descendant)
        using (var context = new MyDbContext())
        {
            // creates a Command 
            var cmd = context.Database.Connection.CreateCommand();
            cmd.CommandType = commandType;
            cmd.CommandText = sql;

            // adds all parameters
            foreach (var pr in parameters)
            {
                var p = cmd.CreateParameter();
                p.ParameterName = pr.Key;
                p.Value = pr.Value;
                cmd.Parameters.Add(p);
            }

            try
            {
                // executes
                context.Database.Connection.Open();
                var reader = cmd.ExecuteReader();

                // loop through all resultsets (considering that it's possible to have more than one)
                do
                {
                    // loads the DataTable (schema will be fetch automatically)
                    var tb = new DataTable();
                    tb.Load(reader);
                    result.Tables.Add(tb);

                } while (!reader.IsClosed);
            }
            finally
            {
                // closes the connection
                context.Database.Connection.Close();
            }
        }

        // returns the DataSet
        return result;
    }
Run Code Online (Sandbox Code Playgroud)