连接到 Spark 中的 Netezza：没有合适的驱动程序错误（但驱动程序存在于 SPARK_CLASSPATH 中）

Question

在启动 spark-shell 之前，我已在 SPARK_CLASSPATH 中添加了我的 Netezza jar (nzjdbc3.jar)。

这就是我在 Scala 中连接到 Netezza 的方式：

scala>> val mytable = sqlContext.load("jdbc", Map("url" -> "jdbc:netezza://host:port/dbName?user=xxxxxx&password=xxxxxx", "dbtable" -> "table_name"))

我不断收到著名的“没有合适的驱动程序”错误。我让 JDBC 连接成功地为 Oracle、Sybase、PostGres 和 MySQL 工作；问题仅在于 Netezza。

有没有办法解决这个问题？

Answer 1

您的驱动程序似乎不是 JDBC 4 驱动程序，这意味着它不会自动加载（您可能需要检查是否有更新的版本可用）。

您可以通过将 driver 属性添加到映射中来指示加载驱动程序，并将 Netezza JDBC 驱动程序的名称作为值。