fm453/nocobase
1
0
Fork 0
mirror of https://gitee.com/nocobase/nocobase.git synced 2025-05-05 13:39:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(plugin-workflow-manual): fix migration (#6484)

Browse Source
This commit is contained in:
Junyi 2025-03-17 12:27:42 +08:00 committed by GitHub
parent ed35d0995e
commit 26d858ae18
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 115 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
packages/plugins/@nocobase/plugin-workflow-manual/src/server/__tests__/migrations/20250312100513-change-table-name.test.ts
View File

@ -281,4 +281,72 @@ describe('20250225175712-change-table-name.test', () => {
await app.destroy(); await app.destroy();
}); });
skipSqlite(`1.6.0 -> 1.6.2, wrong migration executed (with id)`, async () => {
const app = await createMockServer();
await app.version.update('1.5.0');
app.db.collection({
name: 'workflowManualTasks',
migrationRules: ['schema-only'],
shared: true,
autoGenId: false,
fields: [
{
type: 'bigInt',
name: 'id',
},
{
type: 'bigInt',
name: 'userId',
primaryKey: true,
},
{
type: 'bigInt',
name: 'jobId',
primaryKey: true,
},
],
});
await app.db.sync();
app.db.removeCollection('workflowManualTasks');
const migration = new Migration({ db: app.db, app } as any);
await migration.up();
app.db.collection({
...workflowManualTasks,
});
await app.db.sync();
await app.destroy();
});
skipSqlite(`1.6.0 -> 1.6.2, wrong migration executed`, async () => {
const app = await createMockServer();
await app.version.update('1.5.0');
app.db.collection({
name: 'workflowManualTasks',
migrationRules: ['schema-only'],
shared: true,
autoGenId: false,
fields: [
{
type: 'bigInt',
name: 'userId',
primaryKey: true,
},
{
type: 'bigInt',
name: 'jobId',
primaryKey: true,
},
],
});
await app.db.sync();
app.db.removeCollection('workflowManualTasks');
const migration = new Migration({ db: app.db, app } as any);
await migration.up();
app.db.collection({
...workflowManualTasks,
});
await app.db.sync();
await app.destroy();
});
}); });

47
packages/plugins/@nocobase/plugin-workflow-manual/src/server/migrations/20250312100513-change-table-name.ts
View File

@ -32,6 +32,53 @@ export default class extends Migration {
const exists = await queryInterface.tableExists(oldTableName); const exists = await queryInterface.tableExists(oldTableName);
if (!exists) { if (!exists) {
const newColumns = await queryInterface.describeTable(newTableName);
const newPrimaryKeys = Object.values(newColumns).filter((c) => c.primaryKey);
if (newPrimaryKeys.length > 1) {
// @ts-ignore
const constraints: any = await queryInterface.showConstraint(newTableName);
await db.sequelize.transaction(
{
isolationLevel: Transaction.ISOLATION_LEVELS.SERIALIZABLE,
},
async (transaction) => {
if (this.db.isPostgresCompatibleDialect()) {
const primaryKeys = constraints.filter((item) => item.constraintType === 'PRIMARY KEY');
if (primaryKeys.length) {
for (const primaryKey of primaryKeys) {
await queryInterface.removeConstraint(newTableName, primaryKey.constraintName, { transaction });
}
}
} else if (this.db.isMySQLCompatibleDialect()) {
const idExists = await workflowManualTasksCollection.getField('id').existsInDb();
if (!idExists) {
await db.sequelize.query(`ALTER TABLE ${newTableNameWithQuotes} ADD COLUMN id BIGINT;`, {
transaction,
});
await db.sequelize.query(`ALTER TABLE ${newTableNameWithQuotes} DROP PRIMARY KEY`, {
transaction,
});
await db.sequelize.query(`ALTER TABLE ${newTableNameWithQuotes} ADD PRIMARY KEY (id)`, {
transaction,
});
await db.sequelize.query(
`ALTER TABLE ${newTableNameWithQuotes} MODIFY COLUMN id BIGINT AUTO_INCREMENT`,
{
transaction,
},
);
} else {
await db.sequelize.query(`ALTER TABLE ${newTableNameWithQuotes} DROP PRIMARY KEY`, {
transaction,
});
await db.sequelize.query(`ALTER TABLE ${newTableNameWithQuotes} ADD PRIMARY KEY (id)`, {
transaction,
});
}
}
},
);
}
return; return;
} }
const oldColumns = await queryInterface.describeTable(oldTableName); const oldColumns = await queryInterface.describeTable(oldTableName);