Devart Forum

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

-- создаем тип данных:
create or replace type XX_QUEUE_TYPE is object
(
   t_type int
  ,t_content varchar2(1000)
  ,t_clob clob

)

-- Создаем таблицу для очереди
begin
  dbms_aqadm.create_queue_table(
    queue_table        => 'XX_QUEUE_TBL',
    queue_payload_type => 'XX_QUEUE_TYPE'
  );
end;

-- Собственно очередь
begin
  dbms_aqadm.create_queue(
    queue_name  => 'XX_QUEUE_Q',
    queue_table => 'XX_QUEUE_TBL'
  );
end;

-- Запуск очереди
begin
  dbms_aqadm.start_queue(
    queue_name  => 'XX_QUEUE_Q'
  );
end;

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

procedure TForm1.btEnqueueClick(Sender: TObject);
var
  MsgProp: TQueueMessageProperties;
  Payload: TOraObject;
  MsgId: String;

begin
  MsgProp := TQueueMessageProperties.Create;
  try
    MsgProp.Priority := 1;
    Payload := TOraObject.Create;
    try
      Form1.OraSession1.Connect;
      Payload.AllocObject(OraSession1.OCISvcCtx, 'XX_QUEUE_TYPE');
      Payload.AttrAsInteger['t_type'] := 333;
      Payload.AttrAsString['t_content'] := Edit1.Text;
      Payload.AttrAsLob['t_clob'].LoadFromFile('c:\temp\frez.log') ;
      Payload.AttrIsNull['t_clob'] := false;
      MsgId := OraQueue1.Enqueue(Payload, MsgProp);
      meLog.Lines.Add('Вставка: MsgId: ' + MsgId +' - Сообщение: ' + Edit1.Text );
    finally
      Payload.Free;
    end;
  finally
    MsgProp.Free;
  end;
  OraTable1.Close;
  OraTable1.Open;
end;

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

select *  from XX_QUEUE_TBL