HHH-16492 Add test for issue

This commit is contained in:
Andrea Boriero 2023-04-21 15:37:35 +02:00
parent 23e2b40ae8
commit 343da6efb6
2 changed files with 172 additions and 0 deletions

View File

@ -0,0 +1,73 @@
package org.hibernate.orm.test.stream;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.hibernate.testing.TestForIssue;
import org.hibernate.testing.orm.junit.EntityManagerFactoryScope;
import org.hibernate.testing.orm.junit.Jpa;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Test;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
@Jpa(
annotatedClasses = {
JpaNativeQueryFlushSessionTest.Person.class
}
)
@TestForIssue(jiraKey = "HHH-16492")
public class JpaNativeQueryFlushSessionTest {
@AfterEach
public void tearDown(EntityManagerFactoryScope scope) {
scope.inTransaction(
entityManager -> {
entityManager.createQuery( "delete from Person " ).executeUpdate();
}
);
}
@Test
public void testSessionIsFlushedWhenNativeQueryIsExecuted(EntityManagerFactoryScope scope) {
scope.inTransaction(
entityManager -> {
List<String> resultList = entityManager
.createNativeQuery( "select name from Person where name ='John Doe'" )
.getResultList();
assertThat( resultList.size() ).isEqualTo( 0 );
Person person = new Person( 1l, "John Doe" );
entityManager.persist( person );
try (Stream<String> resultStream = entityManager
.createNativeQuery( "select name from Person where name ='John Doe'" )
.getResultStream()) {
List<String> results = resultStream.collect( Collectors.toList() );
assertThat( results.size() ).isEqualTo( 1 );
}
}
);
}
@Entity(name = "Person")
public static class Person {
@Id
private Long id;
private String name;
public Person() {
}
public Person(Long id, String name) {
this.id = id;
this.name = name;
}
}
}

View File

@ -0,0 +1,99 @@
package org.hibernate.orm.test.stream;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.hibernate.testing.TestForIssue;
import org.hibernate.testing.orm.junit.DomainModel;
import org.hibernate.testing.orm.junit.SessionFactory;
import org.hibernate.testing.orm.junit.SessionFactoryScope;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Test;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
@DomainModel(
annotatedClasses = {
NativeQueryAndFlushSessionTest.Person.class
}
)
@SessionFactory
@TestForIssue(jiraKey = "HHH-16492")
public class NativeQueryAndFlushSessionTest {
@AfterEach
public void tearDown(SessionFactoryScope scope) {
scope.inTransaction(
session -> {
session.createQuery( "delete from Person " ).executeUpdate();
}
);
}
@Test
public void testSessionIsNotFlushedWhenNativeQueryIsExecuted(SessionFactoryScope scope) {
scope.inTransaction(
session -> {
List<String> resultList = session
.createNativeQuery( "select name from Person where name ='John Doe'" )
.getResultList();
assertThat( resultList.size() ).isEqualTo( 0 );
Person person = new Person( 1l, "John Doe" );
session.persist( person );
try (Stream<String> resultStream = session
.createNativeQuery( "select name from Person where name ='John Doe'" )
.getResultStream()) {
List<String> results = resultStream.collect( Collectors.toList() );
assertThat( results.size() ).isEqualTo( 0 );
}
}
);
}
@Test
public void testSessionIsFlushedWhenNativeQueryIsExecuted(SessionFactoryScope scope) {
scope.inTransaction(
session -> {
List<String> resultList = session
.createNativeQuery( "select name from Person where name ='John Doe'" )
.getResultList();
assertThat( resultList.size() ).isEqualTo( 0 );
Person person = new Person( 1l, "John Doe" );
session.persist( person );
try (Stream<String> resultStream = session
.createNativeQuery( "select name from Person where name ='John Doe'" )
.addSynchronizedEntityClass( Person.class )
.getResultStream()) {
List<String> results = resultStream.collect( Collectors.toList() );
assertThat( results.size() ).isEqualTo( 1 );
}
}
);
}
@Entity(name = "Person")
public static class Person {
@Id
private Long id;
private String name;
public Person() {
}
public Person(Long id, String name) {
this.id = id;
this.name = name;
}
}
}