ora-queue/example.sql at main · golubovai/ora-queue · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
begin
  p_queue.create_q('QS', p_try_count => 5);
end;

begin
  for i in 1..100000 loop
    p_queue.enq('QS', hextoraw('A'), p_use_pipe => 'Y');
  end loop;
end;

declare
  l_id raw(16);
  l_payload blob;
begin
  for i in 1..100000 loop
    p_queue.deq('QS', 1, l_payload, p_use_pipe => 'Y');
  end loop;
end;

declare
  l_id raw(16);
  l_payload_array p_queue.te_payload_t := p_queue.te_payload_t();
begin
  for i in 1..1 loop
    l_payload_array.extend;
    l_payload_array(i) := hextoraw('A');
  end loop;
  for i in 1..100000 loop
    p_queue.enq_array('QS', l_payload_array);
    commit;
  end loop;
end;

declare
  l_id raw(16);
  l_payload_array p_queue.te_payload_t;
begin
  for i in 1..100000 loop
    p_queue.deq_array('QS', 1, l_payload_array, p_size => 1);
    commit;
  end loop;
end;

declare
  l_id raw(16);
  l_payload blob;
begin
  for i in 1..100000 loop
    p_queue.deq('QS', 1, l_payload, p_prefetch => 1);
    commit;
  end loop;
end;

enq_array (100000):
100 - 8.46ñ
50  - 8.58ñ
25  - 8.69ñ
10  - 9.15ñ
5   - 10.00ñ
2   - 12.70ñ
1   - 16.38ñ

enq (100000)
persistent - 16.69ñ (16.56ñ dbms_aq)
use_pipe   -  0.74ñ (1.52ñ  dbms_aq buffered)

deq_array(100000)
100 - 5.67c
50  - 5.79c
25  - 6.86c
10  - 7.98c
5   - 10.88c
2   - 18.02c
1   - 21.65c

deq(100000)
prefetch
100 - 16.30c (11.49c dbms_aq)
50  - 16.35c
25  - 17.40c
10  - 16.83c
5   - 17.67c
2   - 20.58c
1   - 21.91c
use_pipe - 1.08c (1.74c  dbms_aq buffered)