spring - Hibernate 不会在重复时抛出异常
问题描述
大家好,我正在尝试实现基本的 CRUD 功能,但困扰我的是 CrudRepository 在保存重复实体时没有抛出任何异常,你能告诉我我在这里缺少什么吗?
我无法通过的测试如下:
@Test
void onDuplicate() {
ReviewEntity duplicated = savedReviewEntity;
assertEquals(savedReviewEntity.getId(), duplicated.getId());
assertThrows(DataIntegrityViolationException.class, () -> {
reviewRepository.save(duplicated);
});
}
这是实体的样子:
@NoArgsConstructor
@AllArgsConstructor
@Builder
@Getter
@Setter
@Entity
@Table(name = "reviews", indexes = { @Index(name = "reviews_unique_idx", unique = true, columnList = "movieId,reviewId") })
public class ReviewEntity {
@Id
@GeneratedValue
private Integer id;
@Version
private Integer version;
private Integer movieId;
private Integer reviewId;
private String author;
private String subject;
private String content;
private String serviceAddress;
}
我正在使用 CrudRepository
public interface ReviewRepository extends CrudRepository<ReviewEntity, Integer> {
@Transactional(readOnly = true)
List<ReviewEntity> findByMovieId(int movieId);
}
我想看看整个测试类,它看起来像:
@ExtendWith(SpringExtension.class)
@DataJpaTest
@Transactional(propagation = NOT_SUPPORTED)
class ReviewRepositoryTest {
public static final int BASE_MOVIE_ID = 1;
public static final int BASE_REVIEW_ID = 2;
@Autowired
ReviewRepository reviewRepository;
ReviewEntity savedReviewEntity;
@Autowired
EntityManager entityManager;
@BeforeEach
void setUp() {
reviewRepository.deleteAll();
ReviewEntity reviewEntity = ReviewEntity.builder()
.movieId(BASE_MOVIE_ID)
.reviewId(BASE_REVIEW_ID)
.author("Fake Author")
.content("Fake Content")
.subject("Fake Subject")
.serviceAddress("Fake Service Address")
.build();
savedReviewEntity = reviewRepository.save(reviewEntity);
assertReview(reviewEntity, savedReviewEntity);
}
@Test
void create() {
reviewRepository.deleteAll();
ReviewEntity reviewEntity = ReviewEntity.builder()
.movieId(BASE_MOVIE_ID)
.reviewId(BASE_REVIEW_ID)
.author("Fake Author")
.content("Fake Content")
.subject("Fake Subject")
.serviceAddress("Fake Service Address")
.build();
ReviewEntity saved = reviewRepository.save(reviewEntity);
assertReview(reviewEntity, saved);
}
@Test
void update() {
String updatedContent = "Updated Content";
savedReviewEntity.setContent(updatedContent);
reviewRepository.save(savedReviewEntity);
ReviewEntity updated = reviewRepository.findById(savedReviewEntity.getId()).get();
assertEquals(updatedContent, updated.getContent());
}
@Test
void delete() {
reviewRepository.delete(savedReviewEntity);
assertEquals(0, reviewRepository.count());
}
@Test
void findByMovieId() {
List<ReviewEntity> reviewEntities = reviewRepository.findByMovieId(savedReviewEntity.getMovieId());
ReviewEntity firstEntity = reviewEntities.get(0);
assertThat(reviewEntities, hasSize(1));
assertReview(savedReviewEntity, firstEntity);
}
@Test
void onDuplicate() {
ReviewEntity duplicated = savedReviewEntity;
assertEquals(savedReviewEntity.getId(), duplicated.getId());
assertThrows(DataIntegrityViolationException.class, () -> {
reviewRepository.save(duplicated);
});
}
@Test
void optimisticLockVerification() {
String r1ConcurrentContent = "r1ConcurrentContent";
String r2ConcurrentContent = "r2ConcurrentContent";
ReviewEntity r1 = reviewRepository.findById(savedReviewEntity.getId()).get();
ReviewEntity r2 = reviewRepository.findById(savedReviewEntity.getId()).get();
r1.setContent(r1ConcurrentContent);
reviewRepository.save(r1);
try {
r2.setContent(r2ConcurrentContent);
reviewRepository.save(r2);
fail("Expected an OptimisticLockingFailureException");
} catch (OptimisticLockingFailureException e) {
System.out.println("OptimisticLockingFailureException should be throw.");
}
ReviewEntity updated = reviewRepository.findById(savedReviewEntity.getId()).get();
assertEquals(1, (int) updated.getVersion());
assertEquals(r1ConcurrentContent, updated.getContent());
}
private void assertReview(ReviewEntity expected, ReviewEntity actual) {
assertAll("Executing assertReview(..)", () -> {
assertEquals(expected.getId(), actual.getId());
assertEquals(expected.getVersion(), actual.getVersion());
assertEquals(expected.getMovieId(), actual.getMovieId());
assertEquals(expected.getReviewId(), actual.getReviewId());
assertEquals(expected.getContent(), actual.getContent());
assertEquals(expected.getAuthor(), actual.getAuthor());
assertEquals(expected.getSubject(), actual.getSubject());
assertEquals(expected.getServiceAddress(), actual.getServiceAddress());
});
}
}
解决方案
当数据库中的插入或更新违反任何完整性约束时,将引发DataIntegrityViolationException 。在您的方法中,您试图用自身覆盖表中的条目,这不会造成任何此类违规。Hibernate 不会在表中创建任何新条目,它只是更新它(这里使用相同的对象,因为没有更改)。
推荐阅读
- javascript - 自动循环浏览 GeoMap 中的工具提示
- salesforce - SalesForce DataLoader CLI 无法加载 JDBC 驱动程序
- video - 使用 gstreamer 通过树莓派流式传输 RTSP。无法输出音频
- opencv - OpenCV 网格板姿态检测不正确
- apache-flink - 使用 Python 的 Apache Beam ReadFromKafka 在 Flink 中运行,但没有发布的消息通过
- css - CSS Grid > 如何让侧栏变得流畅?
- docker - 使用 nuget.config 恢复 Jenkins 包
- python - Python-pptx 与 LibreOffice 中的文本框的兼容性
- windows - Mac 和 PC 之间的通用文件夹名称和路径
- spring - Spring Boot 上的 Swagger:文档仅在 localhost 上可见