java - 如何使用 JDBC 驱动程序连接到 Databricks Delta 表
问题描述
如何使用 JDBC 连接到 Databricks Delta 表?
我尝试连接 simba 驱动程序,但我很难获得驱动程序类名称和 url 配置。
任何解决方案表示赞赏。我不能在此处粘贴代码作为其公司代码。
提前致谢。
解决方案
检查下面的这个链接。这有使用 JDBC 配置 delta 的步骤
http://sedeks.blogspot.com/2019/05/how-to-connect-to-databricks-delta.html
此链接中提供的代码:
import java.sql.DriverManager
import java.sql.Driver
import java.sql.Connection
import javax.sql.DataSource
object ScalaJdbcConnectSelect {
def main(args: Array[String]) {
val driver = "com.simba.spark.jdbc41.Driver" //attach the Spark jar to the Classpath.
val url = "jdbc:spark://field-eng.cloud.databricks.com:443/default;transportMode=http;ssl=true;httpPath=sql/protocolvl/o/0/0911-153027-hopes19";
val username = "token"
val password = "<token-value>" //Token generated from databricks profile page.
var connection:Connection = null
try {
// Create the connection
Class.forName(driver)
connection = DriverManager.getConnection(url, username, password)
if(connection != null){
println("Connection Established");
}
else {
println("Connection Failed");
}
// create the statement
val statement = connection.createStatement()
val resultSet = statement.executeQuery("<<Query>") // Profile your query here.
while ( resultSet.next() ) {
// Iterate through Result set
}
catch {
case e => e.printStackTrace
}
connection.close()
}
}
推荐阅读
- ruby-on-rails - 如何使用集合选择为嵌套属性设置表单?
- python - Python - 为什么多线程不能提高我的代码速度?
- sails.js - Sails - Waterline:在哪里可以找到模型属性的完整列表?
- javascript - 来自 webbrowser 中远程控制的事件
- mysql - 创建 TRIGGER 后插入值的问题
- sql - 对postgres数据库索引机制的质疑
- json - Swift Codable - 如何编码和解码字符串化的 JSON 值?
- javascript - 比较两个数组并在未找到项目时创建另一个数组
- haskell - Traversable 和 MonoTraversable 之间有什么区别吗?
- typescript - 如何解决/抑制 IntelliJ 警告,即模拟类未在任何 Angular 模块中声明?