LAS JDBC访问

大数据数据中台技术服务知识库
问题描述

在 LAS 的“生态连接”中,提供了 JDBC 的访问方式( 可参考:https://www.volcengine.com/docs/6492/101901 ),下游可以通过 BI 产品工具对 LAS 中的库表数据进行访问。 本文将提供该场景的使用样例。

问题分析

本文将以 Java 程序为例,说明 LAS JDBC 访问的具体配置、代码、流程。 本文中使用了库名为 demo,表名为 student 的样例数据,具体的建表语句为:

CREATE TABLE `demo`.`student`( 
`id` INT COMMENT 'id', 
`name` STRING COMMENT 'name', 
`subject` STRING COMMENT 'subject', 
`score` INT COMMENT 'score') 
PARTITIONED BY (`create_date` STRING COMMENT '创建日期')

并在该表中插入了一些测试数据: 图片

解决方案

开启 LAS 公网访问,并配置访问规则 图片

代码编写,以下为参考代码:

Properties properties = new Properties();
properties.setProperty("user", "替换您的AK");
properties.setProperty("password", "替换您的SK");
String url = "jdbc:presto://替换您的公网IP:8080/cn_beijing";
Connection connection = DriverManager.getConnection(url, properties);
Statement statement = connection.createStatement();
try {
    ResultSet rs = statement.executeQuery("select * from demo.student where create_date = '20221214' limit 10");
    while (rs.next()) {
        String id = rs.getString(1);
        String name = rs.getString(2);
        String subject = rs.getString(3);
        String score = rs.getString(4);
        String create_date = rs.getString(5);
        System.out.println(String.format("%s %s %s %s %s", id, name, subject, score, create_date));
    }
} catch (Exception e) {
    e.printStackTrace();
} finally {
    statement.close();
    connection.close();
}

截止2023-6,JDBC仅支持SELECT语句,其他DDL语句(CREATE / UPDATE等)暂不支持。

以上案例的查询结果如下: 图片

如果您有其他问题,欢迎您联系火山引擎技术支持服务

41
0
0
0
相关产品
评论
未登录
看完啦,登录分享一下感受吧~
暂无评论