数据湖探索 DLI-java样例代码:完整示例代码

时间：2024-11-16 13:16:39

数据湖探索 DLI 对接DWS

完整示例代码

通过SQL API 访问DWS表

import org.apache.spark.sql.SparkSession;
 
public class java_dws {
    public static void main(String[] args) {
        SparkSession sparkSession = SparkSession.builder().appName("datasource-dws").getOrCreate();
 
        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'='**')");
 
        //*****************************SQL model***********************************
        //Insert data into the  DLI  data table
        sparkSession.sql("insert into dli_to_dws values(3,'Liu'),(4,'Xie')");
 
        //Read data from DLI data table
        sparkSession.sql("select * from dli_to_dws").show();
 
        //drop table
        sparkSession.sql("drop table dli_to_dws");
 
        sparkSession.close();
    }
}

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

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