一： 自动执行回滚， 已执行成功的忽略，新sql执行失败则执行新sql文件中的回滚sql
pom.xml
<dependency>
<groupId>org.liquibase</groupId>
<artifactId>liquibase-core</artifactId>
<version>4.25.0</version>
</dependency>
sql 文件指定回滚sql
新建一个 CustomChangeExecListener 继承 AbstractChangeExecListener
@Service
@Slf4j
public class CustomChangeExecListener extends AbstractChangeExecListener {@SneakyThrowspublic void runFailed(ChangeSet changeSet, DatabaseChangeLog databaseChangeLog, Database database, Exception exception) {log.error("sql执行失败, 执行回滚sql, 错误原因: {}", exception.getMessage());String line = "\r\n";String jdbc = "jdbc";List<String> sqlList = new ArrayList<>();changeSet.getRollback().getChanges().stream().forEach(e->{RawSQLChange rawSQLChange = (RawSQLChange) e;Arrays.asList(rawSQLChange.getSql().split(line)).stream().forEach(sql->{sqlList.add(sql);});});if(CollectionUtils.isEmpty(sqlList)){return;}Executor executor = Scope.getCurrentScope().getSingleton(ExecutorService.class).getExecutor(jdbc, database);for (String sql : sqlList){executor.execute(new RawSqlStatement(sql));}}}
启动参数加上：
-Dliquibase.command.changeExecListenerClass=com.tang.execListener.CustomChangeExecListener2️⃣： 自动打tag， 注意如果有上面的自动执行回滚sql, 这一步不是很重要
spring.liquibase.tag 不起作用， 搞个自动打tag
1: github 拉取源码
地址:GitHub - liquibase/liquibase: Main Liquibase Source
2: idea 打开如下路径：
liquibase/sqlgenerator/core/MarkChangeSetRanGenerator.java
加入如下代码：
if(change instanceof RawSQLChange){tag = changeSet.getId();} 
把编译的class 替换jar路径中的class放到仓库
sql文件中加入标记如下： 作者:id
加入上面的代码，tag会拿这个id 作为tag标签。
执行结果：
