如何用java.sql.Connection检测Flyway提示的无元数据表非空schema？

可以通过java.sql.Connection对象验证两个核心条件，精准匹配你遇到的错误场景：

1. 检查目标schema是否缺失Flyway元数据表 #

Flyway旧版本的元数据表默认名为schema_version（新版本为flyway_schema_history，需根据你的实际版本确认）。通过JDBC执行以下查询判断表是否存在：

SELECT COUNT(*) FROM information_schema.tables 
WHERE table_schema = 'foobar' 
AND table_name = 'schema_version'; -- 替换为对应版本的元数据表名

若返回结果为0，说明该schema没有Flyway的元数据表。

2. 检查目标schema是否为非空状态 #

查询schema下的用户基础表数量，确认是否存在业务数据/表：

SELECT COUNT(*) FROM information_schema.tables 
WHERE table_schema = 'foobar' 
AND table_type = 'BASE TABLE'; -- 过滤视图、系统表等非业务对象

若返回结果大于0，说明该schema并非空schema。

综合判断逻辑 #

当元数据表不存在且schema非空时，完全匹配你遇到的Flyway报错场景，此时可自动执行修复脚本。

Java实现示例 #

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class FlywayStateChecker {
    private static final String TARGET_SCHEMA = "foobar";
    private static final String FLYWAY_META_TABLE = "schema_version"; // 按实际版本调整

    public static boolean isNeedFix(Connection conn) throws Exception {
        // 校验元数据表是否存在
        String metaCheckSql = "SELECT COUNT(*) FROM information_schema.tables WHERE table_schema = ? AND table_name = ?";
        try (PreparedStatement stmt = conn.prepareStatement(metaCheckSql)) {
            stmt.setString(1, TARGET_SCHEMA);
            stmt.setString(2, FLYWAY_META_TABLE);
            ResultSet rs = stmt.executeQuery();
            rs.next();
            if (rs.getInt(1) > 0) {
                return false;
            }
        }

        // 校验schema是否非空
        String schemaCheckSql = "SELECT COUNT(*) FROM information_schema.tables WHERE table_schema = ? AND table_type = 'BASE TABLE'";
        try (PreparedStatement stmt = conn.prepareStatement(schemaCheckSql)) {
            stmt.setString(1, TARGET_SCHEMA);
            ResultSet rs = stmt.executeQuery();
            rs.next();
            return rs.getInt(1) > 0;
        }
    }
}

你可以在Spring Boot启动流程的前置节点（比如自定义FlywayMigrationStrategy或ApplicationListener）调用该方法，返回true时触发修复脚本执行。

注意：不同数据库的系统视图结构略有差异，比如PostgreSQL的表类型字段为table_type，Oracle需查询ALL_TABLES视图，需根据使用的数据库适配SQL语句。

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