Spring data - 根据之前的插入插入数据
Spring data - insert data depending on previous insert
我需要将数据保存到 2 table 中(一个实体和一个关联 table)。
我只是使用 save()
方法从我的实体存储库中保存我的实体。
然后,为了表现,我需要将行插入 native sql 中的关联 table。这些行引用了我之前保存的实体。
问题来了:我得到一个关于外键的完整性约束异常。在第二次查询中不知道首先保存的实体。
这是我的代码:
回购:
public interface DistributionRepository extends JpaRepository<Distribution, Long>, QueryDslPredicateExecutor<Distribution> {
@Modifying
@Query(value = "INSERT INTO DISTRIBUTION_PERIMETER(DISTRIBUTION_ID, SERVICE_ID) SELECT :distId, p.id FROM PERIMETER p "
+ "WHERE p.id in (:serviceIds) AND p.discriminator = 'SRV' ", nativeQuery = true)
void insertDistributionPerimeter(@Param(value = "distId") Long distributionId, @Param(value = "serviceIds") Set<Long> servicesIds);
}
服务:
@Service
public class DistributionServiceImpl implements IDistributionService {
@Inject
private DistributionRepository distributionRepository;
@Override
@Transactional
public DistributionResource distribute(final DistributionResource distribution) {
// 1. Entity creation and saving
Distribution created = new Distribution();
final Date distributionDate = new Date();
created.setStatus(EnumDistributionStatus.distributing);
created.setDistributionDate(distributionDate);
created.setDistributor(agentRepository.findOne(distribution.getDistributor().getMatricule()));
created.setDocument(documentRepository.findOne(distribution.getDocument().getTechId()));
created.setEntity(entityRepository.findOne(distribution.getEntity().getTechId()));
created = distributionRepository.save(created);
// 2. Association table
final Set<Long> serviceIds = new HashSet<Long>();
for (final ServiceResource sr : distribution.getServices()) {
serviceIds.add(sr.getTechId());
}
// EXCEPTION HERE
distributionRepository.insertDistributionPerimeter(created.getId(), serviceIds);
}
}
这 2 个查询似乎在不同的事务中,而我设置了 @Transactionnal
注释。我还尝试使用 entityManager.createNativeQuery()
执行我的第二个查询并得到相同的结果...
在执行本机查询之前调用 entityManager.flush()
或改用 saveAndFlush
。
根据你的具体情况,我建议使用
created = distributionRepository.saveAndFlush(created);
重要提示:您的 "native" 查询必须使用相同的事务! (或者你现在需要一个事务隔离级别)
您还写道:
I don't really understand why the flush action is not done by default
刷新由 Hibernate 处理(可以配置,默认为 "auto")。这意味着休眠将在任何时间点刷新数据。但始终在您通过 HIBERNATE 提交事务或执行其他 SQL 语句之前。 - 所以通常这没有问题,但在您的情况下,您使用本机查询绕过休眠,因此休眠将不知道此语句,因此它不会刷新其数据。
另见我的这个回答: 关于这个话题
我需要将数据保存到 2 table 中(一个实体和一个关联 table)。
我只是使用 save()
方法从我的实体存储库中保存我的实体。
然后,为了表现,我需要将行插入 native sql 中的关联 table。这些行引用了我之前保存的实体。
问题来了:我得到一个关于外键的完整性约束异常。在第二次查询中不知道首先保存的实体。
这是我的代码:
回购:
public interface DistributionRepository extends JpaRepository<Distribution, Long>, QueryDslPredicateExecutor<Distribution> {
@Modifying
@Query(value = "INSERT INTO DISTRIBUTION_PERIMETER(DISTRIBUTION_ID, SERVICE_ID) SELECT :distId, p.id FROM PERIMETER p "
+ "WHERE p.id in (:serviceIds) AND p.discriminator = 'SRV' ", nativeQuery = true)
void insertDistributionPerimeter(@Param(value = "distId") Long distributionId, @Param(value = "serviceIds") Set<Long> servicesIds);
}
服务:
@Service
public class DistributionServiceImpl implements IDistributionService {
@Inject
private DistributionRepository distributionRepository;
@Override
@Transactional
public DistributionResource distribute(final DistributionResource distribution) {
// 1. Entity creation and saving
Distribution created = new Distribution();
final Date distributionDate = new Date();
created.setStatus(EnumDistributionStatus.distributing);
created.setDistributionDate(distributionDate);
created.setDistributor(agentRepository.findOne(distribution.getDistributor().getMatricule()));
created.setDocument(documentRepository.findOne(distribution.getDocument().getTechId()));
created.setEntity(entityRepository.findOne(distribution.getEntity().getTechId()));
created = distributionRepository.save(created);
// 2. Association table
final Set<Long> serviceIds = new HashSet<Long>();
for (final ServiceResource sr : distribution.getServices()) {
serviceIds.add(sr.getTechId());
}
// EXCEPTION HERE
distributionRepository.insertDistributionPerimeter(created.getId(), serviceIds);
}
}
这 2 个查询似乎在不同的事务中,而我设置了 @Transactionnal
注释。我还尝试使用 entityManager.createNativeQuery()
执行我的第二个查询并得到相同的结果...
在执行本机查询之前调用 entityManager.flush()
或改用 saveAndFlush
。
根据你的具体情况,我建议使用
created = distributionRepository.saveAndFlush(created);
重要提示:您的 "native" 查询必须使用相同的事务! (或者你现在需要一个事务隔离级别)
您还写道:
I don't really understand why the flush action is not done by default
刷新由 Hibernate 处理(可以配置,默认为 "auto")。这意味着休眠将在任何时间点刷新数据。但始终在您通过 HIBERNATE 提交事务或执行其他 SQL 语句之前。 - 所以通常这没有问题,但在您的情况下,您使用本机查询绕过休眠,因此休眠将不知道此语句,因此它不会刷新其数据。
另见我的这个回答: 关于这个话题