tencent cloud

jdbc:hive2://{endpoint}:10009/?spark.engine={DataEngineName};spark.resourcegroup={ResourceGroupName};secretkey={SecretKey};secretid={SecretId};region={Region};kyuubi.engine.type=SPARK_SQL;kyuubi.engine.share.level=ENGINE

Class.forName("org.apache.hive.jdbc.HiveDriver");

jdbc:hive2://{endpoint}:10009/?spark.engine={DataEngineName};spark.resourcegroup={ResourceGroupName};secretkey={SecretKey};secretid={SecretId};region={Region};kyuubi.engine.type=SPARK_SQL;kyuubi.engine.share.level=ENGINE
Properties properties = new Properties();
properties.setProperty("user", {AppId});
Connection cnct = DriverManager.getConnection(url, properties);

import org.apache.hive.jdbc.HiveStatement;
import java.sql.*;
import java.util.Properties;

public class TestStandardSpark {
    public static void main(String[] args) throws SQLException {
        try {
            Class.forName("org.apache.hive.jdbc.HiveDriver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return;
        }
        String url = "jdbc:hive2://{endpoint}:10009/?spark.engine={DataEngineName};spark.resourcegroup={ResourceGroupName};secretkey={SecretKey};secretid={SecretId};region={Region};kyuubi.engine.type=SPARK_SQL;kyuubi.engine.share.level=ENGINE";
        Properties properties = new Properties();
        properties.setProperty("user", {AppId});
        Connection connection = DriverManager.getConnection(url, properties);
        HiveStatement statement = (HiveStatement) connection.createStatement();
        String sql = "SELECT * FROM dlc_test LIMIT 100";
        statement.execute(sql);
        ResultSet rs = statement.getResultSet();
        while (rs.next()) {
            System.out.println(rs.getInt(1) + ":" + rs.getString(2));
        }
        rs.close();
        statement.close();
        connection.close();
}
}