之前已經(jīng)介紹了很多在Spring Boot中使用MySQL的案例，包含了Spring Boot最原始的JdbcTemplate、Spring Data JPA以及我們國內(nèi)最常用的MyBatis。同時，對于一些復(fù)雜場景比如：更換Druid數(shù)據(jù)源，或是多數(shù)據(jù)源的情況也都做了介紹。

不論我們使用哪一個具體實現(xiàn)框架，都離不開對數(shù)據(jù)庫表結(jié)構(gòu)的管理。而這一類管理一直都存在一個問題：由于數(shù)據(jù)庫表元數(shù)據(jù)存儲于數(shù)據(jù)庫中，而我們的訪問邏輯都存在于Git或其他代碼倉庫中。Git已經(jīng)幫助我們完成了代碼的多版本管理，那么數(shù)據(jù)庫中的表該如何做好版本控制呢？

今天我們就來介紹在Spring Boot中使用Flyway來管理數(shù)據(jù)庫版本的方法。

Flyway簡介

Flyway是一個簡單開源數(shù)據(jù)庫版本控制器(約定大于配置)，主要提供migrate、clean、info、validate、baseline、repair等命令。它支持SQL(PL/SQL、T-SQL)方式和Java方式，支持命令行客戶端等，還提供一系列的插件支持(Maven、Gradle、SBT、ANT等)。

官方網(wǎng)站：https://flywaydb.org/

本文對于Flyway的自身功能不做過多的介紹，讀者可以通過閱讀官方文檔或利用搜索引擎獲得更多資料。下面我們具體說說在Spring Boot應(yīng)用中的應(yīng)用，如何使用Flyway來創(chuàng)建數(shù)據(jù)庫以及結(jié)構(gòu)不一致的檢查。

動手試試

下面我們先預(yù)設(shè)一個開發(fā)目標(biāo)：

假設(shè)我們需要開發(fā)一個用戶管理系統(tǒng)，那么我們勢必要設(shè)計一張用戶表，并實現(xiàn)對用戶表的增刪改查操作。

在任務(wù)1的功能完成之后，我們又有一個新需求，需要對用戶表增加了一個字段，看看如何實現(xiàn)對數(shù)據(jù)庫表結(jié)構(gòu)的更改。

目標(biāo) 1 的實現(xiàn)

第一步：創(chuàng)建一個基礎(chǔ)的Spring Boot項目，并在pom.中加入Flyway、MySQL連接和數(shù)據(jù)訪問相關(guān)的必要依賴(這里選用spring-boot-starter-jdbc作為例子)

org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-jdbcmysqlmysql-connector-javaorg.flywaydbflyway-coreorg.projectlomboklombokprovidedorg.springframework.bootspring-boot-starter-testtest

第二步：按Flyway的規(guī)范創(chuàng)建版本化的SQL腳本。

在工程的src/main/resources目錄下創(chuàng)建db目錄，在db目錄下再創(chuàng)建migration目錄

在migration目錄下創(chuàng)建版本化的SQL腳本V1__Base_version.sql

DROP TABLE IF EXISTS user ;CREATE TABLE `user` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵', `name` varchar(20) NOT NULL COMMENT '姓名', `age` int(5) DEFAULT NULL COMMENT '年齡', PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

注意：如果你不想將SQL腳本放到其他目錄，可以用spring.flyway.locations參數(shù)來配置。這里不同于1.x版本的配置項flyway.locations

第三步：根據(jù)User表的結(jié)構(gòu)，編寫對應(yīng)的實體定義

@Data@NoArgsConstructorpublic class User { private Long id; private String name; private Integer age;}

第四步：編寫用戶操作接口和實現(xiàn)

public interface UserService { /** * 新增一個用戶 * * @param name * @param age */ int create(String name, Integer age); /** * 根據(jù)name查詢用戶 * * @param name * @return */ List getByName(String name); /** * 根據(jù)name刪除用戶 * * @param name */ int deleteByName(String name); /** * 獲取用戶總量 */ int getAllUsers(); /** * 刪除所有用戶 */ int deleteAllUsers();}@Servicepublic class UserServiceImpl implements UserService { private JdbcTemplate jdbcTemplate; UserServiceImpl(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } @Override public int create(String name, Integer age) { return jdbcTemplate.update("insert into USER(NAME, AGE) values(?, ?)", name, age); } @Override public List getByName(String name) { List users = jdbcTemplate.query("select * from USER where NAME = ?", (resultSet, i) -> { User user = new User(); user.setId(resultSet.getLong("ID")); user.setName(resultSet.getString("NAME")); user.setAge(resultSet.getInt("AGE")); return user; }, name); return users; } @Override public int deleteByName(String name) { return jdbcTemplate.update("delete from USER where NAME = ?", name); } @Override public int getAllUsers() { return jdbcTemplate.queryForObject("select count(1) from USER", Integer.class); } @Override .........

總結(jié)

以上是生活随笔為你收集整理的flyway常用配置_Spring Boot 2.x基础教程：使用Flyway管理数据库版本的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。