SqlCommand时使用多结果执行

Question

当我执行3行脚本（或多个）（实施例：我更新，II DELETE，III SELECT），SSMS给我3消息（一个或多个）和1个结果：

1. 我UPDATE - > X行（多个）受影响的
2. II删除 - > X行（多个）受影响的

3. III SELECT - > X行（多个）受影响的

4. III SELECT - >网格视图

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

我创建：

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

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

1. 行（S）的影响
2. 行（S）的影响
3. 的DataTable（或DataSet）

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将不火，让rowcounts在这种情况下，你必须在脚本中使用@@rowcount，并明确地返回它作为一个SELECT结果集。

Answer 2

我假设它使得t他整个事情失败或成功？为什么不使用相同的连接和事务，然后在最后提交事务。这就是交易的目的。有关更多示例和详细信息，请参阅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(); 
    } 
}