我想在 sprint boot 中使用 simba.spark.jdbc 驱动程序通过令牌连接到 databricks

发布于 2025-01-10 14:59:29 字数 144 浏览 0 评论 0原文

想要在Spring Boot中使用simba Spark jdbc驱动程序通过令牌连接到数据块这样我就可以利用“JDBC”样板代码上的代码并使用行映射器，并可以从数据块数据库中获取数据，连接到数据块时的用户和密码是什么使用令牌的数据库，因为没有用户和密码。欢迎参考或代码

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

辞旧 2025-01-17 14:59:29

您只需设置用户名和名称即可。明确密码 - 只需提供 URL。这是一个使用 Databricks SQL 端点的简单工作示例（完整示例为这里）：

String host = "adb-123.11.azuredatabricks.net";
String httpPath = "/sql/1.0/endpoints/...";
String token = "your_token";
String query = "select count(1) from default.table";

String jdbcUrl = "jdbc:spark://" + host + 
   ":443/default;transportMode=http;ssl=1;httpPath=" +
   httpPath + ";AuthMech=3;UID=token;PWD=" + token;

SimpleDriverDataSource ds = new SimpleDriverDataSource();
ds.setDriver(new Driver());
ds.setUrl(jdbcUrl);

JdbcTemplate jdbcTemplate = new JdbcTemplate(ds);
int numRows = jdbcTemplate.queryForObject(query, Integer.class);

You just not need to set username & password explicitly - just provide URL. Here is a simple working example that uses Databricks SQL endpoint (full example is here):

String host = "adb-123.11.azuredatabricks.net";
String httpPath = "/sql/1.0/endpoints/...";
String token = "your_token";
String query = "select count(1) from default.table";

String jdbcUrl = "jdbc:spark://" + host + 
   ":443/default;transportMode=http;ssl=1;httpPath=" +
   httpPath + ";AuthMech=3;UID=token;PWD=" + token;

SimpleDriverDataSource ds = new SimpleDriverDataSource();
ds.setDriver(new Driver());
ds.setUrl(jdbcUrl);

JdbcTemplate jdbcTemplate = new JdbcTemplate(ds);
int numRows = jdbcTemplate.queryForObject(query, Integer.class);

回复收藏 0 原文

~没有更多了~