sql/pgq: update regtest for get_batch_cursor() change

diff --git a/sql/pgq/expected/pgq_core.out b/sql/pgq/expected/pgq_core.out
index 15da99a391175445e3444963ec3002e2c5a3da7e..a2cb6b2b32159241c87871d3a7211d32be50b9d4 100644 (file)
--- a/sql/pgq/expected/pgq_core.out
+++ b/sql/pgq/expected/pgq_core.out
@@ -202,6 +202,7 @@ select ev_id,ev_retry,ev_type,ev_data,ev_extra1,ev_extra2,ev_extra3,ev_extra4
      3 |          | r3      | data    |           |           |           | 
 (3 rows)
 
+close acurs;
 select ev_id,ev_retry,ev_type,ev_data,ev_extra1,ev_extra2,ev_extra3,ev_extra4
     from pgq.get_batch_cursor(3, 'acurs', 2);
  ev_id | ev_retry | ev_type | ev_data | ev_extra1 | ev_extra2 | ev_extra3 | ev_extra4 

diff --git a/sql/pgq/sql/pgq_core.sql b/sql/pgq/sql/pgq_core.sql
index bf3f690e6181a710f97feeea04b944689e23edf0..dfc4bd9e5f473c4fc0c2e8cfec33d16710593567 100644 (file)
--- a/sql/pgq/sql/pgq_core.sql
+++ b/sql/pgq/sql/pgq_core.sql
@@ -49,6 +49,7 @@ select ev_id,ev_retry,ev_type,ev_data,ev_extra1,ev_extra2,ev_extra3,ev_extra4 fr
 begin;
 select ev_id,ev_retry,ev_type,ev_data,ev_extra1,ev_extra2,ev_extra3,ev_extra4
     from pgq.get_batch_cursor(3, 'acurs', 10);
+close acurs;
 select ev_id,ev_retry,ev_type,ev_data,ev_extra1,ev_extra2,ev_extra3,ev_extra4
     from pgq.get_batch_cursor(3, 'acurs', 2);
 close acurs;