Spark Jdbc 连接 JDBC选项

Question

我正在尝试使用Spark JdbcUtils中的可保存方法

https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala

该方法的定义如下。它接受JDBCO作为参数之一。

def saveTable(
      df: DataFrame,
      tableSchema: Option[StructType],
      isCaseSensitive: Boolean,
      options: JDBCOptions)

以下是 JDBC 选项的类

https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala

当我用url、事务隔离级别等初始化JDBCOptions时，它抛出了错误。

您能否提供有关 JDBC 选项初始化的见解

 val options :JDBCOptions = Map("url" -> "JDBCUrl")
Error Type Map doesnt conform to be JDBCOption Type

如何用正确的类型初始化？

Answer 1

您需要将地图包装在< code >新的JDBCOptions(...)呼叫

// url and dbtable are required
val options:JDBCOptions = new JDBCOptions(Map("url" -> "JDBCUrl", "dbtable" -> "foo"))