Fixed compatibility with PG 17.

Author: Antonin Houska

concurrent.c

@@ -669,7 +669,11 @@ plugin_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 				HeapTuple	newtuple;
 
 				newtuple = change->data.tp.newtuple != NULL ?
+#if PG_VERSION_NUM >= 170000
+					change->data.tp.newtuple : NULL;
+#else
 					&change->data.tp.newtuple->tuple : NULL;
+#endif
 
 				/*
 				 * Identity checks in the main function should have made this
@@ -687,9 +691,17 @@ plugin_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 							newtuple;
 
 				oldtuple = change->data.tp.oldtuple != NULL ?
+#if PG_VERSION_NUM >= 170000
+					change->data.tp.oldtuple : NULL;
+#else
 					&change->data.tp.oldtuple->tuple : NULL;
+#endif
 				newtuple = change->data.tp.newtuple != NULL ?
+#if PG_VERSION_NUM >= 170000
+					change->data.tp.newtuple : NULL;
+#else
 					&change->data.tp.newtuple->tuple : NULL;
+#endif
 
 				if (newtuple == NULL)
 					elog(ERROR, "Incomplete update info.");
@@ -705,7 +717,11 @@ plugin_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 				HeapTuple	oldtuple;
 
 				oldtuple = change->data.tp.oldtuple ?
+#if PG_VERSION_NUM >= 170000
+					change->data.tp.oldtuple : NULL;
+#else
 					&change->data.tp.oldtuple->tuple : NULL;
+#endif
 
 				if (oldtuple == NULL)
 					elog(ERROR, "Incomplete delete info.");

pg_rewrite.c

@@ -1432,7 +1432,9 @@ setup_decoding(Oid relid, TupleDesc tup_desc)
 	buf = makeStringInfo();
 	appendStringInfoString(buf, REPL_SLOT_BASE_NAME);
 	appendStringInfo(buf, "%u_%u", MyDatabaseId, relid);
-#if PG_VERSION_NUM >= 140000
+#if PG_VERSION_NUM >= 170000
+	ReplicationSlotCreate(buf->data, true, RS_EPHEMERAL, false, false, false);
+#elif PG_VERSION_NUM >= 140000
 	ReplicationSlotCreate(buf->data, true, RS_EPHEMERAL, false);
 #else
 	ReplicationSlotCreate(buf->data, true, RS_EPHEMERAL);
@@ -2675,8 +2677,6 @@ equal_dest_descs(TupleDesc tupdesc1, TupleDesc tupdesc2)
 			return false;
 		if (attr1->atttypid != attr2->atttypid)
 			return false;
-		if (attr1->attstattarget != attr2->attstattarget)
-			return false;
 		if (attr1->attlen != attr2->attlen)
 			return false;
 		if (attr1->attndims != attr2->attndims)