小编点评

**liquibase customChangeliquibase changeset 执行Java代码** 可以使用以下步骤在自定义更改文件中使用 Java 代码执行 DDL、DML 操作： **1. 使用 `CustomChange` 类** 自定义 `CustomTaskChange` 类实现 `execute` 方法。在 `execute` 方法中，您可以使用 `Database` 对象进行 DDL/DML 操作。 ```java @Override public void execute(Database database) throws CustomChangeException { // DDL 或 DML 操作 database.execute("CREATE TABLE my_table (column1 INT, column2 VARCHAR(10))"); } ``` **2. 使用 `ApplicationContext` 获取 DAO 类** 在 `execute` 方法中，您可以使用 `ApplicationContext` 获取所需的 DAO 类。然后，您可以使用 DAO 类执行 DDL/DML 操作。 ```java @Override public void execute(Database database) throws CustomChangeException { ApplicationContext context = ApplicationContextProvider.getApplicationContext(); RouteDao routeDao = context.getBean(RouteDao.class); // DDL 或 DML 操作 routeDao.save(route); } ``` **3. 使用 `JdbcTemplate` 进行 SQL 操作** 您可以使用 `JdbcTemplate` 对象进行 SQL 操作。例如，以下代码将插入多个记录到 `users` 表中： ```java @Override public void execute(Database database) throws CustomChangeException { JdbcTemplate jdbcTemplate = new JdbcTemplate(database); jdbcTemplate.insert("INSERT INTO users (name, email) VALUES (?, ?)", "John Doe", "john.doe@example.com"); } ``` **4. 使用 `CustomSQL` 进行 SQL 操作** 您可以使用 `CustomSQL` 对象进行 SQL 操作。`CustomSQL` 是一个包含 SQL 语句的字符串的类。 ```java @Override public void execute(Database database) throws CustomChangeException { CustomSQL sql = new CustomSQL("CREATE TABLE my_table (column1 INT, column2 VARCHAR(10))"); sql.execute(); } ``` **注意：** * `CustomChange` 是一个抽象类，需要继承 `TaskChange`。 * `Database` 对象用于执行 DDL/DML 操作。 * `JdbcTemplate` 和 `CustomSQL` 对象用于执行 SQL 操作。

正文

liquibase customChange

liquibase changeset 执行Java代码。

liquibase支持yml等文件，支持引入sql文件，还支持Java这种方式执行change。

对于执行 DDL DML 使用sql很方便，但是我想执行一些数据处理，将几个表中的数据放到新建的表中，那么就需要写存储过程。liquibase文档中支持使用存储过程，但是他也支持使用customChange来使用Java代码。

customChange

先说sql文件的使用

maven：

        <dependency>
            <groupId>org.liquibase</groupId>
            <artifactId>liquibase-core</artifactId>
        </dependency>

application.yml

spring:
  liquibase:
    change-log: classpath:db/changelog/db.changelog-master.yml
    enabled: true
 
 ----------------------------
 spring数据库相关的配置 .......

目录结构

db.changelog-master.yml文件部分内容

databaseChangeLog:
  - preConditions:
      - dbms:
          type: mysql
      - runningAs:
          username: root
  - changeSet:
      id: 202308081722
      author: keboom
      changes:
        - sqlFile:
            dbms: mysql
            endDelimiter: ";"
            encoding: "UTF-8"
            path: classpath:/db/changelog/changes/add_board_manager.sql
  - changeSet:
      id: 202308090949
      author: keboom
      changes:
        - sqlFile:
            dbms: mysql
            endDelimiter: ";"
            encoding: "UTF-8"
            path: classpath:/db/changelog/changes/dest_device_table_add_isSDI_column.sql

然后启动项目即可使用。

再说Java文件的使用

在db.changelog-master.yml文件新添加：

  - changeSet:
      id: 202308111016
      author: keboom
      changes:
        - customChange: { "class": "com.example.web.changelog.InitRouteDestRel" }

InitRouteDestRel 类如下：

public class InitRouteDestRel implements CustomTaskChange {

    @Override
    public void execute(Database database) throws CustomChangeException {
        ApplicationContext context = ApplicationContextProvider.getApplicationContext();
        RouteDao routeDao = context.getBean(RouteDao.class);
        RouteDestRelDao routeDestRelDao = context.getBean(RouteDestRelDao.class);

        List<Route> routeList = routeDao.list();
        LinkedList<RouteDestRelDO> insertCollections = new LinkedList<>();
        for (Route route : routeList) {
            String destIds = route.getDestIds();
            if (StringUtils.isEmpty(destIds)) {
                continue;
            }
            String[] destArr = StringUtils.split(destIds, ",");
            for (String s : destArr) {
                RouteDestRelDO routeDestRelDO = new RouteDestRelDO(route.getId(), Integer.valueOf(s));
                insertCollections.add(routeDestRelDO);
            }
        }
        routeDestRelDao.saveBatch(insertCollections);


    }

    @Override
    public String getConfirmationMessage() {
        return null;
    }

    @Override
    public void setUp() throws SetupException {

    }

    @Override
    public void setFileOpener(ResourceAccessor resourceAccessor) {

    }

    @Override
    public ValidationErrors validate(Database database) {
        return null;
    }
}

在execute方法里面执行要做的操作即可。但是liquibase这个是不归springboot管的，里面用各种注解，还是什么构造器注入都不行。我们可以通过获得ApplicationContext来获得想要的 dao 类。

参考：https://www.baeldung.com/spring-get-current-applicationcontext

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;

/**
 * {@code @author:} keboom
 * {@code @date:} 2023/8/11
 * {@code @description:}
 */
@Component
public class ApplicationContextProvider implements ApplicationContextAware {
    private static ApplicationContext applicationContext;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        ApplicationContextProvider.applicationContext = applicationContext;
    }

    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }
}

参考：

stackoverflow-use other spring beans in liquibase customtaskchange