GithubBackup/geekgeekrun
1
0
Fork 0
mirror of https://github.com/geekgeekrun/geekgeekrun.git synced 2026-07-07 07:11:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

add the logic for run migrate to process table schema change

Browse Source
This commit is contained in:
geekgeekrun
2024-10-19 18:00:48 +08:00
parent d026088811
commit 512fc94b1a
1 changed files with 38 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
packages/sqlite-plugin/src/migrations/1729182577167-UpdateChatStartupLogTable.ts
View File

@@ -1,18 +1,43 @@
import { MigrationInterface, QueryRunner } from "typeorm"
import { MigrationInterface, QueryRunner, TableColumn } from "typeorm";
const dropViewSql = `
DROP VIEW IF EXISTS "v_boss_library";
DROP VIEW IF EXISTS "v_chat_startup_log";
DROP VIEW IF EXISTS "v_company_library";
DROP VIEW IF EXISTS "v_job_library";
`;
const viewNames = [
"v_boss_library",
"v_chat_startup_log",
"v_company_library",
"v_job_library",
];
export class UpdateChatStartupLogTable1729182577167 implements MigrationInterface {
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(dropViewSql);
export class UpdateChatStartupLogTable1729182577167
implements MigrationInterface
{
public async up(queryRunner: QueryRunner): Promise<void> {
for (const viewName of viewNames) {
await queryRunner.query(`DROP VIEW IF EXISTS "${viewName}"`);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(dropViewSql);
if (await queryRunner.hasTable("boss_active_status_record")) {
if (await queryRunner.hasColumn("boss_active_status_record", "updateDate")) {
await queryRunner.query(
`ALTER TABLE boss_active_status_record RENAME COLUMN updateDate TO updateTime`
);
}
await queryRunner.changeColumn(
'boss_active_status_record',
'lastActiveStatus',
new TableColumn({
name: 'lastActiveStatus',
type: 'varchar',
isNullable: true
})
)
}
}
public async down(queryRunner: QueryRunner): Promise<void> {
for (const viewName of viewNames) {
await queryRunner.query(`DROP VIEW IF EXISTS "${viewName}"`);
}
await queryRunner.query(
`ALTER TABLE boss_active_status_record RENAME COLUMN updateTime TO updateDate`
);
}
}