|
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