Асинхронная обработка в ADO

[MOV]

Как можно сделать, чтобы
при вызове

AODDB.Connection.execute "my_procedure"

чтобы прога не висла.

представляю, что можно перед ее запуском пустить таймер и в нем ее перерисовывать и делать всякие другие нужные штуки пока выполняется проца, но может.
можно через АПИ многопоточную обработку,
но может само АДО позволяет запустить процу и выполнять прогу дальше?

[alibek]

Почитай про аргумент Option, в частности, про флаг adAsyncExecute.

[MOV]

Спасибо! Оно!!! Ура!

[MOV]

в догонку как динамически созадвать новое соединение

то есть допустим ADODB.Connection.execute "myprocedure"
запускаю с флагом adAsyncExecute,
все отлично проца запустилась,
но мне надо (если необходимо, запустить еще несколько сессий с этой процедурой (с другими параметрами)) сколько сессий заранее еизвестно.
То есть надо как-то динамически создавать новое ADODB connection и экзекутить его.
Может как-то создать динамический массив объектов этого типа?

ааа все. получилось:

да типа такого :

Код: Выделить всё

Dim Cn() As ADODB.Connection

Private Sub Command1_Click()
                Static cnt As Long
                cnt = cnt + 1
                ReDim Preserve Cn(cnt)
                Set Cn(cnt) = New ADODB.Connection
                Cn(cnt).ConnectionString = "mystring"
                Cn(cnt).Open
                Cn(cnt).Execute "truncate table trace", , 16
                cnt = cnt + 1
                ReDim Preserve Cn(cnt)
                Set Cn(cnt) = New ADODB.Connection
                Cn(cnt).ConnectionString = "mystring"
                Cn(cnt).Open
                Cn(cnt).Execute "truncate table trace", , 16
End Sub

[MOV]

Вот такой код:

Код: Выделить всё

Dim WithEvents CN As ADODB.Connection
Dim WithEvents RS As ADODB.Recordset

Private Sub CN_ConnectComplete(ByVal pError As ADODB.Error, adStatus As ADODB.EventStatusEnum, ByVal pConnection As ADODB.Connection)
RS.ActiveConnection = CN
End Sub

Private Sub Command1_Click()
Set CN = New ADODB.Connection
Set RS = New ADODB.Recordset
CN.ConnectionString = "Provider=OraOLEDB.Oracle.1;Persist Security " & _
                                "Info=False;User ID=us; PASSwORD=pass; Data Source=source"
CN.Open
RS.Open "select field1, sum(field2) from mytable group by field1", , , , 16
RS.MoveFirst
End Sub

Хочу открыть рекордсет асинхронно, чтобы прога не висла при выполнении запроса, но какое событие надо отлоить, чтобы увидеть, что запрос уже выполнен и можно продолжать работу (RS.MoveFirst)?
Ни одно из событий не срабатывает.
Близко к истине событие RS_FetchComplete но как его вызвать (метода fetch у рекордсета не вижу есть filter но как его юзать и вызовет ли он фетч_комплит?).
Или это надо делать как-то по другому?

[Konst_One]

Код: Выделить всё

Private Sub rs_FetchComplete(ByVal pError As ADODB.Error, adStatus As ADODB.EventStatusEnum, ByVal pRecordset As ADODB.Recordset)
    bComplete = True
    'ЗДЕСЬ!!!
End Sub

Private Sub rs_FetchProgress(ByVal Progress As Long, ByVal MaxProgress As Long, adStatus As ADODB.EventStatusEnum, ByVal pRecordset As ADODB.Recordset)
    Me.lblRecordCount.Caption = "Найдено записей: " & Me.rs.RecordCount
End Sub

[Antonariy]

Код: Выделить всё

Dim WithEvents CN As ADODB.Connection
Dim WithEvents RS As ADODB.Recordset

Private Sub CN_ConnectComplete(ByVal pError As ADODB.Error, adStatus As ADODB.EventStatusEnum, ByVal pConnection As ADODB.Connection)
    RS.Open "select field1, sum(field2) from mytable group by field1", cn, , , 16
End Sub

Private Sub Command1_Click()
    Set CN = New ADODB.Connection
    Set RS = New ADODB.Recordset
    CN.ConnectionString = "Provider=OraOLEDB.Oracle.1;Persist Security " & _
    "Info=False;User ID=us; PASSwORD=pass; Data Source=source"
    CN.Open
End Sub

Private Sub RS_FetchComplete(pError As Error, adStatus As EventStatusEnum, pRecordset As Recordset)
    RS.MoveFirst
End Sub

[MOV]

Оба варианта не проходят.
Я же говорю, что событие ФетчКомплит Не возникает
ранво как и события rs_FetchProgress

[Antonariy]

RS.Open "select field1, sum(field2) from mytable group by field1", CN, , , adAsyncFetch (32)

С какого потолка значения констант берешь?

[MOV]

да все равно не работает хоть 16, хоть 32 хоть просто adAsyncFetch
может черканете реально работающий пример где бы отработало событие FetchComplete?

[Konst_One]

Код: Выделить всё

  Set cn = New ADODB.Connection
  cn.CommandTimeout = 0
  cn.ConnectionTimeout = 30
  cn.CursorLocation = adUseClient
  cn.Open modADO.GetConnectionString
 
  Set rsEvents = New ADODB.Recordset
  rsEvents.CursorLocation = adUseClient
  rsEvents.PageSize = 100
  rsEvents.CacheSize = 1000
  Set rsEvents.ActiveConnection = cn
  rsEvents.Open SQL, , adOpenStatic, adLockReadOnly, adAsyncFetchNonBlocking
 
 
  Me.lblRecordCount.Caption = "Найдено записей: " & rsEvents.RecordCount
 
  Set dtgEvents.DataSource = rsEvents

