diff --git a/src/test/java/liquibase/ext/mongodb/statement/RowsAffectedStatementIT.java b/src/test/java/liquibase/ext/mongodb/statement/RowsAffectedStatementIT.java index 760f9ad9..b87f9208 100644 --- a/src/test/java/liquibase/ext/mongodb/statement/RowsAffectedStatementIT.java +++ b/src/test/java/liquibase/ext/mongodb/statement/RowsAffectedStatementIT.java @@ -61,7 +61,7 @@ void shouldTrackRowsAffectedForCreateCollection() { Scope.child(scopeValues, () -> { final CreateCollectionStatement createStatement = new CreateCollectionStatement(collectionName); createStatement.execute(database); - assertThat(rowsAffected.get()).isEqualTo(1); + assertThat(rowsAffected.get()).isEqualTo(0); }); } @@ -121,7 +121,7 @@ void shouldTrackRowsAffectedForDropCollection() { final DropCollectionStatement dropStatement = new DropCollectionStatement(collectionName); dropStatement.execute(database); - assertThat(rowsAffected.get()).isEqualTo(1); + assertThat(rowsAffected.get()).isEqualTo(0); }); } @@ -140,7 +140,7 @@ void shouldTrackTotalRowsAffectedForMultipleOperations() { Document doc2 = new Document("test", "value2"); final InsertManyStatement insertStatement = new InsertManyStatement(collectionName, Arrays.asList(doc1, doc2)); insertStatement.execute(database); - assertThat(rowsAffected.get()).isEqualTo(3); // 1 to create + 2 to insert + assertThat(rowsAffected.get()).isEqualTo(2); }); } } \ No newline at end of file