Struct Binder

pub struct Binder {

    catalog: ArcRwLockReadGuard<RawRwLock, Catalog>,
    db_name: String,
    session_id: SessionId,
    context: BindContext,
    auth_context: Arc<AuthContext>,
    upper_subquery_contexts: Vec<(BindContext, Vec<LateralBindContext>)>,
    lateral_contexts: Vec<LateralBindContext>,
    next_subquery_id: usize,
    next_values_id: usize,
    next_share_id: usize,
    session_config: Arc<RwLock<SessionConfig>>,
    search_path: SearchPath,
    bind_for: BindFor,
    shared_views: HashMap<u32, usize>,
    included_relations: HashSet<TableId>,
    included_udfs: HashSet<FunctionId>,
    param_types: ParameterTypes,
    udf_context: UdfContext,
    temporary_source_manager: TemporarySourceManager,
}

Binder binds the identifiers in AST to columns in relations

Fields

catalog: ArcRwLockReadGuard<RawRwLock, Catalog>

db_name: String

session_id: SessionId

context: BindContext

auth_context: Arc<AuthContext>

upper_subquery_contexts: Vec<(BindContext, Vec<LateralBindContext>)>

A stack holding contexts of outer queries when binding a subquery. It also holds all of the lateral contexts for each respective subquery.

See Binder::bind_subquery_expr for details.

lateral_contexts: Vec<LateralBindContext>

A stack holding contexts of left-lateral TableFactors.

We need a separate stack as CorrelatedInputRef depth is determined by the upper subquery context depth, not the lateral context stack depth.

next_subquery_id: usize

next_values_id: usize

next_share_id: usize

The ShareId is used to identify the share relation which could be a CTE, a source, a view and so on.

session_config: Arc<RwLock<SessionConfig>>

search_path: SearchPath

bind_for: BindFor

The type of binding statement.

shared_views: HashMap<u32, usize>

ShareIds identifying shared views.

included_relations: HashSet<TableId>

The included relations while binding a query.

included_udfs: HashSet<FunctionId>

The included user-defined functions while binding a query.

param_types: ParameterTypes

udf_context: UdfContext

The sql udf context that will be used during binding phase

temporary_source_manager: TemporarySourceManager

The temporary sources that will be used during binding phase

Implementations

impl Binder

pub fn bind_columns_to_context( &mut self, name: String, column_catalogs: &[ColumnCatalog], ) -> Result<(), RwError>

pub fn get_column_binding_index( &mut self, table_name: String, column_name: &String, ) -> Result<usize, RwError>

impl Binder

pub(super) fn bind_delete( &mut self, name: ObjectName, selection: Option<Expr>, returning_items: Vec<SelectItem>, ) -> Result<BoundDelete, RwError>

impl Binder

pub(super) fn bind_binary_op( &mut self, left: Expr, op: BinaryOperator, right: Expr, ) -> Result<ExprImpl, RwError>

fn resolve_binary_operator( op: BinaryOperator, bound_left: &ExprImpl, bound_right: &ExprImpl, ) -> Result<Vec<ExprType>, RwError>

impl Binder

pub fn bind_column(&mut self, idents: &[Ident]) -> Result<ExprImpl, RwError>

impl Binder

fn ensure_aggregate_allowed(&self) -> Result<(), RwError>

pub(super) fn bind_aggregate_function( &mut self, agg_type: AggType, distinct: bool, args: Vec<ExprImpl>, order_by: Vec<OrderByExpr>, within_group: Option<Box<OrderByExpr>>, filter: Option<Box<Expr>>, ) -> Result<ExprImpl, RwError>

fn bind_ordered_set_agg( &mut self, kind: &AggType, distinct: bool, args: Vec<ExprImpl>, order_by: Vec<OrderByExpr>, within_group: Option<Box<OrderByExpr>>, ) -> Result<(Vec<Literal>, Vec<ExprImpl>, OrderBy), RwError>

fn bind_normal_agg( &mut self, kind: &AggType, distinct: bool, args: Vec<ExprImpl>, order_by: Vec<OrderByExpr>, within_group: Option<Box<OrderByExpr>>, ) -> Result<(Vec<Literal>, Vec<ExprImpl>, OrderBy), RwError>

impl Binder

