如何在Liquibase自定义前置条件中获取SQL查询结果？

要在CustomPrecondition的check方法里执行SQL查询并验证结果，核心是利用Liquibase的Database对象获取JDBC连接，执行查询后处理结果，不符合预期时抛出对应的前置条件异常。以下是具体实现步骤和代码示例：

1. 自定义前置条件类实现 #

import liquibase.database.Database;
import liquibase.exception.PreconditionFailedException;
import liquibase.exception.PreconditionErrorException;
import liquibase.precondition.CustomPrecondition;

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

public class MaxUserNameLengthPrecondition implements CustomPrecondition {

    @Override
    public void check(Database database) throws PreconditionFailedException, PreconditionErrorException {
        // 从Database对象获取当前数据库连接
        Connection connection = database.getConnection();
        // 注意：不同数据库字符串长度函数有差异，比如MySQL用length()，SQL Server用len()
        String sql = "select max(len(user_name)) from users";

        try (PreparedStatement stmt = connection.prepareStatement(sql);
             ResultSet rs = stmt.executeQuery()) {

            if (rs.next()) {
                Integer maxLength = rs.getInt(1);
                // 替换为你的业务校验逻辑，比如要求最大长度不超过50
                if (maxLength == null || maxLength > 50) {
                    throw new PreconditionFailedException("用户名最大长度超出限制，当前值：" + maxLength);
                }
            } else {
                // 未查询到结果时的处理逻辑
                throw new PreconditionErrorException("查询用户名字段最大长度未获取到有效结果");
            }

        } catch (SQLException e) {
            // SQL执行异常时抛出前置条件错误
            throw new PreconditionErrorException("执行查询出错：" + e.getMessage(), e);
        }
    }
}

2. 关键细节说明 #

• 连接获取：通过database.getConnection()直接复用Liquibase的数据库连接，无需手动管理连接的开闭，Liquibase会统一处理资源释放。
• SQL兼容性：根据你使用的数据库调整长度函数，比如MySQL用length()，Oracle用length()，SQL Server用len()。
• 资源管理：使用try-with-resources语法自动关闭PreparedStatement和ResultSet，避免资源泄漏。
• 异常规范：校验失败时抛出PreconditionFailedException，SQL执行出错时抛出PreconditionErrorException，Liquibase会根据异常类型触发对应的流程（比如终止变更执行或提示错误）。

3. 在Changelog中引用自定义前置条件 #

在你的Liquibase changelog文件中，通过以下方式引用这个自定义前置条件：

<preConditions>
    <customPrecondition className="com.your.package.MaxUserNameLengthPrecondition"/>
</preConditions>

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