org.apache.spark.sql.jdbc

Class NoopDialect

Object

org.apache.spark.sql.jdbc.NoopDialect

public class NoopDialect
extends Object

NOOP dialect object, always returning the neutral element.

Constructor Summary

Constructors

Constructor and Description
NoopDialect()

Method Summary

Modifier and Type	Method and Description
static String[]	alterTable(String tableName, scala.collection.Seq<TableChange> changes, int dbMajorVersion)
static void	beforeFetch(java.sql.Connection connection, scala.collection.immutable.Map<String,String> properties)
static boolean	canHandle(String url)
static AnalysisException	classifyException(String message, Throwable e)
static Object	compileValue(Object value)
static String	getAddColumnQuery(String tableName, String columnName, String dataType)
static scala.Option<DataType>	getCatalystType(int sqlType, String typeName, int size, MetadataBuilder md)
static String	getDeleteColumnQuery(String tableName, String columnName)
static scala.Option<JdbcType>	getJDBCType(DataType dt)
static String	getRenameColumnQuery(String tableName, String columnName, String newName, int dbMajorVersion)
static String	getSchemaCommentQuery(String schema, String comment)
static String	getSchemaQuery(String table)
static String	getTableCommentQuery(String table, String comment)
static String	getTableExistsQuery(String table)
static String	getTruncateQuery(String table)
static String	getTruncateQuery(String table, scala.Option<Object> cascade)
static scala.Option<Object>	getTruncateQuery$default$2()
static String	getUpdateColumnNullabilityQuery(String tableName, String columnName, boolean isNullable)
static String	getUpdateColumnTypeQuery(String tableName, String columnName, String newDataType)
static scala.Option<Object>	isCascadingTruncateTable()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static String	quoteIdentifier(String colName)
static String	removeSchemaCommentQuery(String schema)
static String	renameTable(String oldTable, String newTable)

Methods inherited from class Object

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

Constructor Detail

NoopDialect

public NoopDialect()

Method Detail

canHandle

public static boolean canHandle(String url)

getCatalystType

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

getJDBCType

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

quoteIdentifier

public static String quoteIdentifier(String colName)

getTableExistsQuery

public static String getTableExistsQuery(String table)

getSchemaQuery

public static String getSchemaQuery(String table)

getTruncateQuery

public static String getTruncateQuery(String table)

getTruncateQuery

public static String getTruncateQuery(String table,
                                      scala.Option<Object> cascade)

getTruncateQuery$default$2

public static scala.Option<Object> getTruncateQuery$default$2()

beforeFetch

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

compileValue

public static Object compileValue(Object value)

isCascadingTruncateTable

public static scala.Option<Object> isCascadingTruncateTable()

renameTable

public static String renameTable(String oldTable,
                                 String newTable)

alterTable

public static String[] alterTable(String tableName,
                                  scala.collection.Seq<TableChange> changes,
                                  int dbMajorVersion)

getAddColumnQuery

public static String getAddColumnQuery(String tableName,
                                       String columnName,
                                       String dataType)

getRenameColumnQuery

public static String getRenameColumnQuery(String tableName,
                                          String columnName,
                                          String newName,
                                          int dbMajorVersion)

getDeleteColumnQuery

public static String getDeleteColumnQuery(String tableName,
                                          String columnName)

getUpdateColumnTypeQuery

public static String getUpdateColumnTypeQuery(String tableName,
                                              String columnName,
                                              String newDataType)

getUpdateColumnNullabilityQuery

public static String getUpdateColumnNullabilityQuery(String tableName,
                                                     String columnName,
                                                     boolean isNullable)

getTableCommentQuery

public static String getTableCommentQuery(String table,
                                          String comment)

getSchemaCommentQuery

public static String getSchemaCommentQuery(String schema,
                                           String comment)

removeSchemaCommentQuery

public static String removeSchemaCommentQuery(String schema)

classifyException

public static AnalysisException classifyException(String message,
                                                  Throwable e)

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)