当前位置：首页 > news >正文

Spring Boot 2.x + MyBatis 连接 Doris 数据库保姆级教程（附完整项目源码）

news 2026/4/20 4:23:39

Spring Boot 2.x + MyBatis 连接 Doris 数据库实战指南

在当今数据驱动的时代，企业级应用对实时分析能力的需求日益增长。Apache Doris作为一款高性能的MPP分析型数据库，凭借其出色的实时分析能力和与MySQL协议的兼容性，正成为越来越多Java开发者的选择。本文将带你从零开始，在Spring Boot 2.2.0项目中整合Doris数据库，构建一个完整的RESTful数据查询服务。

1. 环境准备与项目初始化

1.1 Doris数据库基础配置

在开始Spring Boot项目之前，我们需要确保Doris集群已正确部署并运行。Doris采用FE（Frontend）和BE（Backend）的架构设计，至少需要配置一个FE节点和一个BE节点。

-- 创建测试数据库 CREATE DATABASE demo_db; -- 创建测试表 CREATE TABLE `user_behavior` ( `user_id` BIGINT NULL COMMENT "用户ID", `item_id` BIGINT NULL COMMENT "商品ID", `behavior_type` VARCHAR(20) NULL COMMENT "行为类型", `timestamp` DATETIME NULL COMMENT "时间戳" ) ENGINE=OLAP DUPLICATE KEY(`user_id`, `item_id`) COMMENT "用户行为分析表" DISTRIBUTED BY HASH(`user_id`) BUCKETS 8 PROPERTIES ( "replication_num" = "3", "storage_format" = "V2" );

1.2 Spring Boot项目初始化

使用Spring Initializr创建一个基础项目，选择以下依赖：

Spring Web
MyBatis Framework
Lombok

或者手动在pom.xml中添加以下核心依赖：

<dependencies> <!-- Spring Boot Starter Web --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- MyBatis Spring Boot Starter --> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.4</version> </dependency> <!-- MySQL Connector --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.23</version> </dependency> <!-- Druid连接池 --> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.2.6</version> </dependency> <!-- Lombok --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> </dependencies>

2. 数据源配置与MyBatis集成

2.1 配置Doris数据源

Doris兼容MySQL协议，这使得我们可以直接使用MySQL的JDBC驱动来连接Doris。在application.yml中配置数据源：

spring: datasource: type: com.alibaba.druid.pool.DruidDataSource driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://your-doris-fe-host:9030/demo_db?useSSL=false&serverTimezone=UTC username: root password: druid: initial-size: 5 min-idle: 5 max-active: 20 max-wait: 60000 time-between-eviction-runs-millis: 60000 min-evictable-idle-time-millis: 300000 validation-query: SELECT 1 test-while-idle: true test-on-borrow: false test-on-return: false mybatis: mapper-locations: classpath:mapper/*.xml type-aliases-package: com.example.doris.model configuration: map-underscore-to-camel-case: true

2.2 实体类与Mapper接口设计

创建对应的实体类和Mapper接口：

@Data @NoArgsConstructor @AllArgsConstructor public class UserBehavior { private Long userId; private Long itemId; private String behaviorType; private LocalDateTime timestamp; }

Mapper接口定义：

@Mapper public interface UserBehaviorMapper { List<UserBehavior> selectByTimeRange(@Param("startTime") LocalDateTime startTime, @Param("endTime") LocalDateTime endTime); @Select("SELECT behavior_type, COUNT(*) as count FROM user_behavior " + "WHERE timestamp BETWEEN #{startTime} AND #{endTime} " + "GROUP BY behavior_type") List<BehaviorCount> countByBehaviorType(@Param("startTime") LocalDateTime startTime, @Param("endTime") LocalDateTime endTime); }

3. MyBatis XML映射文件编写

在resources/mapper目录下创建UserBehaviorMapper.xml：

