如何用JavaScript实现一个支持版本迁移的数据库架构？

indexedDB.open()

onupgradeneeded

event.oldVersion

switch

oldVersion

newVersion

function openDatabaseWithMigrations() {
    return new Promise((resolve, reject) => {
        const DB_NAME = 'MyAppData';
        const DB_VERSION = 3; // 期望的最新版本

        const request = indexedDB.open(DB_NAME, DB_VERSION);

        request.onupgradeneeded = function(event) {
            const db = event.target.result;
            const transaction = event.target.transaction; // 获取当前升级事务
            console.log(`数据库升级中：从版本 ${event.oldVersion} 到版本 ${event.newVersion}`);

            switch (event.oldVersion) {
                case 0: // 数据库首次创建或从无版本状态升级
                    console.log("创建初始对象存储：users");
                    db.createObjectStore("users", { keyPath: "id", autoIncrement: true });
                    // 注意：这里没有break，允许“穿透”到下一个case，处理连续升级
                case 1: // 从版本1升级到版本2
                    console.log("从版本1升级到版本2：为users添加'email'索引");
                    // 确保对象存储存在，并获取它
                    if (!db.objectStoreNames.contains("users")) {
                         // 这通常不会发生，除非case 0被跳过或逻辑错误
                         db.createObjectStore("users", { keyPath: "id", autoIncrement: true });
                    }
                    const userStoreV1 = transaction.objectStore("users");
                    if (!userStoreV1.indexNames.contains("email")) {
                        userStoreV1.createIndex("email", "email", { unique: true });
                    }
                    // 继续穿透到下一个case
                case 2: // 从版本2升级到版本3
                    console.log("从版本2升级到版本3：为users添加'lastLogin'索引");
                    const userStoreV2 = transaction.objectStore("users");
                    if (!userStoreV2.indexNames.contains("lastLogin")) {
                        userStoreV2.createIndex("lastLogin", "lastLogin", { unique: false });
                    }
                    // 这里可以添加数据迁移逻辑，比如给所有现有用户添加一个默认的lastLogin字段
                    userStoreV2.openCursor().onsuccess = function(event) {
                        const cursor = event.target.result;
                        if (cursor) {
                            const user = cursor.value;
                            if (!user.lastLogin) {
                                user.lastLogin = new Date().toISOString(); // 默认值
                                cursor.update(user);
                            }
                            cursor.continue();
                        }
                    };
                    break; // 版本3是最新版本，这里停止穿透
            }
        };

        request.onsuccess = function(event) {
            const db = event.target.result;
            console.log("数据库打开成功，当前版本：", db.version);
            resolve(db);
        };

        request.onerror = function(event) {
            console.error("数据库打开失败：", event.target.errorCode);
            reject(event.target.errorCode);
        };
    });
}

// 调用示例
// openDatabaseWithMigrations().then(db => {
//     // 可以在这里使用db对象进行操作
// }).catch(error => {
//     console.error("处理数据库失败:", error);
// });

db-migrate

node-pg-migrate

migrations

up

down

// 示例：一个Node.js迁移脚本文件 (例如使用Sequelize)
// 文件名可能类似：20231027100000-create-users-table.js
module.exports = {
    up: async (queryInterface, Sequelize) => {
        await queryInterface.createTable('users', {
            id: {
                type: Sequelize.INTEGER,
                autoIncrement: true,
                primaryKey: true,
            },
            name: {
                type: Sequelize.STRING,
                allowNull: false,
            },
            email: {
                type: Sequelize.STRING,
                allowNull: false,
                unique: true,
            },
            createdAt: {
                type: Sequelize.DATE,
                allowNull: false,
            },
            updatedAt: {
                type: Sequelize.DATE,
                allowNull: false,
            },
        });
    },
    down: async (queryInterface, Sequelize) => {
        await queryInterface.dropTable('users');
    }
};

// 另一个迁移文件：20231027110000-add-lastLogin-to-users.js
module.exports = {
    up: async (queryInterface, Sequelize) => {
        await queryInterface.addColumn('users', 'lastLogin', {
            type: Sequelize.DATE,
            allowNull: true, // 可以为空，或者提供默认值
            defaultValue: null,
        });
    },
    down: async (queryInterface, Sequelize) => {
        await queryInterface.removeColumn('users', 'lastLogin');
    }
};

deleteObjectStore

onupgradeneeded

onupgradeneeded