pub(super) fn bind_builtin_scalar_function( &mut self, function_name: &str, inputs: Vec<ExprImpl>, variadic: bool, ) -> Result<ExprImpl, RwError>

fn ensure_now_function_allowed(&self) -> Result<(), RwError>

fn ensure_proctime_function_allowed(&self) -> Result<(), RwError>

impl Binder

fn ensure_window_function_allowed(&self) -> Result<(), RwError>

pub(super) fn bind_window_function( &mut self, kind: WindowFuncKind, args: Vec<ExprImpl>, ignore_nulls: bool, filter: Option<Box<Expr>>, _: WindowSpec, ) -> Result<ExprImpl, RwError>

Bind window function calls according to PostgreSQL syntax. See https://www.postgresql.org/docs/current/sql-expressions.html#SYNTAX-WINDOW-FUNCTIONS for syntax detail.

fn bind_window_frame_usize_bounds( &mut self, start: WindowFrameBound, end: Option<WindowFrameBound>, ) -> Result<(FrameBound<usize>, FrameBound<usize>), RwError>

fn bind_window_frame_scalar_impl_bounds( &mut self, start: WindowFrameBound, end: Option<WindowFrameBound>, offset_data_type: &DataType, ) -> Result<(FrameBound<ScalarImpl>, FrameBound<ScalarImpl>), RwError>

fn bind_window_frame_bound_offset( &mut self, offset: Expr, cast_to: DataType, ) -> Result<ScalarImpl, RwError>

impl Binder

pub(in binder) fn bind_function( &mut self, _: Function, ) -> Result<ExprImpl, RwError>

fn bind_array_transform( &mut self, args: Vec<FunctionArg>, ) -> Result<ExprImpl, RwError>

fn bind_unary_lambda_function( &mut self, input_ty: DataType, arg: Ident, body: Expr, ) -> Result<ExprImpl, RwError>

fn ensure_table_function_allowed(&self) -> Result<(), RwError>

fn bind_sql_udf( &mut self, func: Arc<FunctionCatalog>, args: Vec<ExprImpl>, ) -> Result<ExprImpl, RwError>

pub(in binder) fn bind_function_expr_arg( &mut self, arg_expr: FunctionArgExpr, ) -> Result<Vec<ExprImpl>, RwError>

pub(in binder) fn bind_function_arg( &mut self, arg: FunctionArg, ) -> Result<Vec<ExprImpl>, RwError>

impl Binder

pub(super) fn bind_order_by_expr( &mut self, _: OrderByExpr, ) -> Result<BoundOrderByExpr, RwError>

Bind an ORDER BY expression in other places than Query, including in OVER and in aggregate functions.

Different from a query-level ORDER BY (Self::bind_order_by_expr_in_query), output-column names or numbers are not allowed here.

impl Binder

pub fn bind_subquery_expr( &mut self, query: Query, kind: SubqueryKind, ) -> Result<ExprImpl, RwError>

impl Binder

pub fn bind_value(&mut self, value: Value) -> Result<Literal, RwError>

pub(super) fn bind_string(&mut self, s: String) -> Result<Literal, RwError>

fn bind_bool(&mut self, b: bool) -> Result<Literal, RwError>

fn bind_number(&mut self, s: String) -> Result<Literal, RwError>

fn bind_interval( &mut self, s: String, leading_field: Option<AstDateTimeField>, ) -> Result<Literal, RwError>

pub(crate) fn bind_date_time_field(field: AstDateTimeField) -> DateTimeField

pub(super) fn bind_array( &mut self, exprs: Vec<Expr>, ) -> Result<ExprImpl, RwError>

ARRAY[...] is represented as an function call at the binder stage.

