使用Flyway进行Java数据库版本控制的操作指南

<dependencies>
    <dependency>
        <groupId>org.flywaydb</groupId>
        <artifactId>flyway-core</artifactId>
        <version>9.16.1</version>
    </dependency>
    <!-- 数据库驱动依赖 -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.28</version>
    </dependency>
</dependencies>

spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase
spring.datasource.username=root
spring.datasource.password=password

# Flyway配置
spring.flyway.enabled=true
spring.flyway.locations=classpath:db/migration

-- V1__Create_person_table.sql
CREATE TABLE person (
    id INT AUTO_INCREMENT PRIMARY KEY,
    first_name VARCHAR(50),
    last_name VARCHAR(50)
);

package cn.juwatech.flyway;

import org.flywaydb.core.Flyway;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FlywayConfig {

    @Autowired
    private javax.sql.DataSource dataSource;

    @Bean
    public CommandLineRunner runFlyway() {
        return args -> {
            Flyway flyway = Flyway.configure()
                                  .dataSource(dataSource)
                                  .load();
            flyway.migrate();
        };
    }
}

mvn flyway:repair

package cn.juwatech.flyway;

import org.flywaydb.core.api.MigrationType;
import org.flywaydb.core.api.callback.Context;
import org.flywaydb.core.api.callback.Callback;
import org.flywaydb.core.api.callback.CallbackContext;
import org.flywaydb.core.api.callback.CallbackContextType;
import org.flywaydb.core.api.callback.Event;
import org.flywaydb.core.api.callback.Context;

public class V2__Add_age_column extends BaseJavaMigration {

    @Override
    public void migrate(Context context) throws Exception {
        context.getConnection().createStatement().execute("ALTER TABLE person ADD COLUMN age INT");
    }
}