如何在Flyway Java迁移中注入Quarkus Bean？

Flyway的Java迁移（比如继承BaseJavaMigration的类）是在Quarkus CDI上下文完全初始化之前执行的，这就是你用@Inject、CDI.current()或者Arc.container()拿不到Bean实例的核心原因。下面是几种可行的解决思路：

1. 手动初始化所需Bean，绕过CDI #

对于不需要复杂CDI生命周期的Bean，直接手动实例化并配置依赖：

• 普通Bean（如MyBean1）：直接new实例，手动设置它的依赖（比如从Flyway上下文获取DataSource）
• RestClient（如MyBean2）：用Quarkus提供的RestClientBuilder手动构建实例

示例代码：

public class V1_0_0__SampleMigration implements BaseJavaMigration {
    @Override
    public void migrate(Context context) throws Exception {
        // 初始化MyBean1：假设它依赖DataSource
        DataSource dataSource = context.getConfiguration().getDataSource();
        MyBean1 myBean1 = new MyBean1();
        myBean1.setDataSource(dataSource);
        
        // 初始化MyBean2（RestClient）
        MyBean2 myBean2 = RestClientBuilder.newBuilder()
                .baseUri(URI.create("https://your-api-base-url.com"))
                .build(MyBean2.class);
        
        // 执行迁移逻辑
        myBean1.runMigrationTask();
        myBean2.callExternalApiForMigration();
    }
}

2. 推迟迁移到CDI上下文初始化完成后执行 #

关闭Flyway的自动迁移，改用Quarkus的启动事件触发迁移，这样就能正常注入Bean：

步骤1：修改application.properties关闭自动迁移 #

quarkus.flyway.migrate-at-start=false

步骤2：创建启动事件监听器，注入Bean并执行迁移 #

import io.quarkus.runtime.StartupEvent;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.event.Observes;
import jakarta.inject.Inject;
import org.flywaydb.core.Flyway;

@ApplicationScoped
public class MigrationTrigger {
    @Inject
    MyBean1 myBean1;
    @Inject
    MyBean2 myBean2;
    @Inject
    Flyway flyway;

    public void onStartup(@Observes StartupEvent event) {
        // 先执行Flyway的DDL迁移
        flyway.migrate();
        
        // 再执行需要Bean的业务迁移逻辑
        myBean1.postMigrationDataSetup();
        myBean2.syncExternalMigrationData();
    }
}

3. 拆分迁移逻辑：Flyway做DDL，Quarkus启动后做DML/业务操作 #

如果你的迁移既有DDL（建表、改结构）又有需要Bean的业务操作，建议拆分：

• 用Flyway的SQL迁移或Java迁移只处理DDL（不需要Bean的部分）
• 在Quarkus启动完成后（比如用@Startup注解的Bean），注入Bean执行后续的业务逻辑（比如初始化数据、调用外部API）

内容的提问来源于stack exchange，提问作者Anton