|
30 | 30 | import static org.assertj.core.api.Assertions.assertThat; |
31 | 31 |
|
32 | 32 | /** |
33 | | - * The test aims to check that methods accepting the batch size as parameter e.g. {@link Stage.StatelessSession#insert(int, Object...)} |
34 | | - * work when {@link AvailableSettings#STATEMENT_BATCH_SIZE} hasn't been set. |
| 33 | + * The test aims to check that methods accepting the batch size as parameter |
| 34 | + * e.g. {@link Stage.StatelessSession#insert(int, Object...)} work |
| 35 | + * when {@link AvailableSettings#STATEMENT_BATCH_SIZE} hasn't been set. |
35 | 36 | */ |
36 | 37 | @Timeout(value = 10, timeUnit = MINUTES) |
37 | 38 | public class ReactiveStatelessDefaultBatchSizeTest extends BaseReactiveTest { |
@@ -144,7 +145,8 @@ public void testStageBatchingInsertMultiple(VertxTestContext context) { |
144 | 145 |
|
145 | 146 | @Test |
146 | 147 | public void testStageBatchingInsertNoBatchSizeParameter(VertxTestContext context) { |
147 | | - test( context, getSessionFactory().withStatelessTransaction( s -> s.insert( PIGS ) ) |
| 148 | + test( context, getSessionFactory() |
| 149 | + .withStatelessTransaction( s -> s.insert( PIGS ) ) |
148 | 150 | .thenAccept( v -> assertSqlLogTracker( "insert into pig \\(name,id\\) values (.*)" ) ) |
149 | 151 | .thenCompose( v -> assertExpectedResult( PIGS ) ) |
150 | 152 | ); |
@@ -289,7 +291,7 @@ public void testMutinyBatchingUpdateAllNoBatchSizeParameter(VertxTestContext con |
289 | 291 | .chain( pigs -> { |
290 | 292 | pigs.get( 0 ).setName( "One updated" ); |
291 | 293 | pigs.get( 1 ).setName( "Two updated" ); |
292 | | - return s.updateAll( 10, pigs.toArray() ); |
| 294 | + return s.updateAll( pigs.toArray() ); |
293 | 295 | } ) ) |
294 | 296 | ) |
295 | 297 | .invoke( () -> assertSqlLogTracker( "update pig set name=.* where id=.*" ) ) |
|
0 commit comments