Извлечение записей из нескольких операторов

Question

Я написал свой собственный SQL-клиент, потому что устал от SSMS. Я хочу, чтобы захваченные строки подсчитывались точно так же, как SSMS, но SqlCommand.StatementCompletedподнимается несколько раз, когда ExecuteReader заканчивается (или вызывается EndExecuteReader). Несмотря на то, что утверждения в пакетной версии с регулярным интервалом, кажется, что сообщения DONE_IN_PROC помещаются в очередь на клиенте, а затем сбрасываются все сразу, а не постоянно повышаться. Нет InfoMessage событий, прошедших с SqlConnection.

Обновление выше в курсивом.

Скажем, у вас есть SQL заявление, которое обновляет строки в цикле, или что-то вроде этого:

WHILE 1=1 
BEGIN 
    UPDATE tbl SET .... WHERE Id BETWEEN i AND i+10; 
    IF @@ROWCOUNT =0 BREAK; 
    SET i = i + 10; 
END 

SSMS правильно показывает «(10 строк пострадавших)» каждый Х количество секунд, или ж/д. Нет записей, поступающих от читателя, так как это оператор только для UPDATE, поэтому для подсчета строк использовать .

Возможно ли, используя библиотеку SqlClient?

Упрощенный код в вопросе, как это:

class ExecuteWorker 
{ 
    public void Start(string query) 
    { 
    this._query = query; 
    this._thread.Start(this.Work); 
    } 

    void Work() 
    { 
    using(var conn = new SqlConnection(this._connStr)) 
    { 
     conn.Open(); 
     using(var command = conn.CreateCommand()) 
     { 
     command.CommandText = this._query; 
     using(var reader = command.ExecuteReader()) 
     { 
      while(reader.Read()) 
      { 
      this._control.BeginInvoke(new Action(()=>{ 
       // update UI 
      })); 
      } 
     } 
     } 
    } 
    } 
} 

Аналогичный вопрос найден here, хотя описание менее ясно.

Answer 1

Есть два события, которые вы хотите обработать. SqlConnectionInfoMessage и SqlCommandStatementCompleted.

Извините за код VB, но вы должны быть в состоянии его преобразовать.

Private Sub OnInfoMessage(sender As Object, args As SqlClient.SqlInfoMessageEventArgs) 
    For Each sqlEvent As System.Data.SqlClient.SqlError In args.Errors 
     Dim msg As String = String.Format("Msg {0}, Level {1}, State {2}, Line {3}{4}", sqlEvent.Number, sqlEvent.Class, sqlEvent.State, sqlEvent.LineNumber, Environment.NewLine) 
     'Write msg to output 
    Next 
End Sub 

Private Sub OnStatementCompleted(sender As Object, args As StatementCompletedEventArgs) 
    Dim msg As String = String.Format("({0} row(s) affected)", args.RecordCount) 
    'Write msg to output 
End Sub 

Public Sub Work() 
    Using dbc As New SqlConnection(Me.ConnectionString), 
      dbcmd As New SqlCommand() 

     dbcmd.Connection = dbc 
     dbcmd.CommandTimeout = Convert.ToInt32(timeout) ' you will want to set this otherwise it will timeout after 30 seconds 
     'set other dbcmd properties 

     AddHandler dbc.InfoMessage, New SqlInfoMessageEventHandler(AddressOf OnInfoMessage) 
     AddHandler dbcmd.StatementCompleted, AddressOf OnStatementCompleted 

     dbc.Open() 

     'dbcmd.ExecuteNonQuery() or Using dataReader As SqlDataReader = dbcmd.ExecuteReader() 

    End Using 
End Sub 

Answer 2

Почему вы не перемещаете sql в хранимую процедуру. Выполнение хранимой процедуры с использованием объекта команды с набором параметров, включающим выходной параметр. Внутри хранимой процедуры есть общая переменная счетчика для суммирования каждой из затронутых отдельных строк обновления. Вернуть это как выходной параметр.

Answer 3

Когда вы обновляете db с помощью метода ExecuteNonQuery, он возвращает количество затронутых строк. Этот метод используется, когда вы используете команду вставки, обновления или удаления sql. Надеюсь, это то, что вы ищете.