如何让testcontainers环境中flyway服务等待MySQL服务就绪后启动

问题原因 #

Node 版 testcontainers 的 DockerComposeEnvironment 默认会并行启动所有 Compose 服务，你为 test_mysql 配置的等待策略只会阻止 up() 方法提前返回，不会拦截 Flyway 容器的启动逻辑，因此 Flyway 会在 MySQL 完全就绪前就开始执行迁移。Docker Compose 原生的 depends_on 仅能控制容器的启动顺序，不会等待服务内部进程完全就绪，因此也无法解决该场景下的问题。

解决方案 #

方案1：分阶段启动服务

手动控制服务启动顺序，先启动 MySQL 服务等待完全就绪后，再启动 Flyway 服务执行迁移，示例代码如下：

// 仅启动MySQL服务，等待就绪
const environment = await new DockerComposeEnvironment(composeFilePath, composeFile)
        .withServicesToStart('test_mysql')
        .withWaitStrategy('test_mysql', Wait.forLogMessage(`ready for connections. Bind-address: '::' port:`))
        .withStartupTimeout(120000)
        .up();

// 再启动Flyway服务，等待迁移完成
await environment
        .withServicesToStart('flyway_c')
        .withWaitStrategy('flyway_c', Wait.forLogMessage(`Successfully applied`))
        .up();

方案2：基于健康检查控制依赖

在 Docker Compose 配置中为 MySQL 服务添加健康检查，同时修改 Flyway 的依赖条件，要求 MySQL 健康检查通过后再启动 Flyway，该方案同时兼容原生 Docker Compose 启动和 Testcontainers 场景：
修改后的 Docker Compose 配置如下：

version: '3'
services:
  db:
    image: mysql:8.0.26
    environment:
      - MYSQL_DATABASE=test_db
      - MYSQL_ROOT_PASSWORD=pass
    command: --character-set-server=utf8mb4 --collation-server=utf8mb4_unicode_ci --default-authentication-plugin=mysql_native_password
    ports:
      - '3306:3306'
      - '33060:33060'
    expose:
      - '3306'
    container_name: test_mysql
    # 新增健康检查配置
    healthcheck:
      test: ["CMD", "mysqladmin" ,"ping", "-h", "localhost", "-uroot", "-ppass"]
      interval: 2s
      timeout: 3s
      retries: 30
  flyway:
    image: flyway/flyway
    command: -url=jdbc:mysql://db -schemas=test_db -user=root -password=pass -connectRetries=100 migrate
    volumes:
      - .:/flyway/sql
    depends_on:
      db:
        # 等待DB健康检查通过再启动
        condition: service_healthy
    container_name: flyway_c

该方案无需修改原有 Testcontainers 初始化代码，保留你原有的等待策略即可。

补充优化建议 #

你当前配置的 Flyway connectRetries=100 已经可以应对大部分 MySQL 启动延迟的问题，如果仍然出现连接失败，可以将 MySQL 的等待策略改为等待端口开放，比日志匹配更稳定：

.withWaitStrategy('test_mysql', Wait.forListeningPorts())

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