Skip to content

Commit cc8c24b

Browse files
committed
add sqloperations test
1 parent 51413b5 commit cc8c24b

File tree

2 files changed

+15
-8
lines changed

2 files changed

+15
-8
lines changed

lib/stove-testing-e2e-mongodb/src/main/kotlin/com/trendyol/stove/testing/e2e/mongodb/MongodbSystem.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@ import com.mongodb.reactivestreams.client.*
77
import com.trendyol.stove.functional.*
88
import com.trendyol.stove.testing.e2e.system.TestSystem
99
import com.trendyol.stove.testing.e2e.system.abstractions.*
10-
import com.trendyol.stove.testing.e2e.system.annotations.StoveDsl
1110
import kotlinx.coroutines.reactive.*
1211
import kotlinx.coroutines.runBlocking
1312
import org.bson.*

lib/stove-testing-e2e-rdbms/src/test/kotlin/com/trendyol/stove/testing/e2e/rdbms/R2DbcResultMapperKtTest.kt

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,10 @@ package com.trendyol.stove.testing.e2e.rdbms
22

33
import io.kotest.assertions.throwables.shouldThrow
44
import io.kotest.core.spec.style.FunSpec
5-
import io.kotest.matchers.shouldBe
6-
import io.kotest.matchers.shouldNotBe
7-
import io.r2dbc.spi.ColumnMetadata
8-
import io.r2dbc.spi.Row
9-
import io.r2dbc.spi.RowMetadata
10-
import org.mockito.kotlin.doReturn
11-
import org.mockito.kotlin.mock
5+
import io.kotest.matchers.*
6+
import io.r2dbc.spi.*
7+
import kotlinx.coroutines.reactor.mono
8+
import org.mockito.kotlin.*
129

1310
class R2DbcResultMapperKtTest : FunSpec({
1411

@@ -196,4 +193,15 @@ class R2DbcResultMapperKtTest : FunSpec({
196193
result.id shouldBe givenId
197194
result.description shouldBe givenDescription
198195
}
196+
197+
test("sqloperations should not be opened if it is already open") {
198+
val connectionFactory = mock<ConnectionFactory> {
199+
on { create() }.thenReturn(mono { mock<Connection>() })
200+
}
201+
val ops = SqlOperations(connectionFactory)
202+
ops.open()
203+
ops.isOpen() shouldBe true
204+
ops.open()
205+
verify(connectionFactory, times(1)).create()
206+
}
199207
})

0 commit comments

Comments
 (0)