org.apache.spark.sql.jdbc

Class MsSqlServerDialect

java.lang.Object

org.apache.spark.sql.jdbc.MsSqlServerDialect

public class MsSqlServerDialect
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MsSqlServerDialect()

Method Summary

Methods

Modifier and Type	Method and Description
static void	beforeFetch(java.sql.Connection connection, scala.collection.immutable.Map<java.lang.String,java.lang.String> properties)
static boolean	canHandle(java.lang.String url)
static scala.Option<DataType>	getCatalystType(int sqlType, java.lang.String typeName, int size, MetadataBuilder md)
static scala.Option<JdbcType>	getJDBCType(DataType dt)
static java.lang.String	getTableExistsQuery(java.lang.String table)
static java.lang.String	quoteIdentifier(java.lang.String colName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MsSqlServerDialect

public MsSqlServerDialect()

Method Detail

canHandle

public static boolean canHandle(java.lang.String url)

getCatalystType

public static scala.Option<DataType> getCatalystType(int sqlType,
                                     java.lang.String typeName,
                                     int size,
                                     MetadataBuilder md)

getJDBCType

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

quoteIdentifier

public static java.lang.String quoteIdentifier(java.lang.String colName)

getTableExistsQuery

public static java.lang.String getTableExistsQuery(java.lang.String table)

beforeFetch

public static void beforeFetch(java.sql.Connection connection,
               scala.collection.immutable.Map<java.lang.String,java.lang.String> properties)