<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.example.doris.mapper.UserBehaviorMapper"> <resultMap id="BaseResultMap" type="UserBehavior"> <result column="user_id" property="userId" /> <result column="item_id" property="itemId" /> <result column="behavior_type" property="behaviorType" /> <result column="timestamp" property="timestamp" /> </resultMap> <select id="selectByTimeRange" resultMap="BaseResultMap"> SELECT user_id, item_id, behavior_type, timestamp FROM user_behavior WHERE timestamp BETWEEN #{startTime} AND #{endTime} ORDER BY timestamp DESC </select> </mapper>

4. 业务层与控制器实现

4.1 服务层实现

@Service @RequiredArgsConstructor public class UserBehaviorService { private final UserBehaviorMapper userBehaviorMapper; public List<UserBehavior> getUserBehaviors(LocalDateTime startTime, LocalDateTime endTime) { return userBehaviorMapper.selectByTimeRange(startTime, endTime); } public List<BehaviorCount> getBehaviorStatistics(LocalDateTime startTime, LocalDateTime endTime) { return userBehaviorMapper.countByBehaviorType(startTime, endTime); } }

4.2 RESTful API控制器

@RestController @RequestMapping("/api/behavior") @RequiredArgsConstructor public class UserBehaviorController { private final UserBehaviorService userBehaviorService; @GetMapping("/list") public ResponseEntity<List<UserBehavior>> listBehaviors( @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime start, @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime end) { return ResponseEntity.ok(userBehaviorService.getUserBehaviors(start, end)); } @GetMapping("/stats") public ResponseEntity<List<BehaviorCount>> getBehaviorStats( @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime start, @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime end) { return ResponseEntity.ok(userBehaviorService.getBehaviorStatistics(start, end)); } }

5. 高级配置与性能优化

5.1 Doris特有的JDBC参数优化

为了获得更好的性能，可以在JDBC URL中添加Doris特有的参数：

spring: datasource: url: jdbc:mysql://your-doris-fe-host:9030/demo_db?useSSL=false&serverTimezone=UTC&doris.query.timeout=300&doris.request.retries=3

5.2 MyBatis批量操作优化

Doris支持高效的批量插入操作，可以通过MyBatis的批量模式来提升性能：

@Mapper public interface UserBehaviorMapper { @Insert("<script>" + "INSERT INTO user_behavior (user_id, item_id, behavior_type, timestamp) VALUES " + "<foreach collection='list' item='item' separator=','>" + "(#{item.userId}, #{item.itemId}, #{item.behaviorType}, #{item.timestamp})" + "</foreach>" + "</script>") int batchInsert(@Param("list") List<UserBehavior> behaviors); }

5.3 连接池监控配置

启用Druid连接池的监控功能：

spring: datasource: druid: stat-view-servlet: enabled: true url-pattern: /druid/* login-username: admin login-password: admin web-stat-filter: enabled: true url-pattern: /* exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"

6. 常见问题排查

6.1 连接超时问题

如果遇到连接超时，可以检查以下几点：

确认FE节点的9030端口是否开放
检查Doris的FE日志是否有异常
适当增加JDBC连接超时参数

6.2 查询性能优化

对于复杂查询，可以考虑：

在Doris中合理设计分区和分桶策略
使用物化视图预计算常用查询
为常用查询条件创建合适的索引

6.3 数据类型映射

Doris与MySQL数据类型存在一些差异，需要注意：

Doris的DECIMAL精度与MySQL有所不同
日期时间类型的处理需要特别注意时区设置
VARCHAR长度限制在Doris中更为严格

7. 完整项目结构与部署

一个典型的Spring Boot集成Doris的项目结构如下：

src/main/java ├── com.example.doris │ ├── config │ ├── controller │ ├── model │ ├── mapper │ ├── service │ └── DorisApplication.java src/main/resources ├── application.yml ├── mapper │ └── UserBehaviorMapper.xml

部署时需要注意：