testcontainers

Author: antonarhipov

build.gradle.kts

@@ -11,6 +11,9 @@ group = "com.example"
 version = "0.0.1-SNAPSHOT"
 java.sourceCompatibility = JavaVersion.VERSION_11
 
+val testcontainersVersion = "1.15.3"
+val postgresVersion="42.2.14"
+
 repositories {
     mavenCentral()
 }
@@ -30,6 +33,12 @@ dependencies {
     testImplementation("org.springframework.boot:spring-boot-starter-test")
     testImplementation("io.mockk:mockk:1.10.4")
     testImplementation("com.ninja-squad:springmockk:3.0.1")
+
+    testImplementation("org.testcontainers:testcontainers:$testcontainersVersion")
+    testImplementation("org.testcontainers:junit-jupiter:$testcontainersVersion")
+    testImplementation("org.testcontainers:postgresql:$testcontainersVersion")
+
+    implementation("org.postgresql:postgresql:$postgresVersion")
 }
 
 tasks.withType<KotlinCompile> {

settings.gradle.kts

@@ -1 +1 @@
-rootProject.name = "spring-time-in-kotlin-episode4"
+rootProject.name = "spring-time-in-kotlin-episode5"

src/main/resources/application.properties

@@ -1,4 +1,5 @@
-spring.datasource.driver-class-name=org.h2.Driver
+#spring.datasource.driver-class-name=org.h2.Driver
+spring.datasource.driver-class-name=org.postgresql.Driver
 spring.datasource.url=jdbc:h2:file:./data/testdb
 spring.datasource.username=sa
 spring.datasource.password=password

src/main/resources/sql/schema.ddl

@@ -0,0 +1,5 @@
+CREATE TABLE messages (
+    id VARCHAR(100) UNIQUE NOT NULL,
+    text VARCHAR(500),
+    CONSTRAINT id_messages PRIMARY KEY (id)
+);

src/test/kotlin/demo/IntegrationTests.kt

@@ -0,0 +1,25 @@
+package demo
+
+import org.junit.jupiter.api.Assertions.assertTrue
+import org.junit.jupiter.api.Test
+import org.testcontainers.junit.jupiter.Container
+import org.testcontainers.junit.jupiter.Testcontainers
+
+@Testcontainers
+class IntegrationTests {
+
+    @Container
+    var container = postgres("postgres:13-alpine") {
+//        withExposedPorts(6379)
+        withInitScript("schema.ddl")
+        withDatabaseName("db")
+        withUsername("user")
+        withPassword("password")
+    }
+
+    @Test
+    fun `the container is up and running`() {
+        assertTrue(container.isRunning)
+    }
+
+}

src/test/kotlin/demo/SpringBootIntegrationTests.kt

@@ -0,0 +1,83 @@
+package demo
+
+import demo.kx.uuid
+import org.assertj.core.api.Assertions
+import org.junit.jupiter.api.MethodOrderer
+import org.junit.jupiter.api.Order
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.TestMethodOrder
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
+import org.springframework.boot.test.web.client.TestRestTemplate
+import org.springframework.boot.test.web.client.getForEntity
+import org.springframework.boot.test.web.client.getForObject
+import org.springframework.boot.test.web.client.postForObject
+import org.springframework.http.HttpStatus
+import org.springframework.test.context.DynamicPropertyRegistry
+import org.springframework.test.context.DynamicPropertySource
+import org.testcontainers.junit.jupiter.Container
+import org.testcontainers.junit.jupiter.Testcontainers
+import kotlin.random.Random
+
+@Testcontainers
+@SpringBootTest(
+    webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
+)
+@TestMethodOrder(MethodOrderer.OrderAnnotation::class)
+class SpringBootIntegrationTests(@Autowired val client: TestRestTemplate) {
+    companion object {
+        @Container
+        val container = postgres("postgres:13-alpine") {
+            withInitScript("sql/schema.ddl")
+            withDatabaseName("db")
+            withUsername("user")
+            withPassword("password")
+        }
+
+        @JvmStatic
+        @DynamicPropertySource
+        fun datasourceConfig(registry: DynamicPropertyRegistry) {
+            registry.add("spring.datasource.url", container::getJdbcUrl)
+            registry.add("spring.datasource.password", container::getPassword)
+            registry.add("spring.datasource.username", container::getUsername)
+        }
+    }
+
+    @Test
+    @Order(1)
+    fun `test hello endpoint`() {
+        println(">>>>>>>>>>>>> Asserting Hello endpoint! >>>>>>>>>>>>>>>>>>>>>>>>> ")
+        val entity = client.getForEntity<String>("/hello")
+        Assertions.assertThat(entity.statusCode).isEqualTo(HttpStatus.OK)
+        Assertions.assertThat(entity.body).contains("Hello")
+    }
+
+    //TODO: remove
+    val id = "e3b7f959-f5c2-3d07-86e3-cd9df75e0b83"//"${Random.nextInt()}".uuid()
+
+    @Test
+    @Order(2)
+    fun `testing if we can post and retrieve the data`() {
+//        val id = "${Random.nextInt()}".uuid()
+        val message = Message(id, "some message")
+        client.postForObject<Message>("/", message)
+
+        val entity = client.getForEntity<String>("/$id")
+        Assertions.assertThat(entity.statusCode).isEqualTo(HttpStatus.OK)
+        Assertions.assertThat(entity.body).contains(message.id)
+        Assertions.assertThat(entity.body).contains(message.text)
+
+        val msg = client.getForObject<Message>("/$id")!!
+        Assertions.assertThat(entity.statusCode).isEqualTo(HttpStatus.OK)
+        Assertions.assertThat(msg.id).isEqualTo(message.id)
+        Assertions.assertThat(msg.text).contains(message.text)
+    }
+
+    @Test
+    @Order(3)
+    fun `message not found`() {
+//        val id = "${Random.nextInt()}".uuid()
+        val entity = client.getForEntity<String>("/$id")
+        Assertions.assertThat(entity.statusCode).isEqualTo(HttpStatus.NOT_FOUND)
+    }
+}

src/test/kotlin/demo/common.kt

@@ -0,0 +1,8 @@
+package demo
+
+import org.testcontainers.containers.JdbcDatabaseContainer
+import org.testcontainers.containers.PostgreSQLContainer
+import org.testcontainers.utility.DockerImageName
+
+fun postgres(imageCoordinates: String, options: JdbcDatabaseContainer<Nothing>.() -> Unit) =
+    PostgreSQLContainer<Nothing>(DockerImageName.parse(imageCoordinates)).apply(options)