Skip to main content

SnowflakeDialect

Struct SnowflakeDialect 

Source
pub struct SnowflakeDialect {}
Expand description

Dialect for Snowflake SQL.

Key differences from the default dialect:

  • Uses double-quote identifier quoting
  • Supports NULLS FIRST/NULLS LAST in ORDER BY
  • Does not support empty select lists (SELECT FROM t)
  • Does not support column aliases in table alias definitions (Snowflake accepts the syntax but silently ignores the renames in join contexts)
  • Unparses UNNEST plans as LATERAL FLATTEN(INPUT => expr, ...)

Implementations§

Trait Implementations§

Source§

impl Dialect for SnowflakeDialect

Source§

fn identifier_quote_style(&self, _: &str) -> Option<char>

Return the character used to quote identifiers.
Source§

fn supports_nulls_first_in_sort(&self) -> bool

Does the dialect support specifying NULLS FIRST/LAST in ORDER BY clauses?
Source§

fn supports_empty_select_list(&self) -> bool

Whether the dialect supports an empty select list such as SELECT FROM table. Read more
Source§

fn supports_column_alias_in_table_alias(&self) -> bool

Does the dialect support specifying column aliases as part of alias table definition? (SELECT col1, col2 from my_table) AS my_table_alias(col1_alias, col2_alias)
Source§

fn timestamp_cast_dtype( &self, _time_unit: &TimeUnit, tz: &Option<Arc<str>>, ) -> DataType

The SQL type to use for Timestamp unparsing Most dialects use Timestamp, but some, like MySQL, require Datetime Some dialects like Dremio does not support WithTimeZone and requires always Timestamp
Source§

fn unnest_as_lateral_flatten(&self) -> bool

Unparse the unnest plan as LATERAL FLATTEN(INPUT => expr, ...). Read more
Source§

fn use_array_keyword_for_array_literals(&self) -> bool

Whether array literals should be rendered with the ARRAY[...] keyword.
Source§

fn use_timestamp_for_date64(&self) -> bool

Does the dialect use TIMESTAMP to represent Date64 rather than DATETIME? E.g. Trino, Athena and Dremio does not have DATETIME data type
Source§

fn interval_style(&self) -> IntervalStyle

Source§

fn float64_ast_dtype(&self) -> DataType

Does the dialect use DOUBLE PRECISION to represent Float64 rather than DOUBLE? E.g. Postgres uses DOUBLE PRECISION instead of DOUBLE
Source§

fn utf8_cast_dtype(&self) -> DataType

The SQL type to use for Arrow Utf8 unparsing Most dialects use VARCHAR, but some, like MySQL, require CHAR
Source§

fn large_utf8_cast_dtype(&self) -> DataType

The SQL type to use for Arrow LargeUtf8 unparsing Most dialects use TEXT, but some, like MySQL, require CHAR
Source§

fn date_field_extract_style(&self) -> DateFieldExtractStyle

The date field extract style to use: DateFieldExtractStyle
Source§

fn character_length_style(&self) -> CharacterLengthStyle

The character length extraction style to use: CharacterLengthStyle
Source§

fn int64_cast_dtype(&self) -> DataType

The SQL type to use for Arrow Int64 unparsing Most dialects use BigInt, but some, like MySQL, require SIGNED
Source§

fn int8_cast_dtype(&self) -> DataType

The SQL type to use for Arrow Int8 unparsing Most dialects use TinyInt, but PostgreSQL prefers SmallInt
Source§

fn int32_cast_dtype(&self) -> DataType

The SQL type to use for Arrow Int32 unparsing Most dialects use Integer, but some, like MySQL, require SIGNED
Source§

fn date32_cast_dtype(&self) -> DataType

The SQL type to use for Arrow Date32 unparsing Most dialects use Date, but some, like SQLite require TEXT
Source§

fn requires_derived_table_alias(&self) -> bool

Whether the dialect requires a table alias for any subquery in the FROM clause This affects behavior when deriving logical plans for Sort, Limit, etc.
Source§

fn division_operator(&self) -> BinaryOperator

