Revert "Handle more than 4 result columns from IDENTIFY_SYSTEM"

scott-rc · jackc · commit fdf40658d6e9 · 2025-03-31T16:55:43.000-05:00
This reverts commit 0759e8c.
diff --git a/pglogrepl.go b/pglogrepl.go
@@ -247,8 +247,8 @@ func ParseCreateReplicationSlot(mrr *pgconn.MultiResultReader) (CreateReplicatio
 	}
 
 	row := result.Rows[0]
-	if len(row) < 4 {
-		return crsr, fmt.Errorf("expected at least 4 result columns, got %d", len(row))
+	if len(row) != 4 {
+		return crsr, fmt.Errorf("expected 4 result columns, got %d", len(row))
 	}
 
 	crsr.SlotName = string(row[0])

Original file line number	Diff line number	Diff line change
`@@ -247,8 +247,8 @@ func ParseCreateReplicationSlot(mrr *pgconn.MultiResultReader) (CreateReplicatio`
`247`	`247`	`}`
`248`	`248`
`249`	`249`	`row := result.Rows[0]`
`250`		`- if len(row) < 4 {`
`251`		`- return crsr, fmt.Errorf("expected at least 4 result columns, got %d", len(row))`
	`250`	`+ if len(row) != 4 {`
	`251`	`+ return crsr, fmt.Errorf("expected 4 result columns, got %d", len(row))`
`252`	`252`	`}`
`253`	`253`
`254`	`254`	`crsr.SlotName = string(row[0])`