JdbcDialect¶
JdbcDialect
is the <DataFrame
).
[[contract]] [source, scala]
package org.apache.spark.sql.jdbc
abstract class JdbcDialect extends Serializable { // only required properties (vals and methods) that have no implementation // the others follow def canHandle(url : String): Boolean }
.(Subset of) JdbcDialect Contract [cols="1,2",options="header",width="100%"] |=== | Property | Description
| canHandle
| [[canHandle]] Used when...FIXME |===
[[extensions]] .JdbcDialects [cols="1,2",options="header",width="100%"] |=== | JdbcDialect | Description
| AggregatedDialect
| [[AggregatedDialect]]
| DB2Dialect
| [[DB2Dialect]]
| DerbyDialect
| [[DerbyDialect]]
| MsSqlServerDialect
| [[MsSqlServerDialect]]
| MySQLDialect
| [[MySQLDialect]]
| NoopDialect
| [[NoopDialect]]
| OracleDialect
| [[OracleDialect]]
| PostgresDialect
| [[PostgresDialect]]
| TeradataDialect
| [[TeradataDialect]] |===
=== [[getCatalystType]] getCatalystType
Method
[source, scala]¶
getCatalystType( sqlType: Int, typeName: String, size: Int, md: MetadataBuilder): Option[DataType]
getCatalystType
...FIXME
NOTE: getCatalystType
is used when...FIXME
=== [[getJDBCType]] getJDBCType
Method
[source, scala]¶
getJDBCType(dt: DataType): Option[JdbcType]¶
getJDBCType
...FIXME
NOTE: getJDBCType
is used when...FIXME
=== [[quoteIdentifier]] quoteIdentifier
Method
[source, scala]¶
quoteIdentifier(colName: String): String¶
quoteIdentifier
...FIXME
NOTE: quoteIdentifier
is used when...FIXME
=== [[getTableExistsQuery]] getTableExistsQuery
Method
[source, scala]¶
getTableExistsQuery(table: String): String¶
getTableExistsQuery
...FIXME
NOTE: getTableExistsQuery
is used when...FIXME
=== [[getSchemaQuery]] getSchemaQuery
Method
[source, scala]¶
getSchemaQuery(table: String): String¶
getSchemaQuery
...FIXME
NOTE: getSchemaQuery
is used when...FIXME
=== [[getTruncateQuery]] getTruncateQuery
Method
[source, scala]¶
getTruncateQuery(table: String): String¶
getTruncateQuery
...FIXME
NOTE: getTruncateQuery
is used when...FIXME
=== [[beforeFetch]] beforeFetch
Method
[source, scala]¶
beforeFetch(connection: Connection, properties: Map[String, String]): Unit¶
beforeFetch
...FIXME
NOTE: beforeFetch
is used when...FIXME
=== [[escapeSql]] escapeSql
Internal Method
[source, scala]¶
escapeSql(value: String): String¶
escapeSql
...FIXME
NOTE: escapeSql
is used when...FIXME
=== [[compileValue]] compileValue
Method
[source, scala]¶
compileValue(value: Any): Any¶
compileValue
...FIXME
NOTE: compileValue
is used when...FIXME
=== [[isCascadingTruncateTable]] isCascadingTruncateTable
Method
[source, scala]¶
isCascadingTruncateTable(): Option[Boolean]¶
isCascadingTruncateTable
...FIXME
NOTE: isCascadingTruncateTable
is used when...FIXME