Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HHH-16810 Add test for issue

This commit is contained in:
Andrea Boriero 2023-07-03 17:51:15 +02:00
parent 90bb46a465
commit 59ee9a9eb6
1 changed files with 211 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

211
hibernate-core/src/test/java/org/hibernate/orm/test/locking/CompositeIdBatchDeletionTest.java Normal file
View File

@ -0,0 +1,211 @@
package org.hibernate.orm.test.locking;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import org.hibernate.annotations.DynamicUpdate;
import org.hibernate.annotations.OptimisticLockType;
import org.hibernate.annotations.OptimisticLocking;
import org.hibernate.cfg.AvailableSettings;
import org.hibernate.testing.orm.junit.DomainModel;
import org.hibernate.testing.orm.junit.JiraKey;
import org.hibernate.testing.orm.junit.ServiceRegistry;
import org.hibernate.testing.orm.junit.SessionFactory;
import org.hibernate.testing.orm.junit.SessionFactoryScope;
import org.hibernate.testing.orm.junit.Setting;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.IdClass;
import jakarta.persistence.JoinColumn;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.OneToMany;
import jakarta.persistence.Table;
import static jakarta.persistence.FetchType.LAZY;
import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
@DomainModel(
annotatedClasses = {
CompositeIdBatchDeletionTest.Operator.class,
CompositeIdBatchDeletionTest.Product.class,
}
)
@SessionFactory
@ServiceRegistry(
settings = {
@Setting(name = AvailableSettings.STATEMENT_BATCH_SIZE, value = "2")
}
)
@JiraKey("HHH-16810")
public class CompositeIdBatchDeletionTest {
private final static String PRODUCT_ID = "ID";
private final static String PRODUCT_ID_2 = "ID2";
private final static String OPERATOR_ID = "operatorID";
private final static String OPERATOR_ID_2 = "operatorID2";
@BeforeEach
public void setUp(SessionFactoryScope scope) {
scope.inTransaction(
session -> {
Operator operator = new Operator( OPERATOR_ID );
Operator operator2 = new Operator( OPERATOR_ID_2 );
Product product = new Product( PRODUCT_ID, operator, "test" );
Product product2 = new Product( PRODUCT_ID_2, operator, "test 2" );
session.persist( operator );
session.persist( operator2 );
session.persist( product );
session.persist( product2 );
}
);
}
@AfterEach
public void tearDown(SessionFactoryScope scope) {
scope.inTransaction(
session -> {
session.createMutationQuery( "delete from Product" ).executeUpdate();
session.createMutationQuery( "delete from Operator" ).executeUpdate();
}
);
}
@Test
public void testDelete(SessionFactoryScope scope) {
ProductPK productPK = new ProductPK( PRODUCT_ID, OPERATOR_ID );
scope.inTransaction(
session -> {
Product product = session.find( Product.class, productPK );
session.remove( product );
}
);
scope.inTransaction(
session -> {
Product product = session.find( Product.class, productPK );
assertThat( product ).isNull();
}
);
}
@Test
public void testUpdate(SessionFactoryScope scope) {
ProductPK productPK = new ProductPK( PRODUCT_ID, OPERATOR_ID );
String newDescription = "new description";
scope.inTransaction(
session -> {
Product product = session.find( Product.class, productPK );
product.setDescription( newDescription );
}
);
scope.inTransaction(
session -> {
Product product = session.find( Product.class, productPK );
assertThat( product ).isNotNull();
assertThat( product.getDescription() ).isEqualTo( newDescription );
}
);
}
@Test
public void testDelete2(SessionFactoryScope scope) {
ProductPK productPK = new ProductPK( PRODUCT_ID, OPERATOR_ID );
ProductPK productPK2 = new ProductPK( PRODUCT_ID_2, OPERATOR_ID_2 );
scope.inTransaction(
session -> {
session.getReference( Product.class, productPK2 );
Product product = session.find( Product.class, productPK );
session.remove( product );
}
);
scope.inTransaction(
session -> {
Product product = session.find( Product.class, productPK );
assertThat( product ).isNull();
}
);
}
@IdClass(ProductPK.class)
@Entity(name = "Product")
@OptimisticLocking(type = OptimisticLockType.DIRTY)
@DynamicUpdate
@Table(name = "PRODUCTS")
public static class Product {
@Id
private String productId;
@Id
@ManyToOne(fetch = LAZY)
@JoinColumn(nullable = false)
private Operator operator;
private String description;
public Product() {
}
public Product(String productId, Operator operator, String description) {
this.productId = productId;
this.operator = operator;
this.description = description;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
}
public static class ProductPK implements Serializable {
private String productId;
private String operator;
public ProductPK() {
}
public ProductPK(String productId, String operator) {
this.productId = productId;
this.operator = operator;
}
}
@Entity(name = "Operator")
@Table(name = "OPERATORS")
@DynamicUpdate
@OptimisticLocking(type = OptimisticLockType.DIRTY)
public static class Operator {
@Id
private String operatorId;
@OneToMany(mappedBy = "operator")
private List<Product> products = new ArrayList<>();
public Operator() {
}
public Operator(String operatorId) {
this.operatorId = operatorId;
}
public void setProducts(List<Product> products) {
this.products = products;
}
}
}