python - 如何在 Python 中注册 JDBC Spark 方言？

Question

我正在尝试从数据块表中读取数据。我已经使用了数据块中集群的 url。我收到此错误：

 java.sql.SQLDataException: [Simba][JDBC](10140) Error converting value to int.

在这些声明之后：

jdbcConnUrl= "jdbc:spark://adb....."
testquery="(select * from db.table limit 3)"
testdf=spark.read.format("jdbc").option("url", jdbcConnUrl).option("dbtable", testquery).option("fetchsize", "10000").load()
testdf.show()

我遇到了这个问题的所有 Scala 解决方案，但我使用的是 python。我想要这个代码的python等价物：

import org.apache.spark.sql.jdbc.{JdbcDialect, JdbcDialects}
JdbcDialects.registerDialect(new JdbcDialect() {
override def canHandle(url: String): Boolean = url.toLowerCase.startsWith("jdbc:spark:")
override
def quoteIdentifier(column: String): String = column
})