如何使用spring boot建立Microsoft azure databricks delta tables的连接,就像mysql、sql server一样。

2 人关注

嗨,我想在我的spring boot应用程序中与Microsoft azure databricks delta表建立连接。我有delta表的集群网址、用户名和密码(token),我需要从它那里获取数据到我的应用程序。请告诉我这个问题的一些情况

azure
databricks
azure-databricks
delta-lake
Rishi
Rishi
发布于 2021-05-17
1 个回答
Alex Ott
Alex Ott
发布于 2021-05-17
0 人赞同

你可以使用JDBC访问集群和底层表(见 文档 )。 你需要获得相应的驱动程序,并将其添加到你的应用程序中,然后只需使用正常的 JDBC API ,像这样。

String jdbcConnectPassthroughCluster = "jdbc:spark://<server-hostname>:443/default;transportMode=http;ssl=1;httpPath=sql/protocolv1/o/0/xxxx-xxxxxx-xxxxxxxx;AuthMech=3;UID=token;PWD=";
String PATH = "<personal token>"
String JDBC_DRIVER = "com.simba.spark.jdbc.Driver";
String DB_URL = jdbcConnectPassthroughCluster + PAT;
Class.forName(JDBC_DRIVER);
System.out.println("Getting connection");
Connection conn = DriverManager.getConnection(DB_URL);
Statement stmt = conn.createStatement();
System.out.println("Going to execute query");
ResultSet rs = stmt.executeQuery("select * from table");
System.out.println("Query is executed");
int i = 0;
while(rs.next()) {
    System.out.println("Row " + i + "=" + rs.getLong(1));