如何从存储过程中读取值？

Question

我正在尝试从我的 .NET Core Web API 上的存储过程中读取值。

这是得到的响应：

System.InvalidOperationException: Invalid attempt to call FieldCount when reader is closed.
   at Microsoft.Data.SqlClient.SqlDataReader.get_FieldCount()
   at System.Data.Common.DbEnumerator.BuildSchemaInfo()
   at System.Data.Common.DbEnumerator.MoveNext()
   at System.Text.Json.JsonSerializer.HandleEnumerable(JsonClassInfo elementClassInfo, JsonSerializerOptions options, Utf8JsonWriter writer, WriteStack& state)
   at System.Text.Json.JsonSerializer.Write(Utf8JsonWriter writer, Int32 originalWriterDepth, Int32 flushThreshold, JsonSerializerOptions options, WriteStack& state)
   at System.Text.Json.JsonSerializer.WriteAsyncCore(Stream utf8Json, Object value, Type inputType, JsonSerializerOptions options, CancellationToken cancellationToken)
   at Microsoft.AspNetCore.Mvc.Formatters.SystemTextJsonOutputFormatter.WriteResponseBodyAsync(OutputFormatterWriteContext context, Encoding selectedEncoding)
   at Microsoft.AspNetCore.Mvc.Formatters.SystemTextJsonOutputFormatter.WriteResponseBodyAsync(OutputFormatterWriteContext context, Encoding selectedEncoding)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeNextResultFilterAsync>g__Awaited|29_0[TFilter,TFilterAsync](ResourceInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)

这是我的代码：

try
{
    using (SqlConnection con = new SqlConnection(myConnString))
    {
        using (SqlCommand cmd = new SqlCommand("GetUsers", con)) // Simple proc which returning all 'child' users
        {
            cmd.CommandType = CommandType.StoredProcedure;

            cmd.Parameters.Add("@parentUserId", SqlDbType.UniqueIdentifier).Value = parentUserId;

            // open connection to database
            con.Open();

            //set the SqlCommand type to stored procedure and execute
            cmd.CommandType = CommandType.StoredProcedure;

            SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);

           message.Data = reader;
        }
    }
    return message;
}
catch (Exception ex)
{
    message.IsValid = false;
}

当我对此进行调试时，我意识到数据存在于结果中，但它嵌套在另一个对象中，就像它在此处的图像上显示的那样：

Answer 1

当代码从包含连接的 using 块中退出时，连接及其关联的读取器都将关闭。
这意味着 DataReader 通常不太适合在方法之间传递。存在一些解决方法，see here for example，但我发现完全放弃 SqlDataReader 和 SqlCommand 并用像 Dapper 这样的简单 ORM 替换它们更有用

现在，假设您有一个 User 类，其中包含一些与数据表字段名称完全匹配的属性。

public class User
{
     public Guid ID {get;set;}
     public string Name {get;set;}
     public string EMail {get;set;}
     public Guid ParentID {get;set;}
     ... etc ...
}

此时您的代码，使用 Dapper 将是

using (SqlConnection con = new SqlConnection(myConnString))
{
    con.Open();
    List<User> users = con.Query<User>("GetUsers",  
                       new {parentUserId=parentUserId}, 
                       commandType: CommandType.StoredProcedure).ToList();
    message.Data = users;
    return message;
}

当然消息类中的Data字段应该是User类型，或者如果你使用多种不同的类型，你甚至可以将列表序列化为Json字符串并返回

Answer 2

尝试在两个 using 语句中移动 return message;。

try
{
    using (SqlConnection con = new SqlConnection(myConnString))
    {
        using (SqlCommand cmd = new SqlCommand("GetUsers", con)) // Simple proc which returning all 'child' users
        {
            cmd.CommandType = CommandType.StoredProcedure;

            cmd.Parameters.Add("@parentUserId", SqlDbType.UniqueIdentifier).Value = parentUserId;

            // open connection to database
            con.Open();

            //set the SqlCommand type to stored procedure and execute
            cmd.CommandType = CommandType.StoredProcedure;

            SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);

           while (reader.Read())
            {
                // add each line to message.Data
            }

           return message;
        }
    }
}
catch (Exception ex)
{
    message.IsValid = false;
}

一旦您离开using，您的reader 就会丢失。

你如何处理这个// add each line to message.Data 将取决于message.Data 的样子，我们无法判断。

还有一些其他的事情：

cmd.CommandType = CommandType.StoredProcedure; -- 你有这个两次。没有伤害任何东西，但也没有帮助。

您真的应该寻找一种更优雅的方式来进行数据访问。直接的 ADO.NET 笨重且难以使用。探索 Entity Framework 和 Dapper 等选项。

Answer 3

我认为使用 Dapper 之类的东西会更开心，但是，如果你想遵循直接的 SqlConnection/DataReader 路径，请考虑使用类似这个简单的包装类的东西：

public class WrappedReader : IDisposable
{
    public SqlDataReader Reader { get; }
    public SqlConnection Connection { get; }
    public WrappedReader(SqlConnection connection, SqlDataReader reader)
    {
        Reader = reader;
        Connection = connection;
    }

    public void Dispose()
    {
        Reader?.Dispose();
        Connection?.Dispose();
    }

您构造一个 WrappedReader 并返回它，而不是返回 DataReader，类似于：

public static WrappedReader TestWrappedReader()
{
    var connection = new SqlConnection(connectionString);
    using (var command = new SqlCommand("Select * from SomeTable", connection))
    {
        var reader = command.ExecuteReader();
        return new WrappedReader(connection, reader);
    }
}

那么你可以这样称呼它：

 using (var wrappedReader = TestWrappedReader())
 {
     var reader = wrappedReader.Reader;
     if (reader.HasRows)
     {
         while (reader.Read())
         {
             DoSomethingWith(reader);
         }
     }
 }