技术派数据库表自动初始化（学习）

不需要在db中手动创建或者导入相关的schema、data，项目启动自动创建对应的表，并初始化。实现该过程。

Liquibase数据库版本管理

依赖配置

在paicoding-web模块中，pom.xml 文件中添加

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

然后就是核心配置，首先是application.yml配置文件中，有两个关键参数

spring:
  liquibase:
    change-log: classpath:liquibase/master.xml
    enabled: true # 当实际使用的数据库不支持liquibase，如 mariadb 时，将这个参数设置为false

说明：

对于使用的数据库不支持liquibase，如 mariadb 时，将这个参数设置为false
change-log：对应的是核心的数据库版本变更配置

master.xml文件中的内容如下：

<?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-3.5.xsd">

    <include file="liquibase/changelog/000_initial_schema.xml" relativeToChangelogFile="false"/>

</databaseChangeLog>

注意上面这个include，这个就是告诉liqubase，所有的变更记录，都放在

liquibase/changelog/000_initial_schema.xml这个文件中

现在只有一个include标签，但是实际上是可以有多个的，一个好的建议是，项目首次初始化表、初始化数据可以是一个include标签；后续每次大的版本迭代，对应一个新的include。

再看一下000_initial_schema.xml里面的文件内容

<?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-3.5.xsd">

    <property name="now" value="now()" dbms="mysql"/>
    <property name="autoIncrement" value="true"/>

    <changeSet id="00000000000001" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_schema_221209.sql"/>
    </changeSet>

    <changeSet id="00000000000002" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_data_221209.sql"/>
    </changeSet>

    <changeSet id="00000000000003" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_data_221210.sql"/>
    </changeSet>

    <changeSet id="00000000000005" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_data_221216.sql"/>
    </changeSet>

    <!--  专栏类型，新增免费开始时间、结束时间  -->
    <changeSet id="00000000000006" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/update_schema_221223.sql"/>
    </changeSet>

    <!-- user_info表添加ip字段，用于记录访问用户所在地   -->
    <changeSet id="00000000000007" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/update_schema_221229.sql"/>
    </changeSet>

    <!-- 配置表新增 extra 字段 -->
    <changeSet id="00000000000008" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/update_schema_230103.sql"/>
    </changeSet>

    <!-- 技术派介绍文章 -->
    <changeSet id="00000000000009" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_data_230103.sql"/>
    </changeSet>

    <!-- 重新更新标签 -->
    <changeSet id="00000000000012" author="LouZai">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_data_230105.sql"/>
    </changeSet>

    <!-- 添加审核中 -->
    <changeSet id="00000000000013" author="LouZai">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/init_data_230130.sql"/>
    </changeSet>

    <!-- 添加用户角色 -->
    <changeSet id="00000000000014" author="YiHui">
        <sqlFile dbms="mysql" endDelimiter=";" encoding="UTF-8" path="liquibase/data/update_schema_230131.sql"/>
    </changeSet>
</databaseChangeLog>

说明：

changeSet标签，id必须唯一，不能出现冲突
sqlFile里面的path，对应的可以是标准的sql文件，也可以是xml格式的数据库表定义、数据库操作文件
一旦写上去，changeSet的顺徐不要调整

比如库表创建的sql

项目演示

在技术派的项目中，还做了一个事情，就是初始化库，在下面的DataSourceInitializer中有介绍；如果是一个新的项目，接入Liquibase之后，数据库，请注意还是需要自己来创建的

项目启动之后，一切正常的话，直接连接上数据库可以看到库表创建成功，数据也初始化完成，当然也可以是直接观察控制台的输出。

下面红框中的ChangeSet xxx run successfully in 401ms 就表示对应的sql执行成功了

注意事项

非常重要的一个点是，上面的每个ChangeSet只会执行一次，因此当执行完毕之后发现不对，要回滚怎么办，或者需要修改怎么办？需要Liquibase提供的回滚机制。简单说明。

当Change执行完毕之后，对应的sql文件/xml文件（即path定义的文件）不允许在修改，因为db中会记录这个文件的md5，当修改这个文件之后，这个MD5也会随之发生改变

有两个方案解决：新增一个changeSte

删除DATABASECHANFELOG表中changeSet id对应的记录，然后重新走一遍

DataSourceInitializer首次初始化方案

我们这里主要借助DataSourceInitializer来实现初始化，其核心有两个配置

DatabasePopulator：通过addCcripts来指定对应的的sql文件
DataSourceInitializer#setEnable；判断是否需要执行初始化

我们主要借助DataSourceInitializer来实现Liquibase的表的创建、数据变更等操作；但是在此之前，我们还做了一个库的初始化

库初始化

接下来重点要看的就是needInit方法，我们在这个方法里面，需要判断数据库是否存在，若不存在时，则创建数据库；然后判断表是否存在，以此来决定是否需要执行初始化方法。

入口在实现ForumDataSourceInitializer

  /**
     * 检测一下数据库中表是否存在，若存在则不初始化；否则基于 schema-all.sql 进行初始化表
     *
     * @param dataSource
     * @return
     */
    private boolean needInit(DataSource dataSource) {
        if (autoInitDatabase()) {
            return true;
        }
        // 根据是否存在表来判断是否需要执行sql操作
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        List list = jdbcTemplate.queryForList("SELECT table_name FROM information_schema.TABLES where table_name = 'user_info' and table_schema = '" + database + "';");
        return CollectionUtils.isEmpty(list);
    }


    /**
     * 数据库不存在时，尝试创建数据库
     */
    private boolean autoInitDatabase() {
        // 查询失败，可能是数据库不存在，尝试创建数据库之后再次测试
        URI url = URI.create(SpringUtil.getConfig("spring.datasource.url").substring(5));
        String uname = SpringUtil.getConfig("spring.datasource.username");
        String pwd = SpringUtil.getConfig("spring.datasource.password");
        try (Connection connection = DriverManager.getConnection("jdbc:mysql://" + url.getHost() + ":" + url.getPort() +
                "?useUnicode=true&characterEncoding=UTF-8&useSSL=false", uname, pwd);
             Statement statement = connection.createStatement()) {
            ResultSet set = statement.executeQuery("select schema_name from information_schema.schemata where schema_name = '" + database + "'");
            if (!set.next()) {
                // 不存在时，创建数据库
                String createDb = "CREATE DATABASE IF NOT EXISTS " + database;
                connection.setAutoCommit(false);
                statement.execute(createDb);
                connection.commit();
                log.info("创建数据库（{}）成功", database);
                if (set.isClosed()) {
                    set.close();
                }
                return true;
            }
            set.close();
            log.info("数据库已存在，无需初始化");
            return false;
        } catch (SQLException e2) {
            throw new RuntimeException(e2);
        }
    }