使用 Azure Databricks 查询 MariaDB
此示例使用 MariaDB 的 JDBC 驱动程序对其进行查询。 有关读取、写入、配置并行度和查询下推的更多详细信息,请参阅使用 JDBC 的查询数据库。
创建 JDBC URL
Python
driver = "org.mariadb.jdbc.Driver"
database_host = "<database-host-url>"
database_port = "3306" # update if you use a non-default port
database_name = "<database-name>"
table = "<table-name>"
user = "<username>"
password = "<password>"
url = f"jdbc:mariadb://{database_host}:{database_port}/{database_name}"
Scala
val driver = "org.mariadb.jdbc.Driver"
val database_host = "<database-host-url>"
val database_port = "3306" # update if you use a non-default port
val database_name = "<database-name>"
val table = "<table-name>"
val user = "<username>"
val password = "<password>"
val url = s"jdbc:mariadb://${database_host}:${database_port}/${database_name}"
查询远程表
Python
remote_table = (spark.read
.format("jdbc")
.option("driver", driver)
.option("url", url)
.option("dbtable", table)
.option("user", user)
.option("password", password)
.load()
)
Scala
val remote_table = spark.read
.format("jdbc")
.option("driver", driver)
.option("url", url)
.option("dbtable", table)
.option("user", user)
.option("password", password)
.load()