@@ -26,29 +26,13 @@ const char *PROGRAM_EMAIL = "reorg-general@lists.pgfoundry.org";
26
26
*/
27
27
#define APPLY_COUNT 1000
28
28
29
- #define SQL_XID_SNAPSHOT_80300 \
29
+ #define SQL_XID_SNAPSHOT \
30
30
"SELECT reorg.array_accum(virtualtransaction) FROM pg_locks"\
31
31
" WHERE locktype = 'virtualxid' AND pid <> pg_backend_pid()"
32
- #define SQL_XID_SNAPSHOT_80200 \
33
- "SELECT reorg.array_accum(transactionid) FROM pg_locks"\
34
- " WHERE locktype = 'transactionid' AND pid <> pg_backend_pid()"
35
32
36
- #define SQL_XID_ALIVE_80300 \
33
+ #define SQL_XID_ALIVE \
37
34
"SELECT pid FROM pg_locks WHERE locktype = 'virtualxid'"\
38
35
" AND pid <> pg_backend_pid() AND virtualtransaction = ANY($1)"
39
- #define SQL_XID_ALIVE_80200 \
40
- "SELECT pid FROM pg_locks WHERE locktype = 'transactionid'"\
41
- " AND pid <> pg_backend_pid() AND transactionid = ANY($1)"
42
-
43
- #define SQL_XID_SNAPSHOT \
44
- (PQserverVersion(connection) >= 80300 \
45
- ? SQL_XID_SNAPSHOT_80300 \
46
- : SQL_XID_SNAPSHOT_80200)
47
-
48
- #define SQL_XID_ALIVE \
49
- (PQserverVersion(connection) >= 80300 \
50
- ? SQL_XID_ALIVE_80300 \
51
- : SQL_XID_ALIVE_80200)
52
36
53
37
/*
54
38
* per-table information
@@ -452,7 +436,7 @@ reorg_one_table(const reorg_table *table, const char *orderby)
452
436
command ("BEGIN ISOLATION LEVEL SERIALIZABLE" , 0 , NULL );
453
437
/* SET work_mem = maintenance_work_mem */
454
438
command ("SELECT set_config('work_mem', current_setting('maintenance_work_mem'), true)" , 0 , NULL );
455
- if (PQserverVersion ( connection ) >= 80300 && orderby && !orderby [0 ])
439
+ if (orderby && !orderby [0 ])
456
440
command ("SET LOCAL synchronize_seqscans = off" , 0 , NULL );
457
441
res = execute (SQL_XID_SNAPSHOT , 0 , NULL );
458
442
vxid = strdup (PQgetvalue (res , 0 , 0 ));
0 commit comments