pub(super) fn bind_map( &mut self, entries: Vec<(Expr, Expr)>, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_array_cast( &mut self, exprs: Vec<Expr>, element_type: Box<DataType>, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_map_cast( &mut self, entries: Vec<(Expr, Expr)>, map_type: MapType, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_index( &mut self, obj: Expr, index: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_array_range_index( &mut self, obj: Expr, start: Option<Box<Expr>>, end: Option<Box<Expr>>, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_row(&mut self, exprs: Vec<Expr>) -> Result<ExprImpl, RwError>

Row(...) is represented as an function call at the binder stage.

impl Binder

pub fn bind_expr(&mut self, expr: Expr) -> Result<ExprImpl, RwError>

Bind an expression with bind_expr_inner, attach the original expression to the error message.

This may only be called at the root of the expression tree or when crossing the boundary of a subquery. Otherwise, the source chain might be too deep and confusing to the user.

fn bind_expr_inner(&mut self, expr: Expr) -> Result<ExprImpl, RwError>

pub(super) fn bind_extract( &mut self, field: String, expr: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_at_time_zone( &mut self, input: Expr, time_zone: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_in_list( &mut self, expr: Expr, list: Vec<Expr>, negated: bool, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_in_subquery( &mut self, expr: Expr, subquery: Query, negated: bool, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_is_json( &mut self, expr: Expr, negated: bool, item_type: JsonPredicateType, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_unary_expr( &mut self, op: UnaryOperator, expr: Expr, ) -> Result<ExprImpl, RwError>

fn rewrite_positive(&mut self, expr: Expr) -> Result<ExprImpl, RwError>

Directly returns the expression itself if it is a positive number.

pub(super) fn bind_trim( &mut self, expr: Expr, trim_where: Option<TrimWhereField>, trim_what: Option<Box<Expr>>, ) -> Result<ExprImpl, RwError>

fn bind_substring( &mut self, expr: Expr, substring_from: Option<Box<Expr>>, substring_for: Option<Box<Expr>>, ) -> Result<ExprImpl, RwError>

fn bind_position( &mut self, substring: Expr, string: Expr, ) -> Result<ExprImpl, RwError>

fn bind_overlay( &mut self, expr: Expr, new_substring: Expr, start: Expr, count: Option<Box<Expr>>, ) -> Result<ExprImpl, RwError>

fn bind_parameter(&mut self, index: u64) -> Result<ExprImpl, RwError>

pub(super) fn bind_between( &mut self, expr: Expr, negated: bool, low: Expr, high: Expr, ) -> Result<ExprImpl, RwError>

Bind expr (not) between low and high

fn bind_like( &mut self, expr_type: ExprType, expr: Expr, negated: bool, pattern: Expr, escape_char: Option<EscapeChar>, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_similar_to( &mut self, expr: Expr, negated: bool, pattern: Expr, escape_char: Option<EscapeChar>, ) -> Result<ExprImpl, RwError>

Bind <expr> [ NOT ] SIMILAR TO <pat> ESCAPE <esc_text>

fn check_constant_case_when_optimization( &mut self, conditions: Vec<Expr>, results_expr: Vec<ExprImpl>, operand: Option<Box<Expr>>, fallback: Option<ExprImpl>, constant_case_when_eval_inputs: &mut Vec<ExprImpl>, ) -> bool

The optimization check for the following case-when expression pattern e.g., select case 1 when (…) then (…) else (…) end;

fn compare_or_set(col_expr: &mut Option<Expr>, test_expr: Expr) -> bool

Helper function to compare or set column identifier used in check_convert_simple_form

fn check_invariant(left: Expr, op: BinaryOperator, right: Expr) -> bool

left expression and right expression must be either: <constant> <Eq> <identifier> or <identifier> <Eq> <constant> used in check_convert_simple_form

fn try_extract_simple_form( &mut self, ident_expr: Expr, constant_expr: Expr, column_expr: &mut Option<Expr>, inputs: &mut Vec<ExprImpl>, ) -> bool

Helper function to extract expression out and insert the corresponding bound version to inputs used in check_convert_simple_form Note: this function will be invoked per arm

fn check_convert_simple_form( &mut self, conditions: Vec<Expr>, results_expr: Vec<ExprImpl>, fallback: Option<ExprImpl>, constant_lookup_inputs: &mut Vec<ExprImpl>, ) -> bool

See if the case when expression in form select case when <expr_1 = constant> (...with same pattern...) else <constant> end; If so, this expression could also be converted to constant lookup

fn check_bind_case_optimization( &mut self, conditions: Vec<Expr>, results_expr: Vec<ExprImpl>, operand: Option<Box<Expr>>, fallback: Option<ExprImpl>, constant_lookup_inputs: &mut Vec<ExprImpl>, ) -> bool

The helper function to check if the current case-when expression in bind_case could be optimized into ConstantLookupExpression

pub(super) fn bind_case( &mut self, operand: Option<Box<Expr>>, conditions: Vec<Expr>, results: Vec<Expr>, else_result: Option<Box<Expr>>, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_is_operator( &mut self, func_type: ExprType, expr: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_is_unknown( &mut self, func_type: ExprType, expr: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_distinct_from( &mut self, left: Expr, right: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_not_distinct_from( &mut self, left: Expr, right: Expr, ) -> Result<ExprImpl, RwError>

pub(super) fn bind_cast( &mut self, expr: Expr, data_type: AstDataType, ) -> Result<ExprImpl, RwError>

pub fn bind_cast_inner( &mut self, expr: Expr, data_type: DataType, ) -> Result<ExprImpl, RwError>

pub fn bind_collate( &mut self, expr: Expr, collation: ObjectName, ) -> Result<ExprImpl, RwError>

impl Binder

pub fn bind_fetch_cursor( &mut self, cursor_name: String, count: u32, returning_schema: Option<Schema>, ) -> Result<BoundFetchCursor, RwError>

impl Binder

pub fn bind_sink_by_name(&self, name: ObjectName) -> Result<BoundSink, RwError>

pub fn bind_view_by_name(&self, name: ObjectName) -> Result<BoundView, RwError>

impl Binder

pub(super) fn bind_insert( &mut self, name: ObjectName, cols_to_insert_by_user: Vec<Ident>, source: Query, returning_items: Vec<SelectItem>, ) -> Result<BoundInsert, RwError>

pub(super) fn cast_on_insert( expected_types: &Vec<DataType>, exprs: Vec<ExprImpl>, ) -> Result<Vec<ExprImpl>, RwError>

Cast a list of exprs to corresponding expected_types IN ASSIGNMENT CONTEXT. Make sure you understand the difference of implicit, assignment and explicit cast before reusing it.

impl Binder

pub fn bind_query(&mut self, query: Query) -> Result<BoundQuery, RwError>

Bind a Query.

Before binding the Query, we push the current BindContext to the stack and create a new context, because it may be a subquery.

After finishing binding, we pop the previous context from the stack.

pub(super) fn bind_query_inner( &mut self, _: Query, ) -> Result<BoundQuery, RwError>

Bind a Query using the current BindContext.

pub fn build_name_to_index( names: impl Iterator<Item = String>, ) -> HashMap<String, usize>

fn bind_order_by_expr_in_query( &mut self, _: OrderByExpr, name_to_index: &HashMap<String, usize>, extra_order_exprs: &mut Vec<ExprImpl>, visible_output_num: usize, ) -> Result<ColumnOrder, RwError>

Bind an ORDER BY expression in a Query, which can be either:

• an output-column name
• index of an output column
• an arbitrary expression

Refer to bind_group_by_expr_in_select to see their similarities and differences.

Arguments

• name_to_index - visible output column name -> index. Ambiguous (duplicate) output names are marked with usize::MAX.
• visible_output_num - the number of all visible output columns, including duplicates.

fn bind_with(&mut self, with: With) -> Result<(), RwError>

fn validate_rcte(query: Query) -> Result<(SetExpr, Option<With>), RwError>

syntactically validate the recursive cte ast with the current support features in rw.

fn bind_rcte( &mut self, with: Option<With>, entry: Rc<RefCell<BindingCte>>, left: SetExpr, right: SetExpr, all: bool, ) -> Result<(), RwError>

fn bind_rcte_inner( &mut self, with: Option<With>, entry: Rc<RefCell<BindingCte>>, left: SetExpr, right: SetExpr, all: bool, ) -> Result<(), RwError>

impl Binder

pub(crate) fn bind_vec_table_with_joins( &mut self, from: Vec<TableWithJoins>, ) -> Result<Option<Relation>, RwError>

pub(crate) fn bind_table_with_joins( &mut self, table: TableWithJoins, ) -> Result<Relation, RwError>

fn bind_join_constraint( &mut self, constraint: JoinConstraint, table_factor: Option<TableFactor>, join_type: JoinType, ) -> Result<(ExprImpl, Option<Relation>), RwError>

fn get_identifier_from_indices( context: &BindContext, indices: &[usize], column: Ident, ) -> Result<Expr, RwError>

impl Binder

pub(super) fn bind_subquery_relation( &mut self, query: Query, alias: Option<TableAlias>, lateral: bool, ) -> Result<BoundSubquery, RwError>

Binds a subquery using bind_query, which will use a new empty BindContext for it.

After finishing binding, we update the current context with the output of the subquery.

impl Binder

pub(super) fn bind_table_function( &mut self, name: ObjectName, alias: Option<TableAlias>, args: Vec<FunctionArg>, with_ordinality: bool, ) -> Result<Relation, RwError>

Binds a table function AST, which is a function call in a relation position.

Besides crate::expr::TableFunction expr, it can also be other things like window table functions, or scalar functions.

with_ordinality is only supported for the TableFunction case now.

impl Binder

pub fn bind_relation_by_name_inner( &mut self, schema_name: Option<&str>, table_name: &str, alias: Option<TableAlias>, as_of: Option<AsOf>, ) -> Result<Relation, RwError>

Binds table or source, or logical view according to what we get from the catalog.

fn resolve_table_relation( &mut self, table_catalog: Arc<TableCatalog>, schema_name: &str, as_of: Option<AsOf>, ) -> Result<(Relation, Vec<(bool, Field)>), RwError>

fn resolve_source_relation( &mut self, source_catalog: &SourceCatalog, as_of: Option<AsOf>, ) -> (Relation, Vec<(bool, Field)>)

fn resolve_view_relation( &mut self, view_catalog: &ViewCatalog, ) -> Result<(Relation, Vec<(bool, Field)>), RwError>

fn resolve_table_indexes( &self, schema_name: &str, table_id: TableId, ) -> Result<Vec<Arc<IndexCatalog>>, RwError>

pub(crate) fn bind_table( &mut self, schema_name: Option<&str>, table_name: &str, alias: Option<TableAlias>, ) -> Result<BoundBaseTable, RwError>

pub(crate) fn resolve_dml_table<'a>( &'a self, schema_name: Option<&str>, table_name: &str, is_insert: bool, ) -> Result<&'a TableCatalog, RwError>

impl Binder

pub(super) fn bind_watermark( &mut self, alias: Option<TableAlias>, args: Vec<FunctionArg>, ) -> Result<BoundWatermark, RwError>

impl Binder

pub(super) fn bind_window_table_function( &mut self, alias: Option<TableAlias>, kind: WindowTableFunctionKind, args: Vec<FunctionArg>, ) -> Result<BoundWindowTableFunction, RwError>

impl Binder

pub fn resolve_schema_qualified_name( db_name: &str, name: ObjectName, ) -> Result<(Option<String>, String), ResolveQualifiedNameError>

return (schema_name, name)

fn resolve_single_name( identifiers: Vec<Ident>, ident_desc: &str, ) -> Result<String, RwError>

return first name in identifiers, must have only one name.

pub fn resolve_database_name(name: ObjectName) -> Result<String, RwError>

return the database_name

pub fn resolve_schema_name(name: ObjectName) -> Result<String, RwError>

return the schema_name

pub fn resolve_index_name(name: ObjectName) -> Result<String, RwError>

return the index_name

pub fn resolve_view_name(name: ObjectName) -> Result<String, RwError>

return the view_name

pub fn resolve_sink_name(name: ObjectName) -> Result<String, RwError>

return the sink_name

pub fn resolve_subscription_name(name: ObjectName) -> Result<String, RwError>

return the subscription_name

pub fn resolve_table_name(name: ObjectName) -> Result<String, RwError>

return the table_name

pub fn resolve_source_name(name: ObjectName) -> Result<String, RwError>

return the source_name

pub fn resolve_user_name(name: ObjectName) -> Result<String, RwError>

return the user_name

pub(super) fn bind_table_to_context( &mut self, columns: impl IntoIterator<Item = (bool, Field)>, table_name: String, alias: Option<TableAlias>, ) -> Result<(), RwError>

Fill the BindContext for table.

pub fn bind_relation_by_name( &mut self, name: ObjectName, alias: Option<TableAlias>, as_of: Option<AsOf>, ) -> Result<Relation, RwError>

Binds a relation, which can be:

• a table/source/materialized view
• a reference to a CTE
• a logical view

fn bind_relation_by_function_arg( &mut self, arg: Option<FunctionArg>, err_msg: &str, ) -> Result<(Relation, ObjectName), RwError>

fn bind_column_by_function_args( &mut self, arg: Option<FunctionArg>, err_msg: &str, ) -> Result<Box<InputRef>, RwError>

fn bind_internal_table( &mut self, args: Vec<FunctionArg>, alias: Option<TableAlias>, ) -> Result<Relation, RwError>

rw_table(table_id[,schema_name]) which queries internal table

pub(super) fn bind_table_factor( &mut self, table_factor: TableFactor, ) -> Result<Relation, RwError>

impl Binder

pub(super) fn bind_select( &mut self, select: Select, ) -> Result<BoundSelect, RwError>

pub fn bind_select_list( &mut self, select_items: Vec<SelectItem>, ) -> Result<(Vec<ExprImpl>, Vec<Option<String>>), RwError>

fn bind_group_by_expr_in_select( &mut self, expr: Expr, name_to_index: &HashMap<String, usize>, select_items: &[ExprImpl], ) -> Result<ExprImpl, RwError>

Bind an GROUP BY expression in a Select, which can be either:

• index of an output column
• an arbitrary expression on input columns
• an output-column name

Note the differences from bind_order_by_expr_in_query:

• When a name matches both an input column and an output column, group by interprets it as input column while order by interprets it as output column.
• As the name suggests, group by is part of select while order by is part of query. A query may consist unions of multiple selects (each with their own group by) but only one order by.
• Logically / semantically, group by evaluates before select items, which evaluates before order by. This means, group by can evaluate arbitrary expressions itself, or take expressions from select items (we clone here and logical_agg will rewrite those select items to InputRef). However, order by can only refer to select items, or append its extra arbitrary expressions as hidden select items for evaluation.

Arguments

• name_to_index - output column name -> index. Ambiguous (duplicate) output names are marked with usize::MAX.

fn bind_grouping_items_expr_in_select( &mut self, grouping_items: Vec<Vec<Expr>>, name_to_index: &HashMap<String, usize>, select_items: &[ExprImpl], ) -> Result<Vec<Vec<ExprImpl>>, RwError>

pub fn bind_returning_list( &mut self, returning_items: Vec<SelectItem>, ) -> Result<(Vec<ExprImpl>, Vec<Field>), RwError>

pub fn iter_bound_columns<'a>( column_binding: impl Iterator<Item = &'a ColumnBinding>, ) -> (Vec<ExprImpl>, Vec<Option<String>>)

pub fn iter_column_groups(&self) -> (Vec<ExprImpl>, Vec<Option<String>>)

fn bind_distinct_on( &mut self, distinct: Distinct, name_to_index: &HashMap<String, usize>, select_items: &[ExprImpl], ) -> Result<BoundDistinct, RwError>

Bind DISTINCT clause in a Select. Note that for DISTINCT ON, each expression is interpreted in the same way as ORDER BY expression, which means it will be bound in the following order:

• as an output-column name (can use aliases)
• as an index (from 1) of an output column
• as an arbitrary expression (cannot use aliases)

See also the bind_order_by_expr_in_query method.

Arguments

• name_to_index - output column name -> index. Ambiguous (duplicate) output names are marked with usize::MAX.

fn generate_except_indices( &mut self, except: Option<Vec<Expr>>, ) -> Result<HashSet<usize>, RwError>

impl Binder

pub(crate) fn align_schema( left: &mut BoundSetExpr, right: &mut BoundSetExpr, op: SetOperator, ) -> Result<(), RwError>

note: align_schema only works when the left and right are both select expression(s).

pub(crate) fn validate( left: &BoundSetExpr, right: &BoundSetExpr, op: SetOperator, ) -> Result<(), RwError>

validate the schema, should be called after aligning.

fn corresponding( &self, left: &BoundSetExpr, right: &BoundSetExpr, corresponding: Corresponding, op: &SetOperator, ) -> Result<(ColIndexMapping, ColIndexMapping), RwError>

Check the corresponding specification of the set operation. Returns the corresponding column index of the left and right side.

pub(super) fn bind_set_expr( &mut self, set_expr: SetExpr, ) -> Result<BoundSetExpr, RwError>

impl Binder

pub(super) fn bind_statement( &mut self, stmt: Statement, ) -> Result<BoundStatement, RwError>

impl Binder

fn extract_struct_column( &mut self, expr: Expr, field_idents: Vec<Ident>, ) -> Result<(ExprImpl, Vec<Ident>), RwError>

Extracts and binds struct column from expr. Returns the bound column and the remaining fields.

Specifically,

• (table).struct_col.fields -> (bound_struct_col, fields)
• Otherwise, expr corresponds to a column. (expr).fields -> (bound_expr, fields)

pub fn bind_wildcard_field_column( &mut self, expr: Expr, prefix: Vec<Ident>, ) -> Result<(Vec<ExprImpl>, Vec<Option<String>>), RwError>

Binds wildcard field column, e.g. (table.v1).* or (table).v1.*.

Returns a vector of Field(expr, int) expressions and aliases.

pub fn bind_single_field_column( &mut self, expr: Expr, idents: &[Ident], ) -> Result<ExprImpl, RwError>

Binds single field column, e.g. (table.v1).v2 or (table).v1.v2.

Returns a Field(expr, int) expression.

fn bind_field( field_name: String, expr: ExprImpl, idents: &[Ident], wildcard: bool, ) -> Result<Vec<(ExprImpl, String)>, RwError>

Bind field in recursive way. It could return a couple Field expressions if it ends with a wildcard.

fn bind_wildcard_field( expr: ExprImpl, ) -> Result<Vec<(ExprImpl, String)>, RwError>

Will fail if it’s an atomic value. Rewrite (expr:Struct).* to [Field(expr, 0), Field(expr, 1), … Field(expr, n)].

impl Binder

pub(super) fn bind_update( &mut self, name: ObjectName, assignments: Vec<Assignment>, selection: Option<Expr>, returning_items: Vec<SelectItem>, ) -> Result<BoundUpdate, RwError>

impl Binder

pub(super) fn bind_values( &mut self, values: Values, expected_types: Option<Vec<DataType>>, ) -> Result<BoundValues, RwError>

Bind Values with given expected_types. If no types are expected, a compatible type for all rows will be used. If values are shorter than expected, NULLs will be filled.

impl Binder

fn new_inner( session: &SessionImpl, bind_for: BindFor, param_types: Vec<Option<DataType>>, ) -> Binder

pub fn new(session: &SessionImpl) -> Binder

pub fn new_with_param_types( session: &SessionImpl, param_types: Vec<Option<DataType>>, ) -> Binder

pub fn new_for_stream(session: &SessionImpl) -> Binder

pub fn new_for_ddl(session: &SessionImpl) -> Binder

pub fn new_for_system(session: &SessionImpl) -> Binder

pub fn new_for_stream_with_param_types( session: &SessionImpl, param_types: Vec<Option<DataType>>, ) -> Binder

fn is_for_stream(&self) -> bool

fn is_for_batch(&self) -> bool

fn is_for_ddl(&self) -> bool

pub fn bind(&mut self, stmt: Statement) -> Result<BoundStatement, RwError>

Bind a Statement.

pub fn export_param_types(&self) -> Result<Vec<DataType>, RwError>

pub fn included_relations(&self) -> &HashSet<TableId>

Get included relations in the query after binding. This is used for resolving relation dependencies. Note that it only contains referenced relations discovered during binding. After the plan is built, the referenced relations may be changed. We cannot rely on the collection result of plan, because we still need to record the dependencies that have been optimised away.

pub fn included_udfs(&self) -> &HashSet<FunctionId>

Get included user-defined functions in the query after binding.

fn push_context(&mut self)

fn pop_context(&mut self) -> Result<(), RwError>

fn push_lateral_context(&mut self)

fn pop_and_merge_lateral_context(&mut self) -> Result<(), RwError>

fn try_mark_lateral_as_visible(&mut self)

fn try_mark_lateral_as_invisible(&mut self)

fn next_subquery_id(&mut self) -> usize

fn next_values_id(&mut self) -> usize

fn next_share_id(&mut self) -> usize

fn first_valid_schema(&self) -> Result<&SchemaCatalog, CatalogError>

pub fn set_clause(&mut self, clause: Option<Clause>)

pub fn udf_context_mut(&mut self) -> &mut UdfContext