Оишбка в потоке при работе с ADO

[MyIE]

Текст потока:

unit ThreadStream_status;

interface

uses
  Classes, ADODB, DB, idhttp;

type
  StreamStatus = class(TThread)
    ADOC1: TADOConnection;
    Streams: TADOTable;
    Streamsid: TAutoIncField;
    StreamsDS: TDataSource;
    ADOQ1: TADOQuery;
    idhttp1: TIdHTTP;
    procedure SetSettings;
    procedure CheckStatus(service: integer; id: string);
    procedure SetStatus(status, id: string);
  private
    { Private declarations }
  protected
    procedure Execute; override;
  end;

implementation

uses UnitMain;

{ StreamStatus }

procedure StreamStatus.SetSettings;
begin
  ADOC1 := TADOConnection.Create(nil);
  Streams := TADOTable.Create(nil);
  StreamsDS := TDataSource.Create(nil);
  ADOQ1 := TADOQuery.Create(nil);
  // ADOConnection 
  ADOC1.ConnectionString :=
    'Provider=Microsoft.Jet.OLEDB.4.0;User ID=Admin;Data Source=D:\Programming\delphi_2010\__sc2stream\db.mdb;';
  ADOC1.ConnectionString := ADOC1.ConnectionString +
    'Mode=Share Deny None;Jet OLEDB:System database="";Jet OLEDB:Registry Path="";Jet OLEDB:Database Password="";';
  ADOC1.ConnectionString := ADOC1.ConnectionString +
    'Jet OLEDB:Engine Type=5;Jet OLEDB:Database Locking Mode=1;Jet OLEDB:Global Partial Bulk Ops=2;Jet OLEDB:Global Bulk Transactions=1;';
  ADOC1.ConnectionString := ADOC1.ConnectionString +
    'Jet OLEDB:New Database Password="";Jet OLEDB:Create System Database=False;Jet OLEDB:Encrypt Database=False;Jet OLEDB:Don''t Copy Locale on Compact=False;Jet OLEDB:Compact Without Replica Repair=False;Jet OLEDB:SFP=False;';
  ADOC1.LoginPrompt := false;
  ADOC1.Mode := cmShareDenyNone;
  ADOC1.Provider := 'Microsoft.Jet.OLEDB.4.0';
  ADOC1.Connected := true;
  // ADOTable 
  Streams.Connection := ADOC1;
  Streams.CursorType := ctStatic;
  Streams.IndexName := 'PrimaryKey';
  Streams.TableName := 'Streams';
  // DataSource 
  StreamsDS.DataSet := Streams;
  StreamsDS.DataSet.Open;
  StreamsDS.Enabled := true;
  // ADOQuery 
  ADOQ1.Connection := ADOC1;
  ADOQ1.DataSource := StreamsDS;
end;

procedure StreamStatus.CheckStatus(service: integer; id: string);
var
  html: string;
