您可以通过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 | 自定义实例用户的登录密码 |
我们的产品专家为您找到最合适的产品/解决⽅案
1v1线上咨询获取售前专业咨询
专业产品顾问,随时随地沟通