org.apache.spark.sql.jdbc

Class MySQLDialect

Object

org.apache.spark.sql.jdbc.MySQLDialect

public class MySQLDialect
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MySQLDialect.MySQLSQLBuilder

Constructor Summary

Constructors

Constructor and Description
MySQLDialect()

Method Summary

Modifier and Type	Method and Description
static String[]	alterTable(String tableName, scala.collection.Seq<org.apache.spark.sql.connector.catalog.TableChange> changes, int dbMajorVersion)
static void	beforeFetch(java.sql.Connection connection, scala.collection.immutable.Map<String,String> properties)
abstract static boolean	canEqual(Object that)
static boolean	canHandle(String url)
static AnalysisException	classifyException(String message, Throwable e)
static scala.Option<String>	compileAggregate(org.apache.spark.sql.connector.expressions.aggregate.AggregateFunc aggFunction)
static scala.Option<String>	compileExpression(org.apache.spark.sql.connector.expressions.Expression expr)
static Object	compileValue(Object value)
static org.apache.spark.sql.internal.SQLConf	conf()
static scala.Function1<Object,java.sql.Connection>	createConnectionFactory(org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)
static String	createIndex(String indexName, org.apache.spark.sql.connector.catalog.Identifier tableIdent, org.apache.spark.sql.connector.expressions.NamedReference[] columns, java.util.Map<org.apache.spark.sql.connector.expressions.NamedReference,java.util.Map<String,String>> columnsProperties, java.util.Map<String,String> properties)
static void	createSchema(java.sql.Statement statement, String schema, String comment)
static String	dropIndex(String indexName, org.apache.spark.sql.connector.catalog.Identifier tableIdent)
static String	dropSchema(String schema, boolean cascade)
abstract static boolean	equals(Object that)
static scala.collection.Seq<scala.Tuple2<String,org.apache.spark.sql.connector.catalog.functions.UnboundFunction>>	functions()
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	getLimitClause(Integer limit)
static String	getOffsetClause(Integer offset)
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	getTableSample(org.apache.spark.sql.execution.datasources.v2.TableSampleInfo sample)
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 boolean	indexExists(java.sql.Connection conn, String indexName, org.apache.spark.sql.connector.catalog.Identifier tableIdent, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)
static scala.Option<Object>	isCascadingTruncateTable()
static boolean	isSupportedFunction(String funcName)
static org.apache.spark.sql.connector.catalog.index.TableIndex[]	listIndexes(java.sql.Connection conn, org.apache.spark.sql.connector.catalog.Identifier tableIdent, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)
static String[][]	listSchemas(java.sql.Connection conn, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
abstract static int	productArity()
abstract static Object	productElement(int n)
static scala.collection.Iterator<Object>	productIterator()
static String	productPrefix()
static String	quoteIdentifier(String colName)
static String	removeSchemaCommentQuery(String schema)
static String	renameTable(String oldTable, String newTable)
static boolean	schemasExists(java.sql.Connection conn, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options, String schema)
static boolean	supportsTableSample()

Methods inherited from class Object

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

Constructor Detail

MySQLDialect

public MySQLDialect()

Method Detail

canHandle

public static boolean canHandle(String url)

isSupportedFunction

public static boolean isSupportedFunction(String funcName)

compileExpression

public static scala.Option<String> compileExpression(org.apache.spark.sql.connector.expressions.Expression expr)

getCatalystType

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

quoteIdentifier

public static String quoteIdentifier(String colName)

schemasExists

public static boolean schemasExists(java.sql.Connection conn,
                                    org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options,
                                    String schema)

listSchemas

public static String[][] listSchemas(java.sql.Connection conn,
                                     org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

getTableExistsQuery

public static String getTableExistsQuery(String table)

isCascadingTruncateTable

public static scala.Option<Object> isCascadingTruncateTable()

getUpdateColumnTypeQuery

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

getRenameColumnQuery

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

getUpdateColumnNullabilityQuery

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

getTableCommentQuery

public static String getTableCommentQuery(String table,
                                          String comment)

getJDBCType

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

getSchemaCommentQuery

public static String getSchemaCommentQuery(String schema,
                                           String comment)

removeSchemaCommentQuery

public static String removeSchemaCommentQuery(String schema)

createIndex

public static String createIndex(String indexName,
                                 org.apache.spark.sql.connector.catalog.Identifier tableIdent,
                                 org.apache.spark.sql.connector.expressions.NamedReference[] columns,
                                 java.util.Map<org.apache.spark.sql.connector.expressions.NamedReference,java.util.Map<String,String>> columnsProperties,
                                 java.util.Map<String,String> properties)

indexExists

public static boolean indexExists(java.sql.Connection conn,
                                  String indexName,
                                  org.apache.spark.sql.connector.catalog.Identifier tableIdent,
                                  org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

dropIndex

public static String dropIndex(String indexName,
                               org.apache.spark.sql.connector.catalog.Identifier tableIdent)

listIndexes

public static org.apache.spark.sql.connector.catalog.index.TableIndex[] listIndexes(java.sql.Connection conn,
                                                                                    org.apache.spark.sql.connector.catalog.Identifier tableIdent,
                                                                                    org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

classifyException

public static AnalysisException classifyException(String message,
                                                  Throwable e)

dropSchema

public static String dropSchema(String schema,
                                boolean cascade)

createConnectionFactory

public static scala.Function1<Object,java.sql.Connection> createConnectionFactory(org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

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)

compileAggregate

public static scala.Option<String> compileAggregate(org.apache.spark.sql.connector.expressions.aggregate.AggregateFunc aggFunction)

functions

public static scala.collection.Seq<scala.Tuple2<String,org.apache.spark.sql.connector.catalog.functions.UnboundFunction>> functions()

createSchema

public static void createSchema(java.sql.Statement statement,
                                String schema,
                                String comment)

renameTable

public static String renameTable(String oldTable,
                                 String newTable)

alterTable

public static String[] alterTable(String tableName,
                                  scala.collection.Seq<org.apache.spark.sql.connector.catalog.TableChange> changes,
                                  int dbMajorVersion)

getAddColumnQuery

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

getDeleteColumnQuery

public static String getDeleteColumnQuery(String tableName,
                                          String columnName)

getLimitClause

public static String getLimitClause(Integer limit)

getOffsetClause

public static String getOffsetClause(Integer offset)

supportsTableSample

public static boolean supportsTableSample()

getTableSample

public static String getTableSample(org.apache.spark.sql.execution.datasources.v2.TableSampleInfo sample)

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)

conf

public static org.apache.spark.sql.internal.SQLConf conf()

canEqual

public abstract static boolean canEqual(Object that)

equals

public abstract static boolean equals(Object that)

productElement

public abstract static Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<Object> productIterator()

productPrefix

public static String productPrefix()