Java中用JDBC实现轻量数据库迁移的核心是手动控制SQL执行顺序、记录已执行版本、安全执行变更；通过schema_version表追踪版本，按命名规则扫描SQL脚本，逐条执行并事务化提交。
Java 中用 JDBC 实现简单的数据库迁移脚本，核心是**手动控制 SQL 执行顺序 + 记录已执行版本 + 安全执行变更**。不需要引入 Liquibase 或 Flyway，适合轻量项目或学习理解迁移原理。
1. 设计迁移元数据表
先在目标数据库中建一张表（如 schema_version），用于记录哪些脚本已执行：
CREATE TABLE schema_version ( id BIGINT PRIMARY KEY AUTO_INCREMENT, version VARCHAR(20) NOT NULL UNIQUE, description VARCHAR(200), script TEXT NOT NULL, installed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP );
关键字段：version（如 "V1_0", "V1_1"）用于排序和去重；script 可选存原始 SQL，便于审计。
2. 编写可扫描的迁移脚本文件
把 SQL 迁移语句按命名规则放在 classpath 下（如 src/main/resources/migrations/）：
立即学习“Java免费学习笔记（深入）”；
- V1_0__init_table.sql
- V1_1__add_email_index.sql
- V1_2__alter_user_add_status.sql
命名格式建议：V{主版本}_{次版本}__{描述}.sql，确保字典序即执行序。脚本内容就是纯 SQL（支持多语句，用分号分隔）。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
3. JDBC 迁移执行器（核心逻辑）
用标准 JDBC 加载驱动、连接数据库，读取并按序执行未运行的脚本：
public class SimpleMigration {
private final String url;
private final String user;
private final String password;
public SimpleMigration(String url, String user, String password) {
this.url = url;
this.user = user;
this.password = password;
}
public void migrate() throws SQLException {
try (Connection conn = DriverManager.getConnection(url, user, password)) {
// 1. 确保元数据表存在
initVersionTable(conn);
// 2. 查询已执行的 version 列表
Set<String> applied = getAppliedVersions(conn);
// 3. 扫描 classpath 中所有迁移文件，按 version 排序
List<MigrationScript> pending = scanMigrationScripts()
.stream()
.filter(script -> !applied.contains(script.version))
.sorted(Comparator.comparing(s -> s.version))
.collect(Collectors.toList());
// 4. 逐个执行
for (MigrationScript script : pending) {
executeScript(conn, script);
markAsApplied(conn, script);
System.out.println("✅ Applied: " + script.version);
}
}
}
private void executeScript(Connection conn, MigrationScript script) throws SQLException {
try (Statement stmt = conn.createStatement()) {
// 拆分并执行每条语句（简单处理，不支持存储过程等复杂语法）
for (String sql : script.content.split(";")) {
sql = sql.trim();
if (!sql.isEmpty()) {
stmt.execute(sql);
}
}
}
}
private void markAsApplied(Connection conn, MigrationScript script) throws SQLException {
String sql = "INSERT INTO schema_version (version, description, script) VALUES (?, ?, ?)";
try (PreparedStatement ps = conn.prepareStatement(sql)) {
ps.setString(1, script.version);
ps.setString(2, script.description);
ps.setString(3, script.content);
ps.executeUpdate();
}
}
}
注意点：
- 拆分 SQL 用 分号，但需跳过空行和注释（生产环境建议用更健壮的 SQL 解析，如 JSqlParser）
- 每个脚本执行前后加事务控制（
conn.setAutoCommit(false)+commit/rollback）更安全 -
initVersionTable 用
CREATE TABLE IF NOT EXISTS避免重复建表报错
4. 启动迁移（例如在 main 或 Spring Boot CommandLineRunner 中）
只需一行调用：
new SimpleMigration(
"jdbc:mysql://localhost:3306/mydb?serverTimezone=UTC",
"root", "password"
).migrate();
首次运行会建表、执行全部脚本；后续运行只执行新增脚本，自动跳过已记录的 version。
不复杂但容易忽略：务必在测试库验证脚本，禁止在生产环境直接执行含 DROP 或 DELETE 的迁移；敏感操作建议人工审核后执行。
