flyway版本号_Flyway版本化管理数据库脚本

假如我们有一个叫shiny的项目&＃xff0c;它是由一个程序Shiny-Server 和一个数据库 Shiny-DB组成的;

简单结构图如下&＃xff1a;

image.png

但是很多时候&＃xff0c;现实开发团队是这样的&＃xff1a;

image.png

我们的项目shiny项目的运行环境是有多套的&＃xff0c;

我们擅长解决代码层面的问题。

版本控制工具git非常普遍而且好用

我们有持续集成和持续构建的工具

我们很好的定义了测试和生产环境的发布流程

image.png

但是我们的数据库的版本如何控制呢&＃xff1f;

image.png

当前现状

非常不幸的是我们还不能很好的处理数据库的版本管理问题&＃xff0c;

很多的项目依赖运维人员手动的执行SQL脚本&＃xff0c;

有的时候甚至为了快速解决bug去快速的在命令行上执行SQL脚本&＃xff0c;那么问题来了。

通常这些问题的答案是&＃xff1a;鬼知道。

引入目的

flyway解决了上面的这些问题。

目前Flyway支持的数据库还是挺多的&＃xff0c;包括&＃xff1a;

Oracle, SQL Server, SQL Azure, DB2, DB2 z/OS,

MySQL(including Amazon RDS), MariaDB,

Google Cloud SQL, PostgreSQL(including Amazon RDS and Heroku),

Redshift, Vertica, H2, Hsql, Derby, SQLite, SAP HANA,

solidDB, Sybase ASE and Phoenix。

Flyway的执行流程

Flyway是一款开源的数据库版本管理工具&＃xff0c;

它更倾向于规约优于配置的方式。

Flyway可以独立于应用实现管理并跟踪数据库变更&＃xff0c;支持数据库版本自动升级&＃xff0c;

并且有一套默认的规约&＃xff0c;不需要复杂的配置&＃xff0c;

Migrations可以写成SQL脚本&＃xff0c;也可以写在Java代码中&＃xff0c;

不仅支持Command Line和Java API&＃xff0c;还支持Build构建工具和Spring Boot等&＃xff0c;

同时在分布式环境下能够安全可靠地升级数据库&＃xff0c;同时也支持失败恢复等。

Flyway工作流程.png

每次不管是数据库的表结构或者表数据的变更&＃xff0c;

你只需要把问题当成一次数据库的升级&＃xff0c;

简单的创建一个比当前版本更高的版本的迁移SQL文件或者Java文件&＃xff0c;

下次Flyway启动的时候&＃xff0c;他会找到这些脚本并把它更新到数据库。

脚本或者Java迁移脚本的命名规则&＃xff1a;

其中的文件名由以下部分组成&＃xff0c;除了使用默认配置外&＃xff0c;某些部分还可自定义规则。

prefix: 可配置&＃xff0c;前缀标识&＃xff0c;默认值V表示Versioned&＃xff0c;R表示Repeatable

version: 标识版本号&＃xff0c;由一个或多个数字构成&＃xff0c;数字之间的分隔符可用点.或下划线_

separator: 可配置&＃xff0c;用于分隔版本标识与描述信息&＃xff0c;默认为两个下划线__

description: 描述信息&＃xff0c;文字之间可以用下划线或空格分隔

suffix: 可配置&＃xff0c;后续标识&＃xff0c;默认为.sql

实现路径

真实项目版本更新场景中&＃xff0c;我们不可能再基于人力去做这件事情&＃xff0c;我们选择的是API的方式。

使用步骤如下&＃xff1a;

API方式使用Flyway.png

一般大家都是写SQL脚本&＃xff0c;也支持通过写Java代码的方式来实现。

Java方式写迁移功能

使用步骤&＃xff1a;

Java代码方式写迁移代码.png

目前的集成方式

使用的是springboot的方式集成了Flyway;

COLA引入Flyway的流程.png

配置参数&＃xff1a;可自行翻译和参考选择去配置

flyway.baseline-description&＃61; # The description to tag an existing schema with when executing baseline.

flyway.baseline-version&＃61;1 # Version to start migration.

flyway.baseline-on-migrate&＃61;false # Whether to execute migration against a non-empty schema with no metadata table

flyway.check-location&＃61;false # Check that migration scripts location exists.

flyway.clean-on-validation-error&＃61;false # will clean all objects. Warning! Do NOT enable in production!

flyway.enabled&＃61;true # Enable flyway.

flyway.encoding&＃61;UTF-8 # The encoding of migrations.

flyway.ignore-failed-future-migration&＃61;true # Ignore future migrations when reading the metadata table.

flyway.init-sqls&＃61; # SQL statements to execute to initialize a connection immediately after obtaining it.

flyway.locations&＃61;classpath:db/migration # locations of migrations scripts.

flyway.out-of-order&＃61;false # Allows migrations to be run "out of order".

flyway.placeholder-prefix&＃61; # The prefix of every placeholder.

flyway.placeholder-replacement&＃61;true # Whether placeholders should be replaced.

flyway.placeholder-suffix&＃61;} # The suffix of every placeholder.

flyway.placeholders.*&＃61; # Placeholders to replace in Sql migrations.

flyway.schemas&＃61; # Default schema of the connection and updating

flyway.sql-migration-prefix&＃61;V # The file name prefix for Sql migrations

flyway.sql-migration-separator&＃61;__ # The file name separator for Sql migrations

flyway.sql-migration-suffix&＃61;.sql # The file name suffix for Sql migrations

flyway.table&＃61;schema_version # The name of Flyway&＃39;s metadata table.

flyway.url&＃61; # JDBC url of the database to migrate. If not set, the primary configured data source is used.

flyway.user&＃61; # Login user of the database to migrate. If not set, use spring.datasource.username value.

flyway.password&＃61; # JDBC password if you want Flyway to create its own DataSource.

flyway.validate-on-migrate&＃61;true # Validate sql migration CRC32 checksum in classpath.

package db.migration;

/**

* &＃64;author carter

* create_date 2020/8/13 17:39

* description java数据库变更模板代码

*/

import lombok.extern.slf4j.Slf4j;

import org.flywaydb.core.api.migration.BaseJavaMigration;

import org.flywaydb.core.api.migration.Context;

import java.sql.ResultSet;

import java.sql.Statement;

&＃64;Slf4j

public class V2__test extends BaseJavaMigration {

&＃64;Override

public void migrate(Context context) throws Exception {

try (Statement select &＃61; context.getConnection().createStatement()) {

try (ResultSet rows &＃61; select.executeQuery("SELECT 1")) {

while (rows.next()) {

int id &＃61; rows.getInt(1);

String anonymizedName &＃61; "Anonymous" &＃43; id;

log.info("执行sql脚本:{}",anonymizedName);

}

}

}

}

}

资料来源

如有问题&＃xff0c;请留言。

原创不易&＃xff0c;关注诚可贵&＃xff0c;转发价更高&＃xff01;转载请注明出处&＃xff0c;让我们互通有无&＃xff0c;共同进步&＃xff0c;欢迎沟通交流。

我会持续分享Java软件编程知识和程序员发展职业之路&＃xff0c;欢迎关注&＃xff01;