Spring Boot 3中Liquibase是否有Flyway clean-on-validation-error类似功能？

Liquibase没有原生提供和Flyway的clean-on-validation-error完全一致的配置，但可以通过自定义逻辑实现相同效果——仅当schema验证失败（比如修改了初始changelog脚本）时才清空数据库，而非每次应用重启都执行重置。

以下是两种可行的实现方案：

方案一：基于验证失败触发Clean+Update #

通过监听Spring Boot启动事件，先执行Liquibase的验证操作，仅当验证失败时才执行clean，再执行更新。

1. 关闭Liquibase自动执行
   在application.yml或application.properties中配置：

   spring:
     liquibase:
       enabled: false
   

2. 自定义启动监听类
   创建一个监听ApplicationReadyEvent的类，手动控制Liquibase的执行逻辑：

   import liquibase.Liquibase;
   import liquibase.exception.ValidationFailedException;
   import liquibase.resource.ClassLoaderResourceAccessor;
   import org.springframework.boot.context.event.ApplicationReadyEvent;
   import org.springframework.context.event.EventListener;
   import org.springframework.stereotype.Component;
   import javax.sql.DataSource;
   
   @Component
   public class LiquibaseCleanOnValidationErrorHandler {
   
       private final DataSource dataSource;
       private final Liquibase liquibase;
   
       public LiquibaseCleanOnValidationErrorHandler(DataSource dataSource) throws Exception {
           this.dataSource = dataSource;
           // 初始化Liquibase，替换为你的changelog主文件路径
           this.liquibase = new Liquibase(
               "db/changelog/db.changelog-master.yaml",
               new ClassLoaderResourceAccessor(),
               liquibase.database.DatabaseFactory.getInstance().findCorrectDatabaseImplementation(
                   new liquibase.database.jvm.JdbcConnection(dataSource.getConnection())
               )
           );
       }
   
       @EventListener(ApplicationReadyEvent.class)
       public void runLiquibase() throws Exception {
           try {
               // 先执行验证操作
               liquibase.validate();
               // 验证通过，直接执行schema更新
               liquibase.update("");
           } catch (ValidationFailedException e) {
               // 验证失败（比如脚本被修改），先清空数据库再更新
               liquibase.clean();
               liquibase.update("");
           }
       }
   }
   

方案二：对比Changelog校验和触发Clean #

通过对比本地changelog的校验和与数据库中存储的历史校验和，判断是否需要执行clean操作。

1. 核心逻辑实现
   在自定义的Liquibase执行类中，添加校验和对比逻辑：

   import liquibase.changelog.ChangeLogHistoryService;
   import liquibase.changelog.DatabaseChangeLog;
   import liquibase.exception.LiquibaseException;
   import liquibase.Liquibase;
   import org.springframework.boot.context.event.ApplicationReadyEvent;
   import org.springframework.context.event.EventListener;
   import org.springframework.stereotype.Component;
   import javax.sql.DataSource;
   import liquibase.resource.ClassLoaderResourceAccessor;
   
   @Component
   public class LiquibaseChecksumBasedCleanHandler {
   
       private final Liquibase liquibase;
   
       public LiquibaseChecksumBasedCleanHandler(DataSource dataSource) throws Exception {
           this.liquibase = new Liquibase(
               "db/changelog/db.changelog-master.yaml",
               new ClassLoaderResourceAccessor(),
               liquibase.database.DatabaseFactory.getInstance().findCorrectDatabaseImplementation(
                   new liquibase.database.jvm.JdbcConnection(dataSource.getConnection())
               )
           );
       }
   
       @EventListener(ApplicationReadyEvent.class)
       public void runLiquibase() throws LiquibaseException {
           DatabaseChangeLog changeLog = liquibase.getDatabaseChangeLog();
           ChangeLogHistoryService historyService = liquibase.getDatabase().getChangeLogHistoryService();
           historyService.init();
   
           boolean checksumMismatch = false;
           // 遍历所有变更集，对比本地与数据库存储的校验和
           for (var changeSet : changeLog.getChangeSets()) {
               var historyEntry = historyService.getChangeSetHistoryEntry(changeSet);
               if (historyEntry != null && !changeSet.generateCheckSum().equals(historyEntry.getChecksum())) {
                   checksumMismatch = true;
                   break;
               }
           }
   
           if (checksumMismatch) {
               liquibase.clean();
               liquibase.update("");
           } else {
               liquibase.update("");
           }
       }
   }
   

注意事项 #

• 以上方案仅适用于非生产环境，生产环境绝对禁止使用clean操作
• 确保changelog文件的变更会被Liquibase的校验和机制检测到，不要随意修改已执行变更集的id或author字段
• 在Kubernetes环境中，只有当changelog脚本确实被修改导致校验失败/不匹配时，才会触发数据库重置，Pod正常重启不会影响现有数据

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