sign

Signed-off-by: Sebastian <sebastian.alfers@gmail.com>

Author: sebastian-alfers

src/test/java/io/r2dbc/mssql/TransactionIntegrationTests.java

@@ -373,33 +373,12 @@ void shouldResetLockTimeoutAfterTransaction() {
             .verifyComplete();
     }
 
-    @Test
-    void shouldGetRowsUpdatedForUpsert() {
-        createTable(connection);
-
-        String upsertSQl = "UPDATE r2dbc_example SET id = 1, first_name = 'Jesse', last_name = 'Pinkman' WHERE id = 1 if @@ROWCOUNT = 0 " +
-                           "INSERT INTO r2dbc_example (id, first_name, last_name)VALUES(1, 'Jesse', 'Pinkmann')";
-
-        // should trigger the "INSERT" part of the query
-        connection.createStatement(upsertSQl)
-                .execute().flatMap(Result::getRowsUpdated)
-                .as(StepVerifier::create)
-                .expectNext(1L)
-                .verifyComplete();
-
-        // should trigger the "UPDATE" part of the query
-        connection.createStatement(upsertSQl)
-                .execute().flatMap(Result::getRowsUpdated)
-                .as(StepVerifier::create)
-                .expectNext(1L)
-                .verifyComplete();
-    }
-
     @Test
     void shouldGetRowsUpdatedInUpsert() throws Exception {
         createTable(connection);
         String insertSql = "INSERT INTO r2dbc_example (id, first_name, last_name) VALUES(1, 'Jessi', 'Pinkmann')";
 
+        
         reactor.core.publisher.Flux<Long> flux = connection
                 .createStatement(insertSql)
                 .execute()