@WebFluxTest

@WebMvcTest

@Configuration

@RestController

List<Post> posts = doInJPA(entityManager -> {
    List<Post> _posts = entityManager
    .createQuery(
        "select distinct p " +
        "from Post p " +
        "left join fetch p.comments " +
        "where p.id between :minId and :maxId ", Post.class)
    .setParameter("minId", 1L)
    .setParameter("maxId", 50L)
    .setHint(QueryHints.PASS_DISTINCT_THROUGH, false)
    .getResultList();
 
    _posts = entityManager
    .createQuery(
        "select distinct p " +
        "from Post p " +
        "left join fetch p.tags t " +
        "where p in :posts ", Post.class)
    .setParameter("posts", _posts)
    .setHint(QueryHints.PASS_DISTINCT_THROUGH, false)
    .getResultList();
 
    return _posts;
});
 
assertEquals(POST_COUNT, posts.size());
 
for(Post post : posts) {
    assertEquals(POST_COMMENT_COUNT, post.getComments().size());
    assertEquals(TAG_COUNT, post.getTags().size());
}

Now, we have to fetch the Post entities along with their associated Tag entities, and, thanks to the Persistence Context, Hibernate will set the tags collection of the previously fetched Post entities.

val companiesWithAddresses = entityManager.createQuery(
            """
            SELECT t from ProjectCompany t
            LEFT JOIN FETCH t.addresses
            ORDER BY t.id ASC
            """,
            ProjectCompany::class.java
        )
            .setHint(QueryHints.PASS_DISTINCT_THROUGH, false)
            .resultList
        val companies = entityManager.createQuery(
            """
            SELECT t from ProjectCompany t
            LEFT JOIN FETCH t.contactPersons persons
            WHERE t in :companies
            ORDER BY t.id ASC
            """,
            ProjectCompany::class.java
        )
            .setParameter("companies", companiesWithAddresses)
            .setHint(QueryHints.PASS_DISTINCT_THROUGH, false)
            .resultList
        return PageImpl(companies, pageable, companies.size.toLong())

org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: ProjectCompany.addresses, could not initialize proxy - no Session

WebFluxTest

@SpringBootTest

@ExtendWith(SpringExtension::class)
@ContextConfiguration(classes = [MyRouteConfiguration::class])
@WebFluxTest
class RouteConfigurationIT(@Autowired val context: ApplicationContext) {

    private lateinit var webClient: WebTestClient

    @BeforeEach
    fun setUp() {
        webClient = WebTestClient.bindToApplicationContext(context).build()
    }

    // some tests here
}

/actuator/health

@Component
class ContentClientHealthIndicator(private val contentJsonClient: ContentJsonClient) : ReactiveHealthIndicator {
    private val logger = KotlinLogging.logger { }
    private val pagesToCheck = listOf("home")
    override fun health(): Mono<Health> =
        mono(Dispatchers.Unconfined) {
            pagesToCheck.map { contentJsonClient.getPage(it) }
            Health.up().build()
        }.onErrorResume(Exception::class.java) { exception ->
            logger.error(exception) { "ContentClient health check failed" }
            Health.down(exception).build().let { Mono.just(it) }
        }
}

coRouter

ServerResponse.from

req.bodyToMono(DataClass::class.java).awaitFirst()

fun sendSimpleMessage(
        op: SimpleMailMessage.() -> Unit
) {
    val message = SimpleMailMessage().apply(op)
    mailSender.send(message)
}

public void setSubject(String subject)

mail.sendSimpleMessage {
    setTo(address)
    subject = "Test Email" // compiler warning
    //setSubject("Test Email") <--- this does work though
    ....
}

Val cannot be reassigned

spring-devtool

graphql-kotlin-spring-server

println

DataFetchingException: Object is not an instance of declaring class

Component

CommandLineRunner