java连接starrocks
时间: 2024-06-14 17:05:45 浏览: 3
Java连接StarRocks可以使用JDBC(Java Database Connectivity)来实现。以下是一个简单的示例代码:
```java
import java.sql.*;
public class StarRocksJDBCExample {
public static void main(String[] args) {
// JDBC连接信息
String url = "jdbc:mysql://<starrocks_host>:<starrocks_port>/<database_name>";
String user = "<username>";
String password = "<password>";
// 加载JDBC驱动
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
return;
}
// 建立连接
Connection conn = null;
try {
conn = DriverManager.getConnection(url, user, password);
// 执行查询
Statement stmt = conn.createStatement();
String sql = "SELECT * FROM <table_name>";
ResultSet rs = stmt.executeQuery(sql);
// 处理结果集
while (rs.next()) {
// 获取每一行的数据
int id = rs.getInt("id");
String name = rs.getString("name");
// 其他字段...
// 打印数据
System.out.println("id: " + id + ", name: " + name);
}
// 关闭结果集和语句
rs.close();
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭连接
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
```
请注意,您需要将`<starrocks_host>`、`<starrocks_port>`、`<database_name>`、`<username>`、`<password>`和`<table_name>`替换为实际的StarRocks连接信息和查询信息。
相关推荐
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)