通过

使用 Azure Databricks 查询 MariaDB

重要

旧查询联合文档已停用，可能不会更新。 此内容中提到的产品、服务或技术未经 Databricks 正式认可或测试。 请改为参阅什么是 Lakehouse Federation？。

此示例使用其 JDBC 驱动程序查询 MariaDB。 有关读取、写入、配置并行度和查询下推的更多详细信息，请参阅 使用 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()