方法返回 -1 而不是更新的行数

Question

我正在尝试通过执行存储过程在我的数据库中进行批量更新。我正在调用 DbContext.Database.ExecuteSqlCommand 方法，如下所示：

_context.Database.ExecuteSqlCommand("EXECUTE TestProcedure");

在这个粗略的测试中，我的存储过程如下所示：

BEGIN
    UPDATE TestTable
    SET MyColumn = 'changed'
END

Select @@ROWCOUNT

当我直接在 SSMS 中执行 SProc 时，我得到了返回的行数。但是，如果我通过上面发布的代码执行此操作，我总是得到 -1 的结果（即使 SProc 正确执行 - 我可以在我的表中验证）。

当我把代码改成这样时：

_context.Database.ExecuteSqlCommand("UPDATE TestTable SET MyColumn = "changed");

然后我得到正确数量的更新行。由于我的实际代码更冗长，我想使用一个 SProc，但我需要准确的受影响行数。

如何使用 SProc？

Answer 1

Database.ExecuteSqlCommand 返回受影响的行数，而不是 SQL 中任何 SELECT... 语句的结果。

如果要返回结果集，则需要改用Database.SqlQuery。

编辑：由于这是 Entity Framework Core，SqlQuery 方法不存在（但计划中）。但是，您可以执行类似的操作来获取原始连接并使用反射返回数据。它不是特别有效，但应该可以工作：

public static class DbContextExtensionss
{
    public static IEnumerable<TEntity> ExecSQL<TEntity>(this DbContext context, string query) where TEntity : new()
    {
        using (var connection = context.Database.GetDbConnection())
        using (var command = connection.CreateCommand())
        {
            command.CommandText = query;
            command.CommandType = CommandType.Text;

            if(connection.State != ConnectionState.Open)
            {
                connection.Open();
            }

            using (var result = command.ExecuteReader())
            {
                while (result.Read())
                {
                    var entity = new TEntity();
                    foreach (PropertyInfo prop in typeof(TEntity).GetProperties())
                    {
                        if (!object.Equals(result[prop.Name], DBNull.Value))
                        {
                            prop.SetValue(entity, result[prop.Name], null);
                        }
                    }
                    yield return entity;
                }
            }
        }
    }
}   

你会这样使用它：

public class TestClass
{
    public int RowCount { get; set; }
}

var results = _context.ExecSQL<>("EXECUTE TestProcedure");

foreach(var testClass in results)
{
    Console.WriteLine(testClass.RowCount);
}

注意：您需要更改存储过程以命名它返回的列以匹配类：

SELECT @@ROWCOUNT AS [RowCount]