如何创建在应用程序启动并使用其他服务后运行的Flyway迁移？

Question

我刚刚在用户表中添加了一个新的时区列，现在我需要为所有现有记录填充它。

这些值应该根据同一表格中的另一列计算出来。

转换由名为OpenCage的地理服务完成。

所以我想创建一个新的Flyway迁移

1. 读取表的每一行，获取其邮政编码值
2. 调用地理服务的API并将邮政编码值传递给它
3. 接收返回的时区，
4. 并将其存储在时区列中

地理服务是我的应用程序中的SpringBoot@Service，所以在迁移类中，我需要@Autow的它。

而且我认为这种迁移需要在应用程序启动后立即自动运行，而不是使用Commmandflyway：迁移。

我当前的实现如下所示，问题是它不会在应用程序启动后运行。

public class V151__CalculateTimeZoneForExistingUsers extends BaseJavaMigration {
    @Autowired
    private GeocodingService geocodingService;

    public void migrate(Context context) throws Exception {
        try (Statement select = context.getConnection().createStatement()) {
            try (ResultSet rows = select.executeQuery("SELECT id, postal_code FROM user")) {
                while (rows.next()) {
                    long id = rows.getLong(1);
                    String postalCode = rows.getString(2);

                    JOpenCageResult jOpenCageResult = geocodingService.geocode(postalCode);
                    if (jOpenCageResult != null && jOpenCageResult.getAnnotations() != null && jOpenCageResult.getAnnotations().getTimeZone() != null) {
                        String timeZone = jOpenCageResult.getAnnotations().getTimeZone().getName();
                        try (Statement update = context.getConnection().createStatement()) {
                            update.execute("UPDATE user SET time_zone = '" + timeZone + "' WHERE id=" + id);
                        }
                    }
                }
            }
        }
    }
}

它位于src\main\java\org\LayerOne\LayerTwo\db\migration\V151\uu CalculateTimeZoneForExistingUsers包中。java

在pom.xml中，flyway的配置是

                <configuration>
                    <user>username</user>
                    <password>password</password>
                    <url>jdbc:mysql://localhost:3306/myDB</url>
                    <baselineOnMigrate>true</baselineOnMigrate>
                    <baselineVersion>0.0</baselineVersion>
                    <locations>
                        <location>classpath:db/migration, classpath:org/LayerOne/LayerTwo/db/migration</location>
                    </locations>
                </configuration>

使用flyway:info，我可以看到迁移列表。但它不会在应用程序启动后运行。

谁能教我怎么让它运转？

谢啦！

Answer 1

原来我只需要在类中添加Springboot注释@Component就像

@Component
public class V151__CalculateTimeZoneForExistingUsers extends BaseJavaMigration {
...
}

然后它将在应用程序启动后运行