risingwave_frontend/binder/
create_view.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 risingwave_sqlparser::ast::{EmitMode, Ident, ObjectName, SqlOption};
16
17use crate::binder::BoundQuery;
18use crate::binder::statement::RewriteExprsRecursive;
19use crate::expr::ExprRewriter;
20
21/// Represents a bounded `CREATE MATERIALIZED VIEW` statement.
22#[derive(Debug, Clone)]
23pub struct BoundCreateView {
24    pub or_replace: bool,
25    pub materialized: bool, // always true currently
26    pub if_not_exists: bool,
27    pub name: ObjectName,
28    pub columns: Vec<Ident>,
29    pub query: Box<BoundQuery>, // reuse the BoundQuery struct
30    pub emit_mode: Option<EmitMode>,
31    pub with_options: Vec<SqlOption>,
32}
33
34impl BoundCreateView {
35    pub fn new(
36        or_replace: bool,
37        materialized: bool,
38        if_not_exists: bool,
39        name: ObjectName,
40        columns: Vec<Ident>,
41        query: BoundQuery,
42        emit_mode: Option<EmitMode>,
43        with_options: Vec<SqlOption>,
44    ) -> Self {
45        Self {
46            or_replace,
47            materialized,
48            if_not_exists,
49            name,
50            columns,
51            query: Box::new(query),
52            emit_mode,
53            with_options,
54        }
55    }
56}
57
58impl RewriteExprsRecursive for BoundCreateView {
59    fn rewrite_exprs_recursive(&mut self, rewriter: &mut impl ExprRewriter) {
60        self.query.rewrite_exprs_recursive(rewriter);
61    }
62}
risingwave_frontend/binder/create_view.rs

risingwave_frontend/binder/
create_view.rs
