Handle more than 4 result columns from IDENTIFY_SYSTEM

scott-rc · jackc · commit 51ad596ee12f · 2025-03-31T16:55:43.000-05:00
diff --git a/pglogrepl.go b/pglogrepl.go
@@ -139,8 +139,8 @@ func ParseIdentifySystem(mrr *pgconn.MultiResultReader) (IdentifySystemResult, e
 	}
 
 	row := result.Rows[0]
-	if len(row) != 4 {
-		return isr, fmt.Errorf("expected 4 result columns, got %d", len(row))
+	if len(row) < 4 {
+		return isr, fmt.Errorf("expected at least 4 result columns, got %d", len(row))
 	}
 
 	isr.SystemID = string(row[0])

Original file line number	Diff line number	Diff line change
`@@ -139,8 +139,8 @@ func ParseIdentifySystem(mrr *pgconn.MultiResultReader) (IdentifySystemResult, e`
`139`	`139`	`}`
`140`	`140`
`141`	`141`	`row := result.Rows[0]`
`142`		`- if len(row) != 4 {`
`143`		`- return isr, fmt.Errorf("expected 4 result columns, got %d", len(row))`
	`142`	`+ if len(row) < 4 {`
	`143`	`+ return isr, fmt.Errorf("expected at least 4 result columns, got %d", len(row))`
`144`	`144`	`}`
`145`	`145`
`146`	`146`	`isr.SystemID = string(row[0])`