数据湖探索 DLI-java样例代码:通过SQL API 访问数据源

时间:2025-02-17 15:19:41

通过SQL API 访问数据源

  1. 创建 DLI 跨源访问DWS的关联表,填写连接参数。
    1
    sparkSession.sql("CREATE TABLE IF NOT EXISTS dli_to_dws USING JDBC OPTIONS ('url'='jdbc:postgresql://10.0.0.233:8000/postgres','dbtable'='test','user'='dbadmin','password'='**')");
    
  2. 插入数据
    1
    sparkSession.sql("insert into dli_to_dws values(3,'Liu'),(4,'Xie')");
    
  3. 查询数据
    1
    sparkSession.sql("select * from dli_to_dws").show();
    

    插入数据后:

support.huaweicloud.com/devg-dli/dli_09_0199.html