通过JDBC连接到Serverless StarRocks实例,您可以享受到跨平台的统一数据接入体验,并显著简化应用程序的集成流程。本文为您介绍如何使用JDBC方式连接Serverless StarRocks实例。
前提条件
已创建Serverless StarRocks实例,详情请参见创建实例。
操作步骤
添加依赖至pom.xml。
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.47</version> </dependency>
说明mysql-connector-java
为MySQL Driver版本,请根据实际情况修改。连接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>/<database>
,其中涉及参数如下:<FE地址>
:Serverless StarRocks实例中FE的内网地址。您可以在实例详情页面的FE详情区域查看。<fe_http_port>
:Serverless StarRocks实例中FE的查询端口(默认为9030)。您可以在实例详情页面的FE详情区域查看。<database>
:Serverless StarRocks实例中的数据库名称。
USER
数据库的用户名。
PASSWORD
数据库的密码。
相关文档
您可以通过Serverless StarRocks提供的SQL Editor直接在Web界面编写、执行和管理SQL查询,以便高效地操作StarRocks实例,详情请参见通过SQL Editor操作StarRocks实例。
文档内容是否对您有帮助?