Package org.apache.spark.sql.jdbc

Class SnowflakeDialect

Object

org.apache.spark.sql.jdbc.JdbcDialect

org.apache.spark.sql.jdbc.SnowflakeDialect

All Implemented Interfaces:

Serializable, org.apache.spark.internal.Logging, NoLegacyJDBCError, scala.Equals, scala.Product

public class SnowflakeDialect
extends JdbcDialect
implements NoLegacyJDBCError, scala.Product, Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

org.apache.spark.internal.Logging.LogStringContext, org.apache.spark.internal.Logging.SparkShellLoggingFilter

Constructor Summary

Constructors

Constructor	Description
SnowflakeDialect()

Method Summary

Modifier and Type	Method	Description
abstract static R	apply()
boolean	canHandle(String url)	Check if this dialect instance can handle a certain jdbc url.
scala.Option<JdbcType>	getJDBCType(DataType dt)	Retrieve the jdbc / sql type for a given datatype.
boolean	isObjectNotFoundException(SQLException e)
boolean	isSyntaxErrorBestEffort(SQLException exception)	Attempts to determine if the given SQLException is a SQL syntax error.
static String	toString()

Methods inherited from class org.apache.spark.sql.jdbc.JdbcDialect

alterTable, beforeFetch, classifyException, classifyException, compileAggregate, compileExpression, compileValue, convertJavaDateToDate, convertJavaTimestampToTimestamp, convertJavaTimestampToTimestampNTZ, convertTimestampNTZToJavaTimestamp, createConnectionFactory, createIndex, createSchema, createTable, dropIndex, dropSchema, dropTable, functions, getAddColumnQuery, getCatalystType, getDayTimeIntervalAsMicros, getDeleteColumnQuery, getFullyQualifiedQuotedTableName, getJdbcSQLQueryBuilder, getLimitClause, getOffsetClause, getRenameColumnQuery, getSchemaCommentQuery, getSchemaQuery, getTableCommentQuery, getTableExistsQuery, getTableSample, getTruncateQuery, getTruncateQuery, getUpdateColumnNullabilityQuery, getUpdateColumnTypeQuery, getYearMonthIntervalAsMonths, indexExists, insertIntoTable, isCascadingTruncateTable, isSupportedFunction, listIndexes, listSchemas, quoteIdentifier, removeSchemaCommentQuery, renameTable, renameTable, schemasExists, supportsHint, supportsLimit, supportsOffset, supportsTableSample, updateExtraColumnMeta

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface org.apache.spark.internal.Logging

initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logBasedOnLevel, logDebug, logDebug, logDebug, logDebug, logError, logError, logError, logError, logInfo, logInfo, logInfo, logInfo, logName, LogStringContext, logTrace, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, logWarning, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, withLogContext

Methods inherited from interface org.apache.spark.sql.jdbc.NoLegacyJDBCError

classifyException

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

SnowflakeDialect

public SnowflakeDialect()

Method Details

apply

public abstract static R apply()

toString

public static String toString()

canHandle

public boolean canHandle(String url)

Description copied from class: JdbcDialect

Check if this dialect instance can handle a certain jdbc url.

Specified by:

canHandle in class JdbcDialect

Parameters:

url - the jdbc url.

Returns:

True if the dialect can be applied on the given jdbc url.

isObjectNotFoundException

public boolean isObjectNotFoundException(SQLException e)

Overrides:

isObjectNotFoundException in class JdbcDialect

getJDBCType

public scala.Option<JdbcType> getJDBCType(DataType dt)

Description copied from class: JdbcDialect

Retrieve the jdbc / sql type for a given datatype.

Overrides:

getJDBCType in class JdbcDialect

Parameters:

dt - The datatype (e.g. StringType)

Returns:

The new JdbcType if there is an override for this DataType

isSyntaxErrorBestEffort

public boolean isSyntaxErrorBestEffort(SQLException exception)

Description copied from class: JdbcDialect

Attempts to determine if the given SQLException is a SQL syntax error.

This check is best-effort: it may not detect all syntax errors across all JDBC dialects. However, if this method returns true, the exception is guaranteed to be a syntax error.

This is used to decide whether to wrap the exception in a more appropriate Spark exception.

Overrides:

isSyntaxErrorBestEffort in class JdbcDialect

Parameters:

exception - (undocumented)

Returns:

true if the exception is confidently identified as a syntax error; false otherwise.