插件升级开发文档

migration -> Upgrade -> data/versions/<version>

extensions/<identifier>/src/api/db/migrations/

extensions/<identifier>/build/db/migrations/

{timestamp}-{version}-{description}.js

1776000000000-0.0.3-add-article-status.ts

extensions_migrations_history

extensions/<identifier>/src/api/upgrade/<version>/index.ts

extensions/<identifier>/build/upgrade/<version>/index.js

extensions/simple-blog/src/api/upgrade/0.0.2/index.ts

import { DataSource } from "@buildingai/db/typeorm";
import { Logger } from "@nestjs/common";

export class Upgrade {
    private readonly logger = new Logger(Upgrade.name);

    constructor(private readonly dataSource: DataSource) {}

    async execute(): Promise<void> {
        this.logger.log("Start plugin upgrade 0.0.3");

        await this.dataSource.query(`
            UPDATE "simple_blog"."article"
            SET "status" = 'draft'
            WHERE "status" IS NULL
        `);

        this.logger.log("Plugin upgrade 0.0.3 completed");
    }
}

new Upgrade(this.dataSource).execute()

await this.dataSource.query(
    `
    UPDATE "simple_blog"."article"
    SET "status" = $1
    WHERE "status" IS NULL
    `,
    ["draft"],
);

const repo = this.dataSource.getRepository("Article");
const rows = await repo.find();

for (const row of rows) {
    row.status = row.status || "draft";
}

await repo.save(rows);

const queryRunner = this.dataSource.createQueryRunner();
await queryRunner.connect();
await queryRunner.startTransaction();

try {
    await queryRunner.query(`
        UPDATE "simple_blog"."article"
        SET "status" = 'draft'
        WHERE "status" IS NULL
    `);

    await queryRunner.query(`
        INSERT INTO "simple_blog"."setting" ("key", "value")
        VALUES ('default_status', 'draft')
    `);

    await queryRunner.commitTransaction();
} catch (error) {
    await queryRunner.rollbackTransaction();
    throw error;
} finally {
    await queryRunner.release();
}

extensions/<identifier>/package.json

build/upgrade/<version>/index.js

build/db/entities