dbTools feature:

improve test and testContainer config, also bugFix

Author: PouyaPouryaie

src/main/java/ir/bigz/springbootreal/dal/DaoRepositoryImpl.java

@@ -1,5 +1,6 @@
 package ir.bigz.springbootreal.dal;
 import org.hibernate.Session;
+import org.hibernate.jpa.QueryHints;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageImpl;
 import org.springframework.data.domain.Pageable;
@@ -140,7 +141,9 @@ public void clear() {
     @Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
     public Stream<T> getAll() {
         Session session = entityManager.unwrap(Session.class);
-        return session.createQuery("from " + daoType.getName()).stream();
+        return session.createQuery("from " + daoType.getName())
+                .setHint(QueryHints.HINT_FETCH_SIZE, 50)
+                .stream();
     }
 
     @Override

src/test/groovy/ir/bigz/springbootreal/web/RepositoryTest.groovy

@@ -2,9 +2,13 @@ package ir.bigz.springbootreal.web
 
 import ir.bigz.springbootreal.configuration.DataSourceConfiguration
 import ir.bigz.springbootreal.configuration.WebConfiguration
+import ir.bigz.springbootreal.dal.DaoRepository
+import ir.bigz.springbootreal.dal.DaoRepositoryImpl
 import ir.bigz.springbootreal.dal.UserRepository
 import ir.bigz.springbootreal.dal.UserRepositoryImpl
+import ir.bigz.springbootreal.dao.BaseEntity
 import ir.bigz.springbootreal.dao.User
+import ir.bigz.springbootreal.datagenerator.DataGenerator
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
@@ -13,13 +17,15 @@ import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfigurat
 import org.springframework.boot.test.context.SpringBootTest
 import org.springframework.test.context.ContextConfiguration
 import org.springframework.transaction.annotation.EnableTransactionManagement
+import spock.lang.Shared
 import spock.lang.Title
 
+import javax.transaction.Transactional
 import java.sql.Timestamp
 import java.time.LocalDateTime
 
 @ContextConfiguration(classes = [UserRepositoryImpl.class, User.class,
-        DataSourceConfiguration.class, WebConfiguration.class])
+        DataSourceConfiguration.class, WebConfiguration.class, DataGenerator.class])
 @Title("Test repository layer")
 @SpringBootTest(properties = "spring.profiles.active:test")
 @EnableAutoConfiguration(exclude = [DataSourceAutoConfiguration.class,
@@ -44,6 +50,23 @@ class RepositoryTest extends InitTestContainerDB {
 
     }
 
+    @Transactional
+    def "deactivate user with stream data and not throw exception"(){
+
+        def countActiveUser = userRepository.getAll().filter(BaseEntity::isActiveStatus).count()
+
+        when: "deactivate users"
+        userRepository.getAll()
+                .filter(BaseEntity::isActiveStatus).peek(user -> { user.setActiveStatus(false) }).count()
+
+        then: "after deactivate user, count active must be zero"
+        def count = userRepository.getAll().filter(BaseEntity::isActiveStatus).count()
+        count == 0
+        countActiveUser != count
+
+    }
+
+
     def "update user db"(){
 
         given: "create fake use"
@@ -66,8 +89,14 @@ class RepositoryTest extends InitTestContainerDB {
 
     }
 
+    //exec once before class run test
+    def setupSpec(){}
+
     //before each test this command run
-    def setup(){}
+    def setup(){
+        DataGenerator dataGenerator = new DataGenerator(userRepository)
+        dataGenerator.run()
+    }
 
     //after each test this command run
     def cleanup(){

src/test/resources/testcontainers.properties

@@ -0,0 +1 @@
+testcontainers.reuse.enable=true