我想简单地从数据库获取单向相关的@OneToMany
数据,并为这个数据提供一个反应性的Spring webFlux端点。
但是,我无法摆脱生产代码中的LazyInitializationException。在我的测试方法中,我使用@Transactional并且一切正常。但即使将@Transactional添加到控制器方法也没有任何帮助。
简单样本:
ENTITY2:
@NoArgsConstructor
@AllArgsConstructor
@Data
@Builder
@Entity
public class Entity2 {
@Id
@GeneratedValue
private Integer id;
private String string;
}
ENTITY1:
@NoArgsConstructor
@AllArgsConstructor
@Data
@Builder
@Entity
public class Entity1 {
@Id
@GeneratedValue
private Integer id;
@JsonIgnore
@OneToMany
@JoinTable(
name = "entity1_to_entity2",
joinColumns = {@JoinColumn(name = "entity1_id", referencedColumnName = "id")},
inverseJoinColumns = {@JoinColumn(name = "entity2_id", referencedColumnName = "id")}
)
private List<Entity2> entity2List;
}
SampleService:
@Service
public class SampleService {
private final Entity1Repository entity1Repository;
@Autowired
public SampleService(Entity1Repository entity1Repository) {
this.entity1Repository = entity1Repository;
}
public Optional<Entity1> findEntity1(Integer id) {
return entity1Repository.findById(id);
}
}
SampleComponent:
@Component
public class SampleComponent {
private final SampleService sampleService;
@Autowired
public SampleComponent(SampleService sampleService) {
this.sampleService = sampleService;
}
public List<Entity2> getList(Integer entity1_id) {
return sampleService
.findEntity1(entity1_id)
.map(Entity1::getEntity2List)
.orElse(Collections.emptyList());
}
}
SampleController:
@RestController
public class SampleController {
private final SampleComponent sampleComponent;
@Autowired
public SampleController(SampleComponent sampleComponent) {
this.sampleComponent = sampleComponent;
}
@GetMapping(value = "/endpoint")
@Transactional
public Mono<List<Entity2>> findList(@RequestParam Integer id) {
return Mono.just(sampleComponent.getList(id));
}
}
测试方法:
@Test
@Transactional
public void simpleTest() {
List<Entity2> entity2List = new ArrayList<>();
entity2List.add(Entity2.builder().string("foo").build());
entity2List.add(Entity2.builder().string("bar").build());
entity2Repository.saveAll(entity2List);
Entity1 entity1 = entity1Repository.save(Entity1.builder().entity2List(entity2List).build());
sampleController.findList(entity1.getId())
.subscribe(
list -> list.forEach(System.out::println)
);
}
正如我所说的,从测试方法中删除@Transactrional让测试失败,同样在程序运行时调用端点。
我知道不想在关系上设置fetch.EAGER
,因为我们的所有其他代码都有理由让List<Entity2>
懒散地获取。
编辑:目前我使用@Query
注释方法,我手动join fetch
列表,但在我看来这不是一个普遍的解决方案。
问题在于,由于getEntity2List()
未在您的代码中调用,因此在@Transactional
方法完成后,首次调用它时,延迟加载不再可能。
您可以通过各种方式解决此问题:
getEntity2List()
方法中调用@Transactional
,在仍然可能的情况下触发延迟加载,或者@OneToMany
关系的查询获取实体,或