Skip to content

Commit 2e9c175

Browse files
author
Maxim Orlov
committed
Issue #27: Fix savepoint in transaction issue, add sql.
1 parent a686050 commit 2e9c175

File tree

1 file changed

+55
-0
lines changed

1 file changed

+55
-0
lines changed

sql/pg_variables_trans.sql

Lines changed: 55 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,3 +1075,58 @@ ROLLBACK;
10751075
SELECT pgv_insert('test1', 'y', ROW (2::float, 1::float), FALSE);
10761076

10771077
SELECT pgv_free();
1078+
1079+
---
1080+
--- Some special cases
1081+
---
1082+
-- 1
1083+
BEGIN;
1084+
SAVEPOINT comm2;
1085+
SELECT pgv_insert('test', 'x1', ROW (2::float, 1::float), TRUE);
1086+
DECLARE r1_cur CURSOR FOR SELECT pgv_stats();
1087+
DECLARE r2_cur CURSOR FOR SELECT pgv_stats();
1088+
FETCH 1 in r1_cur;
1089+
FETCH 1 in r2_cur;
1090+
COMMIT;
1091+
1092+
-- 2
1093+
BEGIN;
1094+
SELECT pgv_insert('test', 'x2', ROW (2::float, 1::float), TRUE);
1095+
SAVEPOINT comm2;
1096+
DECLARE r1_cur CURSOR FOR SELECT pgv_stats();
1097+
DECLARE r2_cur CURSOR FOR SELECT pgv_stats();
1098+
FETCH 1 in r1_cur;
1099+
FETCH 1 in r2_cur;
1100+
COMMIT;
1101+
1102+
-- 3
1103+
BEGIN;
1104+
SELECT pgv_insert('test', 'x3', ROW (2::float, 1::float), TRUE);
1105+
DECLARE r1_cur CURSOR FOR SELECT pgv_stats();
1106+
DECLARE r2_cur CURSOR FOR SELECT pgv_stats();
1107+
SAVEPOINT comm2;
1108+
FETCH 1 in r1_cur;
1109+
FETCH 1 in r2_cur;
1110+
COMMIT;
1111+
1112+
-- 4
1113+
BEGIN;
1114+
SELECT pgv_insert('test', 'x4', ROW (2::float, 1::float), TRUE);
1115+
DECLARE r1_cur CURSOR FOR SELECT pgv_stats();
1116+
DECLARE r2_cur CURSOR FOR SELECT pgv_stats();
1117+
FETCH 1 in r1_cur;
1118+
SAVEPOINT comm2;
1119+
FETCH 1 in r2_cur;
1120+
COMMIT;
1121+
1122+
-- 5
1123+
BEGIN;
1124+
SELECT pgv_insert('test', 'x5', ROW (2::float, 1::float), TRUE);
1125+
DECLARE r1_cur CURSOR FOR SELECT pgv_stats();
1126+
DECLARE r2_cur CURSOR FOR SELECT pgv_stats();
1127+
FETCH 1 in r1_cur;
1128+
FETCH 1 in r2_cur;
1129+
SAVEPOINT comm2;
1130+
COMMIT;
1131+
1132+
SELECT pgv_free();

0 commit comments

Comments
 (0)