The division operator for the dialect Most dialect uses BinaryOperator::Divide (/) But DuckDB dialect uses BinaryOperator::DuckIntegerDivide (//)
Source§

fn scalar_function_to_sql_overrides( &self, _unparser: &Unparser<'_>, _func_name: &str, _args: &[Expr], ) -> Result<Option<Expr>, DataFusionError>

Allows the dialect to override scalar function unparsing if the dialect has specific rules. Returns None if the default unparsing should be used, or Some(ast::Expr) if there is a custom implementation for the function.
Source§

fn higher_order_function_to_sql_overrides( &self, _unparser: &Unparser<'_>, _func_name: &str, _args: &[Expr], ) -> Result<Option<Expr>, DataFusionError>

Allows the dialect to override higher order function unparsing if the dialect has specific rules. Returns None if the default unparsing should be used, or Some(ast::Expr) if there is a custom implementation for the function.
Source§

fn window_func_support_window_frame( &self, _func_name: &str, _start_bound: &WindowFrameBound, _end_bound: &WindowFrameBound, ) -> bool

Allows the dialect to choose to omit window frame in unparsing based on function name and window frame bound Returns false if specific function name / window frame bound indicates no window frame is needed in unparsing
Source§

fn with_custom_scalar_overrides( self, _handlers: Vec<(&str, Box<dyn Fn(&Unparser<'_>, &[Expr]) -> Result<Option<Expr>, DataFusionError> + Sync + Send>)>, ) -> Self
where Self: Sized,

Extends the dialect’s default rules for unparsing scalar functions. This is useful for supporting application-specific UDFs or custom engine extensions.
Source§

fn full_qualified_col(&self) -> bool

Allow to unparse a qualified column with a full qualified name (e.g. catalog_name.schema_name.table_name.column_name) Otherwise, the column will be unparsed with only the table name and column name (e.g. table_name.column_name)
Source§

fn unnest_as_table_factor(&self) -> bool

Allow to unparse the unnest plan as ast::TableFactor::UNNEST. Read more
Source§

fn col_alias_overrides( &self, _alias: &str, ) -> Result<Option<String>, DataFusionError>

Allows the dialect to override column alias unparsing if the dialect has specific rules. Returns None if the default unparsing should be used, or Some(String) if there is a custom implementation for the alias.
Source§

fn supports_qualify(&self) -> bool

Allows the dialect to support the QUALIFY clause Read more
Source§

fn timestamp_with_tz_to_string( &self, dt: DateTime<Tz>, _unit: TimeUnit, ) -> String

Allows the dialect to override logic of formatting datetime with tz into string.
Source§

fn string_literal_to_sql(&self, _s: &str) -> Option<Expr>

Override the default string literal unparsing. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<Source> AccessAs for Source

Source§

fn ref_as<T>(&self) -> <Source as IGuardRef<T>>::Guard<'_>
where Source: IGuardRef<T>, T: ?Sized,

Provides immutable access to a type as if it were its ABI-unstable equivalent.
Source§

fn mut_as<T>(&mut self) -> <Source as IGuardMut<T>>::GuardMut<'_>
where Source: IGuardMut<T>, T: ?Sized,

Provides mutable access to a type as if it were its ABI-unstable equivalent.
Source§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, As> IGuardMut<As> for T
where T: Into<As>, As: Into<T>,

Source§

type GuardMut<'a> = MutAs<'a, T, As> where T: 'a

The type of the guard which will clean up the temporary after applying its changes to the original.
Source§

fn guard_mut_inner(&mut self) -> <T as IGuardMut<As>>::GuardMut<'_>

Construct the temporary and guard it through a mutable reference.
Source§

impl<T, As> IGuardRef<As> for T
where T: Into<As>, As: Into<T>,

Source§

type Guard<'a> = RefAs<'a, T, As> where T: 'a

The type of the guard which will clean up the temporary.
Source§

fn guard_ref_inner(&self) -> <T as IGuardRef<As>>::Guard<'_>

Construct the temporary and guard it through an immutable reference.
Source§

impl<T> Includes<End> for T

Source§

type Output = End

The result
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> Ungil for T
where T: Send,

Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more