TypeORM：初始化后动态管理实体集合的策略

// entity/Product.ts
import { Entity, PrimaryGeneratedColumn, Column } from "typeorm";

@Entity()
export class Product {
    @PrimaryGeneratedColumn()
    id: number;

    @Column()
    name: string; // 示例：添加更多属性以完整定义实体
}

// data-source.ts
import { DataSource } from "typeorm";
import { Product } from "./entity/Product"; // 引入Product实体

export const AppDataSource = new DataSource({
    type: "postgres",
    host: "localhost",
    port: 5432,
    username: "engineerhead",
    password: "",
    database: "test",
    synchronize: true, // 生产环境不推荐使用synchronize: true
    logging: false,
    entities: [Product], // 在此处定义初始实体集合
    migrations: [],
    subscribers: [],
});

export default async () => {
    if (!AppDataSource.isInitialized) {
        await AppDataSource.initialize();
        console.log("DataSource initialized successfully.");
    }
};

// setup.ts
import initDB from "./data-source";

async function setupApplication() {
    await initDB();
    // 应用程序的其他初始化逻辑
}

setupApplication().catch(error => console.error("Failed to initialize application:", error));

// 假设这是您的动态实体集合
let currentEntities = [Product];

async function updateDataSource(newEntity: any) {
    if (AppDataSource.isInitialized) {
        await AppDataSource.destroy(); // 销毁现有DataSource
        console.log("Old DataSource destroyed.");
    }

    currentEntities.push(newEntity); // 添加新实体到集合

    // 创建并初始化新的DataSource实例
    const newAppDataSource = new DataSource({
        // ... 其他配置与AppDataSource相同
        entities: currentEntities, // 使用更新后的实体集合
    });

    await newAppDataSource.initialize();
    console.log("New DataSource initialized with updated entities.");
    // 您可能需要更新全局引用的AppDataSource
    // AppDataSource = newAppDataSource; // 如果AppDataSource是可变的
}

// 示例：动态添加Cart实体
// 定义Cart实体
import { Entity as TypeORMEntity, PrimaryGeneratedColumn as TypeORMPrimaryGeneratedColumn } from "typeorm";

@TypeORMEntity()
export class Cart {
    @TypeORMPrimaryGeneratedColumn()
    id: number;
    // ... 其他Cart实体属性
}

// 在运行时调用
// await updateDataSource(Cart); // 这将关闭并重新初始化DataSource

// entity/DynamicConfig.ts
import { Entity, PrimaryGeneratedColumn, Column } from "typeorm";

@Entity()
export class DynamicConfig {
    @PrimaryGeneratedColumn()
    id: number;

    @Column({ unique: true })
    key: string; // 配置项的键名

    @Column({ type: "jsonb", nullable: true })
    value: object; // 使用JSONB存储任意结构的数据

    @Column({ type: "text", nullable: true })
    type: string; // 可选：记录数据类型，便于解析
}