sql ops simplified for mssql

Author: osoykan

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

@@ -23,7 +23,7 @@ import kotlin.collections.listOf
 import kotlin.collections.plus
 import kotlin.collections.set
 
-@StoveDsl
+@MongoDsl
 class MongodbSystem internal constructor(
     override val testSystem: TestSystem,
     val context: MongodbContext

lib/stove-testing-e2e-rdbms-mssql/src/main/kotlin/com/trendyol/stove/testing/e2e/rdbms/mssql/MsSqlSystem.kt

@@ -67,10 +67,10 @@ class MsSqlSystem internal constructor(
     override fun configuration(): List<String> = context.configureExposedConfiguration(exposedConfiguration)
 
     @MssqlDsl
-    suspend fun ops(operations: suspend SqlOperations.() -> Unit) {
+    suspend fun ops(operations: suspend Handle.() -> Unit) {
         sqlOperations.isOpen().let {
             if (it) {
-                operations(sqlOperations)
+                sqlOperations.transaction(operations)
             } else {
                 throw IllegalStateException("The connection is not open. Please check the connection status.")
             }

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

@@ -68,10 +68,8 @@ class MssqlSystemTests : ShouldSpec({
         validate {
             mssql {
                 ops {
-                    transaction {
-                        val result = select("SELECT 1")
-                        result.rowsUpdated.awaitFirstOrNull() shouldBe 1
-                    }
+                    val result = select("SELECT 1")
+                    result.rowsUpdated.awaitFirstOrNull() shouldBe 1
                 }
             }
         }

lib/stove-testing-e2e-rdbms/src/main/kotlin/com/trendyol/stove/testing/e2e/rdbms/SqlOperations.kt

@@ -16,6 +16,9 @@ class SqlOperations(private val connectionFactory: ConnectionFactory) {
      * Opens a connection from the factory.
      */
     suspend fun open() {
+        if (isOpen()) {
+            return
+        }
         connection = this.connectionFactory.create().awaitFirst()
     }