主页 / dba / 问题 / 119334
Accepted
RBarryYoung
Asked: 2015-10-28 08:00:56 +0800 CST

我怎样才能像 SSMS 一样获得单独的行数？

  • 772

我有一个客户端 c# 程序正在通过 执行存储过程，包括使用 InfoMessage 事件ExectueNonQuery捕获和错误输出。PRINT它工作正常，但我注意到一些奇怪的事情。

当我从 SSMS 执行存储过程时，它会显示在“消息”选项卡中执行的每个单独 SQL 语句的行数（就好像它来自 InfoMessages）。但是我的程序从来没有看到这些消息，尽管它确实捕获了所有相同的其他输出。相反，它只返回在 ExecuteNonQuery 函数结果中受影响的行，该结果是所有单个行计数的总和（这有点无用）。

例如，这个过程：

use [tempdb]
go

SELECT  * 
INTO    MyCols
FROM    sys.columns
go

CREATE PROC foo As

    UPDATE  MyCols
    SET     name = name + N''
-- SSMS shows (662 row(s) affected)

    UPDATE  MyCols
    SET     name = name + N''
    WHERE   name like '%x%'
-- SSMS shows (59 row(s) affected)

PRINT 'bar'
-- both SSMS and ExecuteNonQuery get this

-- ExecuteNonQuery returns 721 rows affected
GO

当fooproc 运行时，SSMS 显示 662 和 59 的行数，但ExecuteNonQuery只返回总数 721。

那么，我怎样才能获得与 SSMS 相同的信息呢？

在这里要明确一点：我对如何更改存储过程以PRINT @@ROWCOUNT在每个 SQL 语句后添加 s 不感兴趣。我知道该怎么做，但出于各种原因，大多数时候这不是一个选择。

我在问如何做 SSMS 在这里做的事情。我现在可以随心所欲地更改客户端代码（无论如何现在），我想做对。

sql-server sql-server-2008-r2

2 个回答

  1. Best Answer

    该SqlCommand.StatementCompleted事件将在批处理中的每个语句之后触发，事件的属性之一（好吧，几乎是唯一的属性）是受触发事件的语句影响的行数。

    一些注意事项：

    • 获取此信息的一个要求是您没有指定，SET NOCOUNT ON;或者相反，您确实指定了SET NOCOUNT OFF;。
    • 所有事件都在每个事件完成时触发Execute___()，而不是在执行期间触发。
    • StatementCompletedEventArgs.RecordCount包括来自语句的行数SELECT，而SqlDataReader.RecordsAffected属性仅报告来自 DML 语句（INSERT、UPDATE、DELETE等）的行数。
    • 该StatementCompleted事件不包括触发该事件的批处理中的单个 SQL 语句。但是，事件处理程序sender作为输入参数发送，这是SqlCommand查询批处理的，您可以通过转换sender为SqlCommand然后查看CommandText属性来查看该批处理（如下例所示）。

    关于这方面的文档非常少，所以我编写了一个示例来显示针对ExecuteNonQuery和ExecuteScalar以及即席查询和存储过程（即SqlCommand.CommandTypevs Text）触发的事件StoredProcedure：

    using System;
using System.Data;
using System.Data.SqlClient;

namespace StatementCompletedFiring
{
    class Program
    {
        static void Main(string[] args)
        {
            using (SqlConnection _Connection =
                          new SqlConnection("Integrated Security = True;"))
            {
                using (SqlCommand _Command = new SqlCommand(@"
SET NOCOUNT OFF; --  ensures that the 'StatementCompleted' event fires

EXEC('
CREATE PROCEDURE #TestProc
AS
SELECT * FROM sys.objects;

SELECT * FROM sys.tables;
');

SELECT * FROM sys.objects;
", _Connection))
                {

                    _Command.StatementCompleted += _Command_StatementCompleted;

                    try
                    {
                        _Connection.Open();

                        _Command.ExecuteNonQuery();

                        _Command.CommandText = @"
SELECT 123 AS [Bob];

WAITFOR DELAY '00:00:05.000'; --5 second pause to shows when the events fire

SELECT 2 AS [Sally]
UNION ALL
SELECT 5;
";
                        Console.WriteLine("\n\t");
                        Console.WriteLine(_Command.ExecuteScalar().ToString());
                        Console.WriteLine("\n");


                        _Command.CommandType = CommandType.StoredProcedure;
                        _Command.CommandText = "#TestProc";
                        _Command.ExecuteNonQuery();
                    }
                    catch (Exception _Exception)
                    {
                        throw new Exception(_Exception.Message);
                    }
                }
            }
        }

        static void _Command_StatementCompleted(object sender,
                                                StatementCompletedEventArgs e)
        {
            Console.ForegroundColor = ConsoleColor.Red;
            Console.Write("\nQuery Batch: ");
            Console.ForegroundColor = ConsoleColor.White;
            Console.WriteLine(((SqlCommand)sender).CommandText);

            Console.ForegroundColor = ConsoleColor.Red;
            Console.Write("Row(s) affected: ");
            Console.ForegroundColor = ConsoleColor.White;
            Console.WriteLine(e.RecordCount.ToString() + "\n");

            Console.ResetColor();
        }
    }
}

    输出：

    查询批次：
    SET NOCOUNT OFF；-- 确保“StatementCompleted”事件触发

    EXEC(' CREATE PROCEDURE #TestProc AS SELECT * FROM sys.objects;

    从 sys.tables 中选择 *；');

    选择 * 来自 sys.objects；

    受影响的行数： 453

    查询批次：
    SELECT 123 AS [Bob]；

    等待延迟“00:00:05.000”；--5 秒停顿

    SELECT 2 AS [Sally] UNION ALL SELECT 5;

    受影响的行： 1

    查询批次：
    SELECT 123 AS [Bob]；

    等待延迟“00:00:05.000”；--5 秒停顿

    SELECT 2 AS [Sally] UNION ALL SELECT 5;

    受影响的行： 2

    123

    查询批次： #TestProc
    受影响的行： 453

    查询批次： #TestProc
    受影响的行： 17

    • 7

  2. executenonquery 结果不会在这里执行您想要的操作。但是您仍然可以到达那里，这仅取决于您要将这些信息用于什么目的。

    您可以在每次插入“PRINT @@ROWCOUNT”之后添加这一行，并且您应该将受先前操作影响的行数作为输出的一部分（在此处获得“bar”。

    或者，您可以将“OUTPUT”参数添加到存储过程以保存结果，然后在运行 executenonquery 时捕获该结果。

    编辑：

    我设法修改了Jonathan Kehasias放在一起的示例，以包括 statementcompleted 事件处理。只需添加这两行。

    #Add handler for StatementCompleted
$statementhandler = {param($sender, [System.Data.StatementCompletedEventArgs]$event) Write-Host $event.RecordCount };

#Attach handler...
$cmd.add_StatementCompleted($statementhandler)
    • -1

相关问题