updating the version of flyway-core and changing the callback implementation.

persistence-modules/flyway/src/test/java/com/baeldung/flywaycallbacks/FlywayApplicationUnitTest.java

@@ -18,7 +18,7 @@ import org.springframework.test.context.junit4.SpringRunner;
 @ContextConfiguration(classes = FlywayCallbackTestConfig.class)
 public class FlywayApplicationUnitTest {
 
-    private Log log = LogFactory.getLog(getClass());
+    private final Log log = LogFactory.getLog(getClass());
 
     @Autowired
     private DataSource dataSource;
@@ -26,43 +26,47 @@ public class FlywayApplicationUnitTest {
     @Test
     public void migrateWithNoCallbacks() {
         logTestBoundary("migrateWithNoCallbacks");
-        Flyway flyway = new Flyway();
-        flyway.setDataSource(dataSource);
-        flyway.setLocations("db/migration");
-        flyway.migrate(); 
+        Flyway flyway = Flyway.configure()
+                .dataSource(dataSource)
+                .locations("db/migration")
+                .load();
+        flyway.migrate();
     }
 
     @Test
     public void migrateWithJavaCallbacks() {
         logTestBoundary("migrateWithJavaCallbacks");
-        Flyway flyway = new Flyway();
-        flyway.setDataSource(dataSource);
-        flyway.setLocations("db/migration");
-        flyway.setCallbacks(new ExampleFlywayCallback());
+        Flyway flyway = Flyway.configure()
+                .dataSource(dataSource)
+                .locations("db/migration")
+                .callbacks(new ExampleFlywayCallback())
+                .load();
         flyway.migrate();
     }
 
     @Test
     public void migrateWithSqlCallbacks() {
         logTestBoundary("migrateWithSqlCallbacks");
-        Flyway flyway = new Flyway();
-        flyway.setDataSource(dataSource);
-        flyway.setLocations("db/migration", "db/callbacks");
-        flyway.migrate(); 
+        Flyway flyway = Flyway.configure()
+                .dataSource(dataSource)
+                .locations("db/migration", "db/callbacks")
+                .load();
+        flyway.migrate();
     }
 
     @Test
     public void migrateWithSqlAndJavaCallbacks() {
         logTestBoundary("migrateWithSqlAndJavaCallbacks");
-        Flyway flyway = new Flyway();
-        flyway.setDataSource(dataSource);
-        flyway.setLocations("db/migration", "db/callbacks");
-        flyway.setCallbacks(new ExampleFlywayCallback());
-        flyway.migrate(); 
+        Flyway flyway = Flyway.configure()
+                .dataSource(dataSource)
+                .locations("db/migration", "db/callbacks")
+                .callbacks(new ExampleFlywayCallback())
+                .load();
+        flyway.migrate();
     }
 
     private void logTestBoundary(String testName) {
         System.out.println("\n");
         log.info("> " + testName);
     }
- }
+}