begin
  idhttp1 := TIdHTTP.Create(nil);
  idhttp1.ReadTimeout := 3000;
  case service of
    1: // own3d 
      begin
        html := idhttp1.Get
          ('http://static.ec.own3d.tv/live_tmp/' + id + '.txt');
        if html = 'liveViewers=0&liveStatus=false&liveVerified=1' then
          SetStatus('off', id)
        else
          SetStatus('on', id);
      end;
    2: // justin 
      begin
        html := idhttp1.Get
          ('http://api.justin.tv/api/stream/search/' + id + '.json');
        if length(html) < 5 then
          // SetStatus('off', id) 
        else
          // SetStatus('on', id); 
        end;
      end;
  end;

  procedure StreamStatus.SetStatus(status, id: string);
  begin
    ADOQ1.SQL.Clear;
    ADOQ1.SQL.Add('UPDATE streams SET status = ''' + status +
        ''' WHERE stream_id = ''' + id + ''' ');
    ADOQ1.ExecSQL;
  end;

  procedure StreamStatus.Execute;

  var
    i, count, service: integer;
    stream_id: string;
  begin
    // Установка настроек 
    SetSettings;
    // Получаем число записей 
    count := 6;
    { Place thread code here }
    ADOQ1.SQL.Clear;
    ADOQ1.SQL.Add('SELECT * FROM streams');
    ADOQ1.Open;
    Streams.Open;
    for i := 1 to 1 do
    begin
      service := ADOQ1.Fields[3].AsInteger;
      stream_id := ADOQ1.Fields[9].AsString;
      CheckStatus(service, stream_id);
      ADOQ1.Open;
      //Streams.Open;
      ADOQ1.Next;
    end;
  end;

end.

Ошибка:

PHP код:

Текущий поставщик не поддерживает возврат нескольких наборов записей в одной операции 


Если закомментировать строку "ADOQ1.Next", то проблем нет. только вот мне надо по-очереди получать данные каждой записи.

Как исправить проблему? Может нужно более позднюю версия access файла использовать? Может более поздняя версия поддерживает возврат нескольких записей?

[Аватар]

Попробуй заменить

    for i := 1 to 1 do 
    begin 
      service := ADOQ1.Fields[3].AsInteger; 
      stream_id := ADOQ1.Fields[9].AsString; 
      CheckStatus(service, stream_id); 
      ADOQ1.Open; 
      //Streams.Open; 
      ADOQ1.Next; 
    end;

на

    while not ADOQ1.Eof do begin
      service := ADOQ1.Fields[3].AsInteger; 
      stream_id := ADOQ1.Fields[9].AsString; 
      CheckStatus(service, stream_id); 
      ADOQ1.Next; 
    end;

И не понятно зачем StreamsDS вообще нужно
Хотя SetStatus закроет ADOQ1. В нем нужно другой ADOQuery использовать

[MyIE]

Ну во-первых: без

ADOQ1.Open;

Ошибка грит, что DataSet закрыт.

А во-вторых: с данной строчкой:

while not ADOQ1.Eof do begin
      service := ADOQ1.Fields[3].AsInteger; 
      stream_id := ADOQ1.Fields[9].AsString; 
      CheckStatus(service, stream_id); 
      ADOQ1.Open;
      ADOQ1.Next; 
    end;

та же ошибка и далее еще одна вылазит:

CommandText does not return a result set

StreamDS наверное действительно не нужен, просто он у меня есть в части программы, где используется DBGrid, но он в данном потоке погоды не делает.

[MyIE]

По-просту говоря, мне нужен лишь принцип получений записей в цикле, в потоке.
Естественно о DBGrid тут речь не идет.

[Аватар]

Главного в посте вы не заметили

Хотя SetStatus закроет ADOQ1. В нем нужно другой ADOQuery использовать

Это и есть основная проблема

[MyIE]

Заметил я
Я попробывал уже и так, если я правильно вас понял:

  procedure StreamStatus.SetStatus(status, id: string);
  begin
    ADOQ1.SQL.Clear;
    ADOQ1.SQL.Add('UPDATE streams SET status = ''' + status +
        ''' WHERE stream_id = ''' + id + ''' ');
    ADOQ1.ExecSQL;
  end;

...

  procedure StreamStatus.Execute;

  var
    i, count, service: integer;
    stream_id: string;
  begin
    // Установка настроек 
    SetSettings;
    // Получаем число записей 
    count := 6;
    { Place thread code here }
    ADOQ2.SQL.Clear;
    ADOQ2.SQL.Add('SELECT * FROM streams');
    ADOQ2.Open;
    Streams.Open;
    {*
    for i := 1 to 1 do
    begin
      service := ADOQ1.Fields[3].AsInteger;
      stream_id := ADOQ1.Fields[9].AsString;
      CheckStatus(service, stream_id);
      ADOQ1.Open;
      //Streams.Open;
      ADOQ1.Next;
    end;
    *}
    while not ADOQ2.Eof do begin
      service := ADOQ2.Fields[3].AsInteger;
      stream_id := ADOQ2.Fields[9].AsString;
      CheckStatus(service, stream_id);
      ADOQ2.Open;
      ADOQ2.Next;
    end;
  end;

[Аватар]

Зачем перед ADOQ2.Next вставили ADOQ2.Open? Теперь ADOQ2 не должен закрываться из-за процедуры CheckStatus. А ошибки дает? И на какой команде?

[MyIE]

Даже не знаю, что сказать
ADOQ2.Open нужен был, т.к. ошибка та же вылетала, что DataSet closed.
Не знаю как так, но после перезагрузуи delphi (Code Gear 2010) все стало работать.
Спс, что помог.

P.S. работает твой вариант с двумя ADOQuery