print debug

PeerDB-io · Mar 16, 2024 · f01c8ad · f01c8ad
1 parent a2cc30c
commit f01c8ad
Showing 1 changed file with 38 additions and 1 deletion.
diff --git a/flow/e2e/postgres/qrep_flow_pg_test.go b/flow/e2e/postgres/qrep_flow_pg_test.go
@@ -36,10 +36,47 @@ func (s PeerFlowE2ETestSuitePG) setupSourceTable(tableName string, rowCount int)
 
 func (s PeerFlowE2ETestSuitePG) comparePGTables(srcSchemaQualified, dstSchemaQualified, selector string) error {
 	// Execute the two EXCEPT queries
-	return errors.Join(
+	err := errors.Join(
 		s.compareQuery(srcSchemaQualified, dstSchemaQualified, selector),
 		s.compareQuery(dstSchemaQualified, srcSchemaQualified, selector),
 	)
+	if err != nil {
+		{
+			query := fmt.Sprintf("SELECT %s FROM %s ORDER BY id", selector, srcSchemaQualified)
+			rows, err := s.Conn().Query(context.Background(), query, pgx.QueryExecModeExec)
+			if err != nil {
+				return err
+			}
+			defer rows.Close()
+			i := 0
+			for rows.Next() {
+				values, err := rows.Values()
+				if err != nil {
+					return err
+				}
+				i += 1
+				s.T().Log("+++", i, values)
+			}
+		}
+		{
+			query := fmt.Sprintf("SELECT %s FROM %s ORDER BY id", selector, dstSchemaQualified)
+			rows, err := s.Conn().Query(context.Background(), query, pgx.QueryExecModeExec)
+			if err != nil {
+				return err
+			}
+			defer rows.Close()
+			i := 0
+			for rows.Next() {
+				values, err := rows.Values()
+				if err != nil {
+					return err
+				}
+				i += 1
+				s.T().Log("+++", i, values)
+			}
+		}
+	}
+	return err
 }
 
 func (s PeerFlowE2ETestSuitePG) checkEnums(srcSchemaQualified, dstSchemaQualified string) error {