Java 中怎么用 JDBC 实现简单的数据库迁移脚本-java教程-PHP中文网

java中用jdbc实现轻量数据库迁移的核心是手动控制sql执行顺序、记录已执行版本、安全执行变更；通过schema_version表追踪版本，按命名规则扫描sql脚本，逐条执行并事务化提交。

java 中怎么用 jdbc 实现简单的数据库迁移脚本

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/）：

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();
        }
    }
}</migrationscript></string>

注意点：

拆分 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 的迁移；敏感操作建议人工审核后执行。

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南