问题描述
import com.expediagroup.api.database.OrderDomain
import com.expediagroup.api.database.OrderDomainRepository
import io.r2dbc.pool.ConnectionPool
import io.r2dbc.spi.ConnectionFactory
import org.assertj.core.api.Assertions.assertthat
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.TestInstance
import org.springframework.beans.factory.annotation.Autowired
import java.io.IOException
import java.sql.Date
import java.util.Arrays
import java.util.function.Consumer
import org.junit.jupiter.api.extension.ExtendWith
import org.springframework.r2dbc.core.DatabaseClient
import org.springframework.test.context.junit.jupiter.SpringExtension
import reactor.test.StepVerifier
import reactor.core.publisher.Hooks
import org.junit.jupiter.api.BeforeEach
import org.springframework.boot.test.autoconfigure.data.r2dbc.DataR2dbcTest
@ExtendWith(SpringExtension::class)
@TestInstance(TestInstance.Lifecycle.PER_METHOD)
@DataR2dbcTest
class R2dbcTemplateIT {
@Autowired
var orderDomain: OrderDomainRepository? = null
@Autowired
var database: DatabaseClient? = null
@ClassRule
var MysqL: MysqLContainer<?> = MysqLContainer<>("MysqL:5.5")
.withDatabaseName("test")
.withUsername("test")
.withPassword("test")
@BeforeEach
fun setUp() {
Hooks.onoperatorDebug()
MysqL.start()
val statements: List<String> = Arrays.asList( //
"DROP TABLE IF EXISTS customer;","CREATE TABLE customer ( id SERIAL PRIMARY KEY,firstname VARCHAR(100) NOT NULL,lastname VARCHAR(100) NOT NULL);"
)
statements.forEach(Consumer { it: String? ->
database!!.sql(it!!) //
.fetch() //
.rowsUpdated() //
.`as`(StepVerifier::create)
.expectNextCount(1) //
.verifyComplete()
})
}
@Test
@Throws(IOException::class)
fun generatesIdOnInsert() {
val domainMetadata = customer(1L,"John","Smith")
orderDomain?.save(domainMetadata) //
?.`as`(StepVerifier::create) //
?.assertNext { actual ->
assertthat(domainMetadata.id).isNull() // immutable before save
assertthat(actual.id).isNotNull() // after save
}?.verifyComplete()
}
}
我正在尝试使用 R2DBCRepositories 在 R2DBC 上运行集成测试来测试我们的一些内容。我想知道我有这个,除了没有运行任何本地数据库的事实
解决方法
事实证明这是 Kotlin 不喜欢它在 Java 中的设置方式的问题。
https://github.com/testcontainers/testcontainers-java/issues/318