@@ -232,94 +232,95 @@ private void configureProperties(FluentConfiguration configuration, FlywayProper
232
232
.toArray (new String [0 ]);
233
233
configuration .locations (locations );
234
234
map .from (properties .isFailOnMissingLocations ())
235
- .to (configuration :: failOnMissingLocations );
236
- map .from (properties .getEncoding ()).to (configuration :: encoding );
235
+ .to (( failOnMissingLocations ) -> configuration . failOnMissingLocations ( failOnMissingLocations ) );
236
+ map .from (properties .getEncoding ()).to (( encoding ) -> configuration . encoding ( encoding ) );
237
237
map .from (properties .getConnectRetries ())
238
- .to (configuration :: connectRetries );
238
+ .to (( connectRetries ) -> configuration . connectRetries ( connectRetries ) );
239
239
map .from (properties .getConnectRetriesInterval ())
240
240
.as (Duration ::getSeconds )
241
241
.as (Long ::intValue )
242
- .to (configuration :: connectRetriesInterval );
242
+ .to (( connectRetriesInterval ) -> configuration . connectRetriesInterval ( connectRetriesInterval ) );
243
243
map .from (properties .getLockRetryCount ())
244
- .to (configuration :: lockRetryCount );
245
- map .from (properties .getDefaultSchema ()).to (configuration :: defaultSchema );
244
+ .to (( lockRetryCount ) -> configuration . lockRetryCount ( lockRetryCount ) );
245
+ map .from (properties .getDefaultSchema ()).to (( schema ) -> configuration . defaultSchema ( schema ) );
246
246
map .from (properties .getSchemas ())
247
247
.as (StringUtils ::toStringArray )
248
- .to (configuration :: schemas );
249
- map .from (properties .isCreateSchemas ()).to (configuration :: createSchemas );
250
- map .from (properties .getTable ()).to (configuration :: table );
251
- map .from (properties .getTablespace ()).to (configuration :: tablespace );
248
+ .to (( schemas ) -> configuration . schemas ( schemas ) );
249
+ map .from (properties .isCreateSchemas ()).to (( createSchemas ) -> configuration . createSchemas ( createSchemas ) );
250
+ map .from (properties .getTable ()).to (( table ) -> configuration . table ( table ) );
251
+ map .from (properties .getTablespace ()).to (( tablespace ) -> configuration . tablespace ( tablespace ) );
252
252
map .from (properties .getBaselineDescription ())
253
- .to (configuration :: baselineDescription );
253
+ .to (( baselineDescription ) -> configuration . baselineDescription ( baselineDescription ) );
254
254
map .from (properties .getBaselineVersion ())
255
- .to (configuration :: baselineVersion );
256
- map .from (properties .getInstalledBy ()).to (configuration :: installedBy );
257
- map .from (properties .getPlaceholders ()).to (configuration :: placeholders );
255
+ .to (( baselineVersion ) -> configuration . baselineVersion ( baselineVersion ) );
256
+ map .from (properties .getInstalledBy ()).to (( installedBy ) -> configuration . installedBy ( installedBy ) );
257
+ map .from (properties .getPlaceholders ()).to (( placeholders ) -> configuration . placeholders ( placeholders ) );
258
258
map .from (properties .getPlaceholderPrefix ())
259
- .to (configuration :: placeholderPrefix );
259
+ .to (( placeholderPrefix ) -> configuration . placeholderPrefix ( placeholderPrefix ) );
260
260
map .from (properties .getPlaceholderSuffix ())
261
- .to (configuration :: placeholderSuffix );
261
+ .to (( placeholderSuffix ) -> configuration . placeholderSuffix ( placeholderSuffix ) );
262
262
map .from (properties .getPlaceholderSeparator ())
263
- .to (configuration :: placeholderSeparator );
263
+ .to (( placeHolderSeparator ) -> configuration . placeholderSeparator ( placeHolderSeparator ) );
264
264
map .from (properties .isPlaceholderReplacement ())
265
- .to (configuration :: placeholderReplacement );
265
+ .to (( placeholderReplacement ) -> configuration . placeholderReplacement ( placeholderReplacement ) );
266
266
map .from (properties .getSqlMigrationPrefix ())
267
- .to (configuration :: sqlMigrationPrefix );
267
+ .to (( sqlMigrationPrefix ) -> configuration . sqlMigrationPrefix ( sqlMigrationPrefix ) );
268
268
map .from (properties .getSqlMigrationSuffixes ())
269
269
.as (StringUtils ::toStringArray )
270
- .to (configuration :: sqlMigrationSuffixes );
270
+ .to (( sqlMigrationSuffixes ) -> configuration . sqlMigrationSuffixes ( sqlMigrationSuffixes ) );
271
271
map .from (properties .getSqlMigrationSeparator ())
272
- .to (configuration :: sqlMigrationSeparator );
272
+ .to (( sqlMigrationSeparator ) -> configuration . sqlMigrationSeparator ( sqlMigrationSeparator ) );
273
273
map .from (properties .getRepeatableSqlMigrationPrefix ())
274
- .to (configuration ::repeatableSqlMigrationPrefix );
275
- map .from (properties .getTarget ()).to (configuration ::target );
274
+ .to ((repeatableSqlMigrationPrefix ) -> configuration
275
+ .repeatableSqlMigrationPrefix (repeatableSqlMigrationPrefix ));
276
+ map .from (properties .getTarget ()).to ((target ) -> configuration .target (target ));
276
277
map .from (properties .isBaselineOnMigrate ())
277
- .to (configuration :: baselineOnMigrate );
278
- map .from (properties .isCleanDisabled ()).to (configuration :: cleanDisabled );
278
+ .to (( baselineOnMigrate ) -> configuration . baselineOnMigrate ( baselineOnMigrate ) );
279
+ map .from (properties .isCleanDisabled ()).to (( cleanDisabled ) -> configuration . cleanDisabled ( cleanDisabled ) );
279
280
map .from (properties .isCleanOnValidationError ())
280
- .to (configuration :: cleanOnValidationError );
281
- map .from (properties .isGroup ()).to (configuration :: group );
282
- map .from (properties .isMixed ()).to (configuration :: mixed );
283
- map .from (properties .isOutOfOrder ()).to (configuration :: outOfOrder );
281
+ .to (( cleanOnValidationError ) -> configuration . cleanOnValidationError ( cleanOnValidationError ) );
282
+ map .from (properties .isGroup ()).to (( group ) -> configuration . group ( group ) );
283
+ map .from (properties .isMixed ()).to (( mixed ) -> configuration . mixed ( mixed ) );
284
+ map .from (properties .isOutOfOrder ()).to (( outOfOrder ) -> configuration . outOfOrder ( outOfOrder ) );
284
285
map .from (properties .isSkipDefaultCallbacks ())
285
- .to (configuration :: skipDefaultCallbacks );
286
+ .to (( skipDefaultCallbacks ) -> configuration . skipDefaultCallbacks ( skipDefaultCallbacks ) );
286
287
map .from (properties .isSkipDefaultResolvers ())
287
- .to (configuration :: skipDefaultResolvers );
288
+ .to (( skipDefaultResolvers ) -> configuration . skipDefaultResolvers ( skipDefaultResolvers ) );
288
289
map .from (properties .isValidateMigrationNaming ())
289
- .to (configuration :: validateMigrationNaming );
290
+ .to (( validateMigrationNaming ) -> configuration . validateMigrationNaming ( validateMigrationNaming ) );
290
291
map .from (properties .isValidateOnMigrate ())
291
- .to (configuration :: validateOnMigrate );
292
+ .to (( validateOnMigrate ) -> configuration . validateOnMigrate ( validateOnMigrate ) );
292
293
map .from (properties .getInitSqls ())
293
294
.whenNot (CollectionUtils ::isEmpty )
294
295
.as ((initSqls ) -> StringUtils .collectionToDelimitedString (initSqls , "\n " ))
295
- .to (configuration :: initSql );
296
+ .to (( initSql ) -> configuration . initSql ( initSql ) );
296
297
map .from (properties .getScriptPlaceholderPrefix ())
297
- .to (configuration :: scriptPlaceholderPrefix );
298
+ .to (( prefix ) -> configuration . scriptPlaceholderPrefix ( prefix ) );
298
299
map .from (properties .getScriptPlaceholderSuffix ())
299
- .to (configuration :: scriptPlaceholderSuffix );
300
+ .to (( suffix ) -> configuration . scriptPlaceholderSuffix ( suffix ) );
300
301
configureExecuteInTransaction (configuration , properties , map );
301
- map .from (properties ::getLoggers ).to (configuration :: loggers );
302
+ map .from (properties ::getLoggers ).to (( loggers ) -> configuration . loggers ( loggers ) );
302
303
// Flyway Teams properties
303
- map .from (properties .getBatch ()).to (configuration :: batch );
304
- map .from (properties .getDryRunOutput ()).to (configuration :: dryRunOutput );
304
+ map .from (properties .getBatch ()).to (( batch ) -> configuration . batch ( batch ) );
305
+ map .from (properties .getDryRunOutput ()).to (( dryRunOutput ) -> configuration . dryRunOutput ( dryRunOutput ) );
305
306
map .from (properties .getErrorOverrides ())
306
- .to (configuration :: errorOverrides );
307
- map .from (properties .getStream ()).to (configuration :: stream );
307
+ .to (( errorOverrides ) -> configuration . errorOverrides ( errorOverrides ) );
308
+ map .from (properties .getStream ()).to (( stream ) -> configuration . stream ( stream ) );
308
309
map .from (properties .getJdbcProperties ())
309
310
.whenNot (Map ::isEmpty )
310
- .to (configuration :: jdbcProperties );
311
+ .to (( jdbcProperties ) -> configuration . jdbcProperties ( jdbcProperties ) );
311
312
map .from (properties .getKerberosConfigFile ())
312
- .to (configuration :: kerberosConfigFile );
313
+ .to (( configFile ) -> configuration . kerberosConfigFile ( configFile ) );
313
314
map .from (properties .getOutputQueryResults ())
314
- .to (configuration :: outputQueryResults );
315
+ .to (( outputQueryResults ) -> configuration . outputQueryResults ( outputQueryResults ) );
315
316
map .from (properties .getSkipExecutingMigrations ())
316
- .to (configuration :: skipExecutingMigrations );
317
+ .to (( skipExecutingMigrations ) -> configuration . skipExecutingMigrations ( skipExecutingMigrations ) );
317
318
map .from (properties .getIgnoreMigrationPatterns ())
318
319
.whenNot (List ::isEmpty )
319
320
.to ((ignoreMigrationPatterns ) -> configuration
320
321
.ignoreMigrationPatterns (ignoreMigrationPatterns .toArray (new String [0 ])));
321
322
map .from (properties .getDetectEncoding ())
322
- .to (configuration :: detectEncoding );
323
+ .to (( detectEncoding ) -> configuration . detectEncoding ( detectEncoding ) );
323
324
}
324
325
325
326
private void configureExecuteInTransaction (FluentConfiguration configuration , FlywayProperties properties ,
@@ -508,13 +509,13 @@ public void customize(FluentConfiguration configuration) {
508
509
OracleConfigurationExtension .class , "Oracle" );
509
510
Oracle properties = this .properties .getOracle ();
510
511
PropertyMapper map = PropertyMapper .get ().alwaysApplyingWhenNonNull ();
511
- map .from (properties ::getSqlplus ).to (extension .via (OracleConfigurationExtension :: setSqlplus ));
512
+ map .from (properties ::getSqlplus ).to (extension .via (( ext , sqlplus ) -> ext . setSqlplus ( sqlplus ) ));
512
513
map .from (properties ::getSqlplusWarn )
513
- .to (extension .via (OracleConfigurationExtension :: setSqlplusWarn ));
514
+ .to (extension .via (( ext , sqlplusWarn ) -> ext . setSqlplusWarn ( sqlplusWarn ) ));
514
515
map .from (properties ::getWalletLocation )
515
- .to (extension .via (OracleConfigurationExtension :: setWalletLocation ));
516
+ .to (extension .via (( ext , walletLocation ) -> ext . setWalletLocation ( walletLocation ) ));
516
517
map .from (properties ::getKerberosCacheFile )
517
- .to (extension .via (OracleConfigurationExtension :: setKerberosCacheFile ));
518
+ .to (extension .via (( ext , kerberosCacheFile ) -> ext . setKerberosCacheFile ( kerberosCacheFile ) ));
518
519
}
519
520
520
521
}
@@ -535,7 +536,7 @@ public void customize(FluentConfiguration configuration) {
535
536
Postgresql properties = this .properties .getPostgresql ();
536
537
PropertyMapper map = PropertyMapper .get ().alwaysApplyingWhenNonNull ();
537
538
map .from (properties ::getTransactionalLock )
538
- .to (extension .via (PostgreSQLConfigurationExtension :: setTransactionalLock ));
539
+ .to (extension .via (( ext , transactionalLock ) -> ext . setTransactionalLock ( transactionalLock ) ));
539
540
}
540
541
541
542
}
@@ -571,7 +572,7 @@ private void setKerberosLoginFile(SQLServerConfigurationExtension configuration,
571
572
*/
572
573
static class Extension <E extends ConfigurationExtension > {
573
574
574
- private final SingletonSupplier <E > extension ;
575
+ private SingletonSupplier <E > extension ;
575
576
576
577
Extension (FluentConfiguration configuration , Class <E > type , String name ) {
577
578
this .extension = SingletonSupplier .of (() -> {
0 commit comments