остальное ты уже видел

[MOV]

во. спасибо. работает классно.

[Antonariy]

Забыл сказать, FetchComplete произойдет только с клиентским рекордсетом, когда все записи отданы.

[MOV]

Сессия вываливается в некативную.
Делаю так:

Код: Выделить всё

Private Declare Sub Sleep Lib "kernel32" (ByVal dwMilliseconds As Long)
Dim CNR() As ADODB.Connection
Dim WithEvents CN As ADODB.Connection
Dim WithEvents RS As ADODB.Recordset
Dim Cstring as String

Private Sub CN_ConnectComplete(ByVal pError As ADODB.Error, adStatus As ADODB.EventStatusEnum, ByVal pConnection As ADODB.Connection)
    RS.ActiveConnection=CN
End Sub

Private Sub Command1_Click()
'АСИНХРОННО ЗАПУСКАЮ ПРОЦУ:   
    Set CNR(0) = New ADODB.Connection
    Cstring="Provider=OraOLEDB.Oracle.1;Persist Security " & _
    "Info=False;User ID=us; PASSwORD=pass; Data Source=source"
     CNR(0).Open Cstring
     CNR.Execute "myprocedure",, adAsyncExecute
'ДАЛЕЕ СМОТРЮ КАК ОНА ВЫПОЛНЯЕТСЯ:
     Set CN= New ADODB.Connection
     Set RS= New ADODB.Recordset
     CN.Open Cstring
     cnt=1
     While cnt<>0
           RS.Open "select count(*) cnt from mytable where dt_obr is null"
           if not RS.EOF then
               RS.MoveFirst 
               cnt=RS.Fields("cnt").value
           else
               cnt=0 'необработанных записей не осталось, выходим из цикла
           end if
            RS.Close
           DoEvents
           Sleep 5000   
     Wend
End Sub

Private Sub RS_FetchComplete(pError As Error, adStatus As EventStatusEnum, pRecordset As Recordset)
    RS.MoveFirst
End Sub

Сначала, все работает нормально и видно как обрабатываются записи, но потом сессия с процедурой, которая запущена асинхронно вываливается в неактивную (видно в V$SESSION) (при чем на одном и том же количестве записей), естественно, обработка прекращается и цикл становится бесконечным. Такое происходит не с одной процедурой, с другими - аналогичная картина.

[Antonariy]

Потому что тут такая дикая мешанина... Вообще непонятно где тут что асинхронно выполняется... Завершения CN_ConnectComplete не ждешь, вернее оно вообще не нужно - соединение открывается без асинхронности... RS_FetchComplete никогда не выполнится... While cnt<>0 ... Sleep 5000 Wend - вообще дикость. Этот цикл блокирует прогу, а если ты им всего лишь ждешь результата выполнения myprocedure, то нафига тогда асинхронность?

Ты бы хоть скачал мой пример, чтобы увидеть, как на самом деле работает асинхронность.

[MOV]

Этот цикл блокирует прогу, а если ты им всего лишь ждешь результата выполнения myprocedure, то нафига тогда асинхронность?

Так если не асинхронить, то прога подвисает пока не выполнится екзекуте (это может занять и час), а я хочу, чтобы прога работала легко и непринужденно, поэтому в цикле жду пока закончится обработка плюс вывожу на форму ход выполнения (ну сколько записей осталось обработать). Плюс к этому есть необходимость пускать несколько процедур параллельно, а потом ждать пока они завершаться, поэтому надо асинхронно.
А на счет слип ты прав, может из-за того, что слишком большой слип прога и отваливается - попробую поставить на 1 секунду. Да и слип сам по себе вешает прогу конечно тоже. Делать все это в отдельной тереде было бы круче наверно, но не умею. Да. Пример сейчас скачаю.

[alibek]

А знаешь, чем тебе грозит DoEvents в цикле?

[MOV]

А знаешь, чем тебе грозит DoEvents в цикле?

Чем?
Неужели нельзя у меня без него ведь форма не будет перерисовываться.
1. Блин может тогда кто-то сбросит как в отдельном треде запустить процедуру на серваке?
2. в принципе можно сбросить скрипт запускающий процу на винт, а потом шелом запустить sqlplus на выполнение этого скрипта в скрытом режиме, но это коряво как-то и труднее отловить оишбку, если проца в склплюсе ругнется вдруг.
В общем, в отдельном потоке было бы лучше. Пойду искать инфу по многопоточности

[alibek]

Тебе уже дали нормальное решение.
Запускаешь процедуру асинхронно.
Устанавливаешь специальный флаг.
Блокируешь все "лишние" элементы управления.
В процедуре _Complete сбрасываешь флаг, восстанавливаешь элементы управления и продолжаешь необходимые действия.

[Wasup!]

Продолжу в этом топике.
Пытаюсь сделать асинхронное выполнение запросов.
У меня получилось сделать это только с проверкой rs.state в таймере.
Думаю, что правильней пользоваться событиями, как описано выше, но у меня событие fetchComplete не возникает. Пробовал
разные варианты. Пример прикладываю.

Также просьба посмотреть, правильно ли реализована отмена асинхронного запроса и высвобождение ресурсов при этой отмене.
Есть подозрение, что что-то там не так - при отмене большого запроса программа подвисает на 5-20 сек.

[GSerg]

У тебя VB не версии 5, случаем?
И Timer1 свой злостный отключи.

[Wasup!]

Нет 6-ой. Ado подключен 2.7
Событие не возникает и при включенном и при выключенном таймере.

[alibek]

Попробуй задать rs.Properties("Initial Fetch Size") = 0
К тому же, не Fetch, а FetchNonBlocking.

[GSerg]

2.8 поставь, и asyncexecute убери.