Removed support for PostgreSQL 12, now EOL.

Author: Antonin Houska

concurrent.c

@@ -12,9 +12,7 @@
 
 #include "pg_squeeze.h"
 
-#if PG_VERSION_NUM >= 130000
 #include "access/heaptoast.h"
-#endif
 #include "executor/executor.h"
 #include "replication/decode.h"
 #include "utils/rel.h"
@@ -121,11 +119,6 @@ decode_concurrent_changes(LogicalDecodingContext *ctx,
 {
 	DecodingOutputState *dstate;
 	ResourceOwner resowner_old;
-#if PG_VERSION_NUM < 130000
-	/* Workaround for XLogBeginRead() in setup_decoding(). */
-	static	bool	first_time = true;
-	XLogRecPtr	startptr;
-#endif
 
 	/*
 	 * Invalidate the "present" cache before moving to "(recent) history".
@@ -153,21 +146,7 @@ decode_concurrent_changes(LogicalDecodingContext *ctx,
 			char	   *errm = NULL;
 			XLogRecPtr	end_lsn;
 
-#if PG_VERSION_NUM < 130000
-			if (first_time)
-			{
-				startptr = MyReplicationSlot->data.restart_lsn;
-				first_time = false;
-			}
-			else
-				startptr = InvalidXLogRecPtr;
-#endif
-
-			record = XLogReadRecord(ctx->reader,
-#if PG_VERSION_NUM < 130000
-									startptr,
-#endif
-									&errm);
+			record = XLogReadRecord(ctx->reader, &errm);
 			if (errm)
 				elog(ERROR, "%s", errm);
 

pg_squeeze.c

@@ -9,15 +9,11 @@
  */
 #include "pg_squeeze.h"
 
-#if PG_VERSION_NUM >= 130000
 #include "access/heaptoast.h"
-#endif
 #include "access/multixact.h"
 #include "access/sysattr.h"
-#if PG_VERSION_NUM >= 130000
 #include "access/toast_internals.h"
 #include "access/xlogutils.h"
-#endif
 #if PG_VERSION_NUM >= 150000
 #include "access/xloginsert.h"
 #endif
@@ -139,9 +135,6 @@ static bool perform_final_merge(Oid relid_src, Oid *indexes_src, int nindexes,
 static void swap_relation_files(Oid r1, Oid r2);
 static void swap_toast_names(Oid relid1, Oid toastrelid1, Oid relid2,
 							 Oid toastrelid2);
-#if PG_VERSION_NUM < 130000
-static Oid	get_toast_index(Oid toastrelid);
-#endif
 
 /*
  * The maximum time to hold AccessExclusiveLock during the final
@@ -1032,19 +1025,13 @@ setup_decoding(Oid relid, TupleDesc tup_desc, Snapshot *snap_hist)
 	ctx = CreateDecodingContext(InvalidXLogRecPtr,
 								NIL,
 								false,
-#if PG_VERSION_NUM >= 130000
 								XL_ROUTINE(.page_read = read_local_xlog_page,
 										   .segment_open = wal_segment_open,
 										   .segment_close = wal_segment_close),
-#else
-								logical_read_local_xlog_page,
-#endif
 								NULL, NULL, NULL);
 
-#if PG_VERSION_NUM >= 130000
 	/* decode_concurrent_changes() handles the older versions. */
 	XLogBeginRead(ctx->reader, MyReplicationSlot->data.restart_lsn);
-#endif
 
 	XLByteToSeg(restart_lsn, squeeze_current_segment, wal_segment_size);
 
@@ -2589,8 +2576,7 @@ create_transient_table(CatalogState *cat_state, TupleDesc tup_desc,
 		 * will eventually be dropped.
 		 */
 #if (PG_VERSION_NUM >= 140000) || \
-	(PG_VERSION_NUM < 140000 && PG_VERSION_NUM > 130004) || \
-	(PG_VERSION_NUM < 130000 && PG_VERSION_NUM > 120008)
+	(PG_VERSION_NUM < 140000 && PG_VERSION_NUM > 130004)
 		NewHeapCreateToastTable(result, reloptions, AccessExclusiveLock,
 								InvalidOid);
 #else
@@ -3312,13 +3298,10 @@ swap_toast_names(Oid relid1, Oid toastrelid1, Oid relid2, Oid toastrelid2)
 		RenameRelationInternal(toastrelid2, name, true, false);
 
 		snprintf(name, NAMEDATALEN, "pg_toast_%u_index_", relid1);
-#if PG_VERSION_NUM < 130000
-		/* NoLock as RenameRelationInternal() did not release its lock. */
-		toastidxid = get_toast_index(toastrelid2);
-#else
+
 		/* TOAST relation is locked, but not its indexes. */
 		toastidxid = toast_get_valid_index(toastrelid2, AccessExclusiveLock);
-#endif
+
 		/*
 		 * Pass is_index=false so that even the index is locked in
 		 * AccessExclusiveLock mode. ShareUpdateExclusiveLock mode (allowing
@@ -3334,43 +3317,15 @@ swap_toast_names(Oid relid1, Oid toastrelid1, Oid relid2, Oid toastrelid2)
 	/* Now set the desired names on the TOAST stuff of relid1. */
 	snprintf(name, NAMEDATALEN, "pg_toast_%u", relid1);
 	RenameRelationInternal(toastrelid1, name, true, false);
-#if PG_VERSION_NUM < 130000
-	/* NoLock as RenameRelationInternal() did not release its lock. */
-	toastidxid = get_toast_index(toastrelid1);
-#else
+
 	/* TOAST relation is locked, but not its indexes. */
 	toastidxid = toast_get_valid_index(toastrelid1, AccessExclusiveLock);
-#endif
+
 	snprintf(name, NAMEDATALEN, "pg_toast_%u_index", relid1);
 	RenameRelationInternal(toastidxid, name, true, false);
 	CommandCounterIncrement();
 }
 
-#if PG_VERSION_NUM < 130000
-/*
- * The function is called after RenameRelationInternal() which does not
- * release the lock it acquired.
- */
-static Oid
-get_toast_index(Oid toastrelid)
-{
-	Relation	toastrel;
-	List	   *toastidxs;
-	Oid			result;
-
-	toastrel = table_open(toastrelid, NoLock);
-	toastidxs = RelationGetIndexList(toastrel);
-
-	if (toastidxs == NIL || list_length(toastidxs) != 1)
-		elog(ERROR, "Unexpected number of TOAST indexes");
-
-	result = linitial_oid(toastidxs);
-	table_close(toastrel, NoLock);
-
-	return result;
-}
-#endif
-
 /*
  * Retrieve the "fillfactor" storage option in a convenient way, so we don't
  * have to parse pg_class(reloptions) value at SQL level.

pg_squeeze.h

@@ -17,21 +17,13 @@
 #include "access/genam.h"
 #include "access/heapam.h"
 #include "access/relscan.h"
-#if PG_VERSION_NUM < 130000
-#include "access/tuptoaster.h"
-#endif
 #include "access/xact.h"
-#if PG_VERSION_NUM >= 130000
 #include "access/xlogutils.h"
-#endif
 #include "access/xlog_internal.h"
 #include "catalog/pg_class.h"
 #include "nodes/execnodes.h"
 #include "postmaster/bgworker.h"
 #include "replication/logical.h"
-#if PG_VERSION_NUM < 130000
-#include "replication/logicalfuncs.h"
-#endif
 #include "replication/origin.h"
 #include "storage/ipc.h"
 #include "utils/array.h"

worker.c

@@ -1114,11 +1114,7 @@ scheduler_worker_loop(void)
 		if (rc != SPI_OK_SELECT)
 			ereport(ERROR, (errmsg("SELECT command failed: %s", query.data)));
 
-#if PG_VERSION_NUM >= 130000
 		ntask = SPI_tuptable->numvals;
-#else
-		ntask = SPI_processed;
-#endif
 
 		ereport(DEBUG1, (errmsg("scheduler worker: %zu tasks available",
 								ntask)));
@@ -1537,13 +1533,9 @@ create_replication_slots(int nslots, MemoryContext mcxt)
 										NIL,
 										true,
 										InvalidXLogRecPtr,
-#if PG_VERSION_NUM >= 130000
 										XL_ROUTINE(.page_read = read_local_xlog_page,
 												   .segment_open = wal_segment_open,
 												   .segment_close = wal_segment_close),
-#else
-										logical_read_local_xlog_page,
-#endif
 										NULL, NULL, NULL);
 
 
@@ -2231,13 +2223,7 @@ run_command(char *command, int rc)
 
 	if (rc == SPI_OK_SELECT || rc == SPI_OK_INSERT_RETURNING ||
 		rc == SPI_OK_DELETE_RETURNING || rc == SPI_OK_UPDATE_RETURNING)
-	{
-#if PG_VERSION_NUM >= 130000
 		ntup = SPI_tuptable->numvals;
-#else
-		ntup = SPI_processed;
-#endif
-	}
 	SPI_finish();
 	PopActiveSnapshot();
 	CommitTransactionCommand();