org.apache.spark.sql.jdbc

Class JdbcDialects

Object

org.apache.spark.sql.jdbc.JdbcDialects

public class JdbcDialects
extends Object

:: DeveloperApi :: Registry of dialects that apply to every new jdbc org.apache.spark.sql.DataFrame.

If multiple matching dialects are registered then all matching ones will be tried in reverse order. A user-added dialect will thus be applied first, overwriting the defaults.

Note:

All new dialects are applied to new jdbc DataFrames only. Make sure to register your dialects first.

Constructor Summary

Constructors

Constructor and Description
JdbcDialects()

Method Summary

Modifier and Type	Method and Description
static JdbcDialect	get(String url) Fetch the JdbcDialect class corresponding to a given database url.
static void	registerDialect(JdbcDialect dialect) Register a dialect for use on all new matching jdbc org.apache.spark.sql.DataFrame.
static void	unregisterDialect(JdbcDialect dialect) Unregister a dialect.

Methods inherited from class Object

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

Constructor Detail

JdbcDialects

public JdbcDialects()

Method Detail

registerDialect

public static void registerDialect(JdbcDialect dialect)

Register a dialect for use on all new matching jdbc org.apache.spark.sql.DataFrame. Reading an existing dialect will cause a move-to-front.

Parameters:

dialect - The new dialect.

unregisterDialect

public static void unregisterDialect(JdbcDialect dialect)

Unregister a dialect. Does nothing if the dialect is not registered.

Parameters:

dialect - The jdbc dialect.

get

public static JdbcDialect get(String url)

Fetch the JdbcDialect class corresponding to a given database url.

Parameters:

url - (undocumented)

Returns:

(undocumented)