Настроен компонент OraSession, OraTable и OraQueue.
С записью в OraTable проблем нет - все красиво, как и должно быть. Проблема возникает при записи в очередь OraQueue.
Для демонстрации проблемы можно сделать следующее. В PL/SQL Developer запустить скрипт для подготовки исходных данных:
Код: Выделить всё
-- создаем тип данных:
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;Сам файл frez.log в кодировке UTF8. Содержимое файла: "Hello friends!"
Для того, чтобы посмотреть можно выполнить селект в PL/SQL Developer:
Код: Выделить всё
select * from XX_QUEUE_TBL