SqlCommand 执行多个结果

Question

当我执行 3 行脚本（或更多）时（例如：I UPDATE、II DELETE、III SELECT），SSMS 会给我 3 条消息和 1 条结果：

1. 我更新 -> x 行受影响
2. II DELETE-> x 行受影响

3. III SELECT -> x 行受影响

4. III SELECT -> 网格视图

我怎样才能让它成为我自己的？使用 C#。

我正在创作：

SqlConnection cn = new SqlConnection("blabla");
SqlCommand cmd = new SqlCommand("my script", cn);

现在我需要执行并获得所有类型的结果

1. 受影响的行
2. 受影响的行
3. 数据表（或数据集）

Answer 1

如果您订阅 StatementCompleted 事件，您可以获得所需的行数。

var rowCounts = new List<int>();
var resultSets = new List<DataTable>();

using (SqlConnection cn = new SqlConnection(connectionString))
using (SqlCommand cmd = new SqlCommand(myScript, cn))
{
    cmd.StatementCompleted += (sender, eventArgs) =>
    {
        rowCounts.Add(eventArgs.RecordCount);
    };
    cn.Open();

    using (var rd = cmd.ExecuteReader())
    {
        do
        {
            var table = new DataTable();
            table.Load(rd);
            resultSets.Add(table);
        } while (rd.NextResult());
    }
}

//rowCounts now holds all of the reported rowcounts
//resultSets now holds all of the result sets returned.

重要说明，如果有人在他们的脚本中执行了SET NOCOUNT ON，则事件StatementCompleted 将不会触发，要在这种情况下获取行数，您必须在脚本中使用@@rowcount 并将其作为结果集显式返回SELECT.

Answer 2

我假设它使整个事情失败或成功，对吗？为什么不只使用相同的连接和事务，然后在最后提交事务。这就是交易的目的。有关更多示例和详细信息，请参阅SqlTransaction documentation。

private static void Demo1()
{
    SqlConnection db = new SqlConnection("connstringhere");
    SqlTransaction transaction;

    db.Open();
    transaction = db.BeginTransaction();
    try
    {
        var updateResultNums = new SqlCommand("UPDATE", db, transaction).ExecuteNonQuery();
        var deleteResultNums = new SqlCommand("DELETE", db, transaction).ExecuteNonQuery();
        var reader = new SqlCommand("SELECT", db, transaction).ExecuteReader();
        while (reader.Read())
        {
            // read
            // alternatively see http://stackoverflow.com/a/13870892/1260204 if you really want a data table from the SqlCommand
        }
        transaction.Commit();
    }
    catch (SqlException sqlError)
    {
        transaction.Rollback();
        // do something to handle error
    }
    finally
    {
        db.Close(); //close connection
        db.Dispose(); //dispose connection
        transaction.Dispose();
    }
}