risingwave_frontend/catalog/system_catalog/pg_catalog/
pg_cast.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use itertools::Itertools;
16use risingwave_common::types::{DataType, Fields};
17use risingwave_frontend_macro::system_catalog;
18
19use crate::catalog::system_catalog::SysCatalogReaderImpl;
20use crate::expr::CAST_TABLE;
21
22/// The catalog `pg_cast` stores data type conversion paths.
23/// Ref: [`https://www.postgresql.org/docs/current/catalog-pg-cast.html`]
24#[derive(Fields)]
25struct PgCast {
26    #[primary_key]
27    oid: i32,
28    castsource: i32,
29    casttarget: i32,
30    castcontext: String,
31}
32
33#[system_catalog(table, "pg_catalog.pg_cast")]
34fn read_pg_cast(_: &SysCatalogReaderImpl) -> Vec<PgCast> {
35    CAST_TABLE
36        .iter()
37        .sorted()
38        .enumerate()
39        .map(|(idx, ((src, target), ctx))| PgCast {
40            oid: idx as i32,
41            castsource: DataType::try_from(*src).unwrap().to_oid(),
42            casttarget: DataType::try_from(*target).unwrap().to_oid(),
43            castcontext: ctx.to_string(),
44        })
45        .collect()
46}