Function GetDestinationTableSchema

flow/pkg/postgres/dest_validation.go:44–70

GetDestinationTableSchema queries a PostgreSQL table's column type information using SELECT * FROM tableIdentifier LIMIT 0 to get field descriptions with OIDs. Returns pgx.ErrNoRows if the table exists but has no columns.

(ctx context.Context, conn *pgx.Conn, tableIdentifier string)

// using SELECT * FROM tableIdentifier LIMIT 0 to get field descriptions with OIDs.
// Returns pgx.ErrNoRows if the table exists but has no columns.
func GetDestinationTableSchema(ctx context.Context, conn *pgx.Conn, tableIdentifier string) (map[string]ColumnSchema, error) {
	parsedTable, err := common.ParseTableIdentifier(tableIdentifier)
	if err != nil {
		return nil, fmt.Errorf("invalid table identifier %s: %w", tableIdentifier, err)
	}

	customTypeMapping, err := GetCustomDataTypes(ctx, conn)
	if err != nil {
		return nil, fmt.Errorf("failed to fetch custom type mapping: %w", err)
	}

	rows, err := conn.Query(ctx,
		"SELECT * FROM "+parsedTable.String()+" LIMIT 0",
		pgx.QueryExecModeSimpleProtocol,
	)
	if err != nil {
		return nil, err
	}
	fields := slices.Clone(rows.FieldDescriptions())
	rows.Close()

	if len(fields) == 0 {
		return nil, pgx.ErrNoRows
	}

	return BuildColumnSchemaMap(fields, conn.TypeMap(), customTypeMapping)
}

// BuildColumnSchemaMap assembles a ColumnSchema map from pgx FieldDescriptions.
func BuildColumnSchemaMap(