Spring Boot中集成外部库Liquibase多Changelog迁移策略

package com.example.app;

import liquibase.integration.spring.SpringLiquibase;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn;
import javax.sql.DataSource;

@Configuration // 确保该配置类被Spring扫描到
public class MultipleLiquibaseConfiguration {

    /**
     * 为外部库定义Liquibase Bean
     * @param dataSource 数据库数据源
     * @return 外部库的SpringLiquibase实例
     */
    @Bean
    public SpringLiquibase liquibaseLib(DataSource dataSource) {
        SpringLiquibase liquibase = new SpringLiquibase();
        liquibase.setDataSource(dataSource);
        // 指定外部库的changelog文件路径
        liquibase.setChangeLog("classpath:library.xml"); 
        // 可以根据需要设置其他属性，如默认模式、上下文等
        // liquibase.setDefaultSchema("lib_schema");
        return liquibase;
    }

    /**
     * 为主项目定义Liquibase Bean
     * @param dataSource 数据库数据源
     * @return 主项目的SpringLiquibase实例
     */
    @Bean
    // 如果外部库的迁移必须在主项目之前执行，可以使用@DependsOn
    // @DependsOn("liquibaseLib") 
    public SpringLiquibase liquibaseMain(DataSource dataSource) {
        SpringLiquibase liquibase = new SpringLiquibase();
        liquibase.setDataSource(dataSource);
        // 指定主项目的changelog文件路径
        liquibase.setChangeLog("classpath:main.xml");
        // 可以根据需要设置其他属性
        return liquibase;
    }
}

# 主项目的Liquibase配置
spring.liquibase.change-log=classpath:/main.xml
# 可以继续配置其他spring.liquibase.*属性，如
# spring.liquibase.default-schema=public
# spring.liquibase.drop-first=false

# 外部库的Liquibase配置，使用自定义前缀 'lib.liquibase'
lib.liquibase.change-log=classpath:/library.xml
# 同样可以配置其他lib.liquibase.*属性，如
# lib.liquibase.default-schema=library_schema

package com.example.app;

import javax.sql.DataSource;
import liquibase.integration.spring.SpringLiquibase;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.liquibase.LiquibaseAutoConfiguration.LiquibaseConfiguration; // 注意：这是Spring Boot内部类，使用时需谨慎
import org.springframework.boot.autoconfigure.liquibase.LiquibaseDataSource;
import org.springframework.boot.autoconfigure.liquibase.LiquibaseProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.DependsOn;

@SpringBootApplication
@EnableConfigurationProperties({LiquibaseProperties.class}) // 启用LiquibaseProperties的绑定
public class Demo {

    public static void main(String[] args) {
        SpringApplication.run(Demo.class, args);
    }

    /**
     * 配置主项目的Liquibase Bean
     * @param dataSourceProvider 数据源提供者
     * @param liquibaseDataSourceProvider Liquibase专用的数据源提供者（如果有）
     * @param properties 主项目的Liquibase属性
     * @return 主项目的SpringLiquibase实例
     */
    @Bean // "main" liquibase
    // 如果外部库的迁移必须在主项目之前执行，可以使用@DependsOn
    // @DependsOn("liquibaseLib") 
    @ConfigurationProperties("spring.liquibase") // 绑定以"spring.liquibase"为前缀的属性
    public SpringLiquibase liquibase( 
        ObjectProvider<DataSource> dataSourceProvider,
        @LiquibaseDataSource ObjectProvider<DataSource> liquibaseDataSourceProvider,
        LiquibaseProperties properties) {
      return createSpringLiquibase(dataSourceProvider, liquibaseDataSourceProvider, properties);
    }

    /**
     * 配置外部库的Liquibase Bean
     * @param dataSourceProvider 数据源提供者
     * @param liquibaseDataSourceProvider Liquibase专用的数据源提供者（如果有）
     * @param properties 外部库的Liquibase属性
     * @return 外部库的SpringLiquibase实例
     */
    @Bean // lib liquibase
    @ConfigurationProperties("lib.liquibase") // 绑定以"lib.liquibase"为前缀的属性
    public SpringLiquibase liquibaseLib(
        ObjectProvider<DataSource> dataSourceProvider,
        @LiquibaseDataSource ObjectProvider<DataSource> liquibaseDataSourceProvider,
        LiquibaseProperties properties) {
      return createSpringLiquibase(dataSourceProvider, liquibaseDataSourceProvider, properties);
    }

    /**
     * 辅助方法，用于创建SpringLiquibase实例，复用Spring Boot的内部逻辑
     * 注意：LiquibaseConfiguration是Spring Boot的内部类，其API可能随版本变化。
     * 在生产环境，如果担心兼容性，可以考虑手动设置SpringLiquibase的属性。
     */
    private SpringLiquibase createSpringLiquibase(ObjectProvider<DataSource> dataSourceProvider,
        ObjectProvider<DataSource> liquibaseDataSourceProvider, LiquibaseProperties properties) {
      // 这里的LiquibaseConfiguration是Spring Boot内部用于创建SpringLiquibase的工具类
      // 它将LiquibaseProperties中的配置应用到SpringLiquibase实例上
      LiquibaseConfiguration helper = new LiquibaseConfiguration(properties);
      return helper.liquibase(dataSourceProvider, liquibaseDataSourceProvider);
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<databaseChangeLog
    xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog
        http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.0.xsd">

    <!-- 包含外部库的changelog -->
    <include file="classpath:library.xml"/>

    <!-- 主项目自身的变更集 -->
    <changeSet id="1" author="main_project">
        <createTable tableName="main_table">
            <column name="id" type="int" autoIncrement="true"><constraints primaryKey="true"/></column>
            <column name="name" type="varchar(255)"/>
        </createTable>
    </changeSet>

    <!-- 更多主项目的变更集 -->

</databaseChangeLog>