Apache Doris JDBC终极指南：5步实现Java应用高效集成

怀琪茵Crown

575人浏览 · 2026-04-16 08:25:23

怀琪茵Crown · 2026-04-16 08:25:23 发布

Apache Doris JDBC终极指南：5步实现Java应用高效集成

【免费下载链接】doris Apache Doris is an easy-to-use, high performance and unified analytics database. 项目地址: https://gitcode.com/gh_mirrors/dori/doris

Apache Doris是一款易用、高性能的统一分析型数据库，通过JDBC驱动可以轻松实现与Java应用的高效集成。本文将详细介绍如何通过5个简单步骤完成Apache Doris的JDBC集成，帮助开发者快速上手这一强大的分析型数据库。

1. 准备Doris JDBC环境

1.1 下载Doris JDBC驱动

Doris JDBC驱动通常随发行版提供，也可以通过Maven仓库获取。建议使用最新版本以获得最佳兼容性和性能。驱动文件一般命名为doris-jdbc-driver-<version>.jar，可以在Doris官方发布渠道找到。

1.2 项目依赖配置

在Java项目的pom.xml中添加Doris JDBC驱动依赖：

<dependency>
    <groupId>org.apache.doris</groupId>
    <artifactId>doris-jdbc-driver</artifactId>
    <version>1.2.0</version>
</dependency>

如果使用Gradle构建项目，添加以下依赖：

implementation 'org.apache.doris:doris-jdbc-driver:1.2.0'

2. 配置Doris连接信息

2.1 理解JDBC URL格式

Doris JDBC连接URL的基本格式如下：

jdbc:mysql://<host>:<port>/<database>?user=<username>&password=<password>

<host>: Doris FE节点的IP地址或主机名
<port>: Doris FE的查询端口，默认为9030
<database>: 要连接的数据库名称
<username>: 数据库用户名
<password>: 数据库密码

2.2 配置连接参数

除了基本连接信息外，还可以配置一些高级参数优化连接性能：

Properties properties = new Properties();
properties.put("user", "root");
properties.put("password", "");
properties.put("useSSL", "false");
properties.put("serverTimezone", "UTC");
properties.put("characterEncoding", "UTF-8");

3. 创建JDBC连接

3.1 编写连接代码

使用DriverManager类创建Doris数据库连接：

String url = "jdbc:mysql://localhost:9030/test_db";
Connection conn = DriverManager.getConnection(url, "root", "");

3.2 验证连接是否成功

通过执行简单的SQL语句验证连接是否正常：

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT version()");
if (rs.next()) {
    System.out.println("Doris version: " + rs.getString(1));
}

4. 实现数据操作

4.1 执行查询操作

使用Statement或PreparedStatement执行查询：

PreparedStatement pstmt = conn.prepareStatement("SELECT id, name FROM users WHERE age > ?");
pstmt.setInt(1, 18);
ResultSet rs = pstmt.executeQuery();
while (rs.next()) {
    System.out.println("ID: " + rs.getInt("id") + ", Name: " + rs.getString("name"));
}

4.2 执行插入、更新和删除操作

// 插入数据
PreparedStatement insertStmt = conn.prepareStatement("INSERT INTO users (id, name, age) VALUES (?, ?, ?)");
insertStmt.setInt(1, 1001);
insertStmt.setString(2, "John Doe");
insertStmt.setInt(3, 25);
int rowsInserted = insertStmt.executeUpdate();
System.out.println("Rows inserted: " + rowsInserted);

// 更新数据
PreparedStatement updateStmt = conn.prepareStatement("UPDATE users SET age = ? WHERE id = ?");
updateStmt.setInt(1, 26);
updateStmt.setInt(2, 1001);
int rowsUpdated = updateStmt.executeUpdate();
System.out.println("Rows updated: " + rowsUpdated);

// 删除数据
PreparedStatement deleteStmt = conn.prepareStatement("DELETE FROM users WHERE id = ?");
deleteStmt.setInt(1, 1001);
int rowsDeleted = deleteStmt.executeUpdate();
System.out.println("Rows deleted: " + rowsDeleted);

4.3 使用事务

Doris支持事务操作，可以通过以下方式管理事务：

try {
    conn.setAutoCommit(false);
    // 执行多个SQL操作
    // ...
    conn.commit();
} catch (SQLException e) {
    conn.rollback();
    e.printStackTrace();
} finally {
    conn.setAutoCommit(true);
}

5. 集成Spring框架（可选）

5.1 Spring JDBC配置

在Spring项目中，可以通过配置DataSource来集成Doris JDBC：

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:9030/test_db" />
    <property name="username" value="root" />
    <property name="password" value="" />
</bean>

5.2 Spring Boot集成

在Spring Boot项目中，只需在application.properties中添加以下配置：

spring.datasource.url=jdbc:mysql://localhost:9030/test_db
spring.datasource.username=root
spring.datasource.password=
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

5.3 Spring JDBC示例项目结构

以下是一个典型的Spring JDBC集成Doris的项目结构：

示例：查询数据并返回JSON结果

下面是一个完整的示例，展示如何通过JDBC查询Doris数据并以JSON格式返回：

@RestController
@RequestMapping("/rest/demo")
public class DemoController {
    
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    @GetMapping("/skulist")
    public List<Map<String, Object>> getSkuList() {
        return jdbcTemplate.queryForList("SELECT * FROM sku_info");
    }
    
    @GetMapping("/skulist/{id}")
    public Map<String, Object> getSkuById(@PathVariable int id) {
        return jdbcTemplate.queryForMap("SELECT * FROM sku_info WHERE id = ?", id);
    }
}

查询所有商品信息的结果：