数据库Car表数据转对象失败，如何用Java Stream过滤数据？

一、先排查List获取失败的核心原因 #

1. 实体类映射问题 #

• 字段与数据库列名不匹配：若数据库列名是car_brand，实体类是brand，需添加@Column(name = "car_brand")（JPA）或在MyBatis映射中指定列名映射。
• 缺失无参构造函数：ORM框架（JPA/MyBatis）实例化对象时依赖无参构造，必须显式定义。
• 类型不兼容：比如数据库DECIMAL对应JavaBigDecimal而非double，DATE对应LocalDate而非String，避免类型转换失败。

2. DAO/Repository层问题 #

• JPA：确保Repository接口继承JpaRepository<Car, Long>，直接使用自带的findAll()方法，不要自定义错误的查询方法。
• MyBatis：Mapper接口的@Select语句需包含所有实体类字段，或XML映射文件的resultMap配置正确，避免返回字段缺失导致对象实例化失败。

3. 运行时环境问题 #

• 数据库连接配置错误：检查application.yml中的URL、用户名、密码是否正确，确保能连接到目标数据库。
• 事务未开启：若在非事务环境下执行查询，可能导致结果无法正确返回（Spring Boot中默认Service方法是事务性的，但需确保依赖正确）。
• 依赖缺失：确认已引入对应ORM框架的starter依赖，比如JPA的spring-boot-starter-data-jpa，MyBatis的mybatis-spring-boot-starter。

二、完整实现示例 #

方案1：Spring Boot + JPA #

1. 定义Car实体类

import jakarta.persistence.*;

@Entity
@Table(name = "car") // 与数据库表名严格一致
public class Car {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    
    @Column(name = "brand") // 若列名与字段名一致可省略
    private String brand;
    
    private Integer year;
    private String color;

    // 必须存在无参构造
    public Car() {}

    // 全参构造、getter、setter
    public Car(Long id, String brand, Integer year, String color) {
        this.id = id;
        this.brand = brand;
        this.year = year;
        this.color = color;
    }

    // 省略getter和setter，需自行实现
}

2. 定义Repository接口

import org.springframework.data.jpa.repository.JpaRepository;

public interface CarRepository extends JpaRepository<Car, Long> {
    // 继承后自动拥有findAll()、save()等方法
}

3. 服务层获取数据

import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class CarService {
    private final CarRepository carRepository;

    // 构造注入（推荐）
    public CarService(CarRepository carRepository) {
        this.carRepository = carRepository;
    }

    public List<Car> getAllCars() {
        // findAll()返回空List而非null，无需额外判空
        return carRepository.findAll();
    }
}

方案2：Spring Boot + MyBatis #

1. 定义Car实体类

public class Car {
    private Long id;
    private String brand;
    private Integer year;
    private String color;

    // 无参构造、全参构造、getter、setter
}

2. 定义Mapper接口

import org.apache.ibatis.annotations.Select;
import java.util.List;

public interface CarMapper {
    @Select("SELECT id, brand, year, color FROM car")
    List<Car> getAllCars();
}

3. 服务层获取数据

import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class CarService {
    private final CarMapper carMapper;

    public CarService(CarMapper carMapper) {
        this.carMapper = carMapper;
    }

    public List<Car> getAllCars() {
        // 兜底处理：若MyBatis返回null，返回空List
        List<Car> cars = carMapper.getAllCars();
        return cars != null ? cars : List.of();
    }
}

三、Java Stream过滤展示示例 #

以过滤2020年之后生产的红色汽车为例：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.stream.Collectors;

@RestController
public class CarController {
    private final CarService carService;

    public CarController(CarService carService) {
        this.carService = carService;
    }

    @GetMapping("/filtered-cars")
    public List<Car> getFilteredCars() {
        List<Car> allCars = carService.getAllCars();
        
        return allCars.stream()
                // 先判空避免NullPointerException
                .filter(car -> car.getYear() != null && car.getYear() > 2020)
                .filter(car -> "RED".equalsIgnoreCase(car.getColor()))
                .collect(Collectors.toList());
    }
}

四、调试技巧 #

• 开启SQL日志：在application.yml中配置，查看实际执行的SQL语句，确认是否正确查询到数据：

# JPA日志配置
spring:
  jpa:
    show-sql: true
    properties:
      hibernate:
        format_sql: true

# MyBatis日志配置
mybatis:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

• 断点调试：在getAllCars()方法处打断点，检查返回的List是否为空或包含预期数据，定位是查询无结果还是映射失败。

内容的提问来源于stack exchange，提问作者Lucky Patel