awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-09-22 13:39:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

misc: updated statement timeout

Browse Source
This commit is contained in:
Sheen Capadngan
2025-10-29 02:41:47 +08:00
parent 71972f9ffb
commit 394f1ae2bb
1 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
backend/src/db/migrations/20251028160921_delete-no-org-identities.ts
View File

@@ -2,14 +2,24 @@ import { Knex } from "knex";
import { TableName } from "../schemas"; import { TableName } from "../schemas";
const MIGRATION_TIMEOUT = 30 * 60 * 1000; // 30 minutes
export async function up(knex: Knex): Promise<void> { export async function up(knex: Knex): Promise<void> {
const result = await knex.raw("SHOW statement_timeout");
const originalTimeout = result.rows[0].statement_timeout;
await knex.transaction(async (tx) => { await knex.transaction(async (tx) => {
const hasIdentityOrgCol = await tx.schema.hasColumn(TableName.Identity, "orgId"); try {
if (hasIdentityOrgCol) { await tx.raw(`SET statement_timeout = ${MIGRATION_TIMEOUT}`);
await tx(TableName.Identity).whereNull("orgId").delete(); const hasIdentityOrgCol = await tx.schema.hasColumn(TableName.Identity, "orgId");
await tx.schema.alterTable(TableName.Identity, (t) => { if (hasIdentityOrgCol) {
t.uuid("orgId").notNullable().alter(); await tx(TableName.Identity).whereNull("orgId").delete();
}); await tx.schema.alterTable(TableName.Identity, (t) => {
t.uuid("orgId").notNullable().alter();
});
}
} finally {
await knex.raw(`SET statement_timeout = '${originalTimeout}'`);
} }
}); });
} }