产品文档

实时数据仓库StarRocks版

2025-02-06 05:56:41

您可以通过JDBC连接到StarRocks实例。本文为您介绍如何使用JDBC方式连接StarRocks实例。

前置依赖

已创建StarRocks实例,同时StarRocks实例的状态为运行中

操作步骤

1、添加依赖至pom.xml

<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.47</version>
</dependency>

说明
mysql-connector-java为MySQL Driver版本,请根据实际情况修改。

2、连接StarRocks实例,示例代码如下:

 public class ConnStarRocks {
    /**连接MySQL数据库
	1、加载驱动程序
	2、数据库连接字符串"jdbc:mysql://localhost:9030/数据库名?"
	3、数据库登录名
	4、数据库登录密码
	**/	
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
static final String DB_URL = "jdbc:mysql://localhost:9030/yourDatabaseName?useSSL=false&serverTimezone=UTC";
    /**数据库的用户名与密码,需要根据实际情况设置。**/
    static final String USER = "****";
    static final String PASSWORD = "1234*****";

    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try{
            // 注册JDBC驱动。
            Class.forName(JDBC_DRIVER);

            // 建立数据库连接。
            System.out.println("连接数据库...");
            conn = DriverManager.getConnection(DB_URL,USER,PASSWORD);

            // 创建Statement对象执行查询。
            System.out.println(" 实例化Statement对象...");
            stmt = conn.createStatement();
            String sql;
            sql = "SELECT id, name, url FROM websites";
            //获取查询结果集。
            ResultSet rs = stmt.executeQuery(sql);
            
            // 完成后关闭。
            rs.close();
            stmt.close();
            conn.close();
        }catch(SQLException se){
            // 处理JDBC错误。
            se.printStackTrace();
        }catch(Exception e){
            // 处理Class.forName错误。
            e.printStackTrace();
        }finally{
            // 关闭资源。
            if(stmt!=null) {
              stmt.close();
            }
            if(conn!=null) {
              conn.close();
            }
        }
        System.out.println("Goodbye!");
    }	
}

涉及参数如下表所示。

参数 说明
JDBC_DRIVER 数据库连接的JDBC驱动。例如,com.mysql.jdbc.Driver。
DB_URL 数据库连接字符串,用于在StarRocks中执行查询操作
格式为jdbc:mysql://<FE地址>:<fe_http_port>/,其中涉及参数如下:

<FE地址>:Serverless StarRocks实例中FE的内网地址。您可以在实例详情页面的FE详情区域查看。

<fe_http_port>:Serverless StarRocks实例中FE的查询端口(默认为9030)。您可以在实例详情页面的FE详情区域查看。

Serverless StarRocks实例中的数据库名称
USER 数据库的自定义实例用户名称
PASSWORD 自定义实例用户的登录密码
文档反馈

开始与售前顾问沟通

可直接拨打电话 400-098-8505转1

我们的产品专家为您找到最合适的产品/解决⽅案

在线咨询 5*8⼩时

1v1线上咨询获取售前专业咨询

点击咨询
企微服务助手

专业产品顾问,随时随地沟通