spark 查询数据库列表
时间: 2023-09-02 20:15:37 浏览: 125
Spark.sql数据库部分的内容
在 Spark 中查询数据库列表可以使用以下代码:
```scala
import java.sql.DriverManager
import java.sql.Connection
object ListDatabases {
def main(args: Array[String]) {
val driver = "com.mysql.jdbc.Driver"
val url = "jdbc:mysql://localhost:3306/"
val username = "root"
val password = "password"
var connection:Connection = null
try {
Class.forName(driver)
connection = DriverManager.getConnection(url, username, password)
val statement = connection.createStatement()
val resultSet = statement.executeQuery("SHOW DATABASES")
while ( resultSet.next() ) {
val database = resultSet.getString("Database")
println(database)
}
} catch {
case e => e.printStackTrace
}
connection.close()
}
}
```
其中,需要根据实际情况修改以下参数:
- `driver`:数据库驱动,这里使用的是 MySQL 的驱动。
- `url`:数据库连接地址。
- `username`:连接数据库的用户名。
- `password`:连接数据库的密码。
运行以上代码,即可列出所有的数据库。
阅读全文