Spring Boot 2.26 + MyBatis + Apache Hudi 0.12 + Hive 3.1.2: 使用 Java 操作 Hudi 实现增删改查

Spring Boot 2.26 + MyBatis + Apache Hudi 0.12 + Hive 3.1.2: 使用 Java 操作 Hudi 实现增删改查

本教程演示如何在 Spring Boot 2.26 中结合 MyBatis、Apache Hudi 0.12 和 Hive 3.1.2，使用 Java 代码实现 Hudi 数据表的增删改查操作。

步骤：

1. 配置 Hudi 数据源:

   在 application.yaml 文件中配置 Hudi 数据源，示例代码如下：

   spring:
     datasource:
       url: jdbc:hive2://localhost:10000/default
       driver-class-name: org.apache.hive.jdbc.HiveDriver
   hudi:
     datasource:
       url: jdbc:hive2://localhost:10000/default
       driver-class-name: org.apache.hive.jdbc.HiveDriver
   

2. 创建 Hudi 数据模型:

   定义一个 Java 类来表示 Hudi 数据表中的数据结构，示例代码如下：

   @Data
   @NoArgsConstructor
   @AllArgsConstructor
   @Builder
   public class User {
       private String id;
       private String name;
       private int age;
       private String city;
   }
   

3. 创建 Hudi 的 Mapper 接口:

   使用 MyBatis 定义 Mapper 接口，并编写 SQL 语句实现增删改查操作，示例代码如下：

   @Mapper
   public interface UserMapper {
       @Insert("insert into user values(#{id},#{name},#{age},#{city})")
       void insert(User user);
   
       @Update("update user set name=#{name},age=#{age},city=#{city} where id=#{id}")
       void update(User user);
   
       @Delete("delete from user where id=#{id}")
       void delete(String id);
   
       @Select("select * from user where id=#{id}")
       User selectById(String id);
   }
   

4. 创建 Hudi 的 Service:

   编写 Service 类，调用 Mapper 接口的方法，实现业务逻辑，示例代码如下：

   @Service
   public class UserService {
       @Autowired
       private UserMapper userMapper;
   
       public void insert(User user) {
           userMapper.insert(user);
       }
   
       public void update(User user) {
           userMapper.update(user);
       }
   
       public void delete(String id) {
           userMapper.delete(id);
       }
   
       public User selectById(String id) {
           return userMapper.selectById(id);
       }
   }
   

5. 创建 Hudi 的 Controller:

   编写 Controller 类，接收 HTTP 请求，调用 Service 方法，并将结果返回给客户端，示例代码如下：

   @RestController
   @RequestMapping("/user")
   public class UserController {
       @Autowired
       private UserService userService;
   
       @PostMapping("/add")
       public void add(@RequestBody User user) {
           userService.insert(user);
       }
   
       @PostMapping("/update")
       public void update(@RequestBody User user) {
           userService.update(user);
       }
   
       @PostMapping("/delete")
       public void delete(@RequestParam("id") String id) {
           userService.delete(id);
       }
   
       @GetMapping("/get")
       public User get(@RequestParam("id") String id) {
           return userService.selectById(id);
       }
   }
   

6. 启动 Spring Boot 应用程序:

   运行 Spring Boot 应用程序，访问以下 URL 进行测试：

   • http://localhost:8080/user/add: 新增数据
   • http://localhost:8080/user/update: 修改数据
   • http://localhost:8080/user/delete: 删除数据
   • http://localhost:8080/user/get: 查询数据

   通过这些接口，您可以对 Hudi 数据表进行增删改查操作。