mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-13 05:47:31 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix(core): Use table-prefixes in queries in import commands (#5887)

Browse source
This commit is contained in:
कारतोफ्फेलस्क्रिप्ट™ 2023-04-03 14:32:49 +02:00 committed by GitHub
parent 32c4eef574
commit ddbfcc7d93
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
packages/cli/src/commands/import/credentials.ts
View file

@ -169,8 +169,9 @@ export class ImportCredentialsCommand extends BaseCommand {
['credentialsId', 'userId'], ['credentialsId', 'userId'],
); );
if (config.getEnv('database.type') === 'postgresdb') { if (config.getEnv('database.type') === 'postgresdb') {
const tablePrefix = config.getEnv('database.tablePrefix');
await this.transactionManager.query( await this.transactionManager.query(
"SELECT setval('credentials_entity_id_seq', (SELECT MAX(id) from credentials_entity))", `SELECT setval('${tablePrefix}credentials_entity_id_seq', (SELECT MAX(id) from ${tablePrefix}credentials_entity))`,
); );
} }
} }

3
packages/cli/src/commands/import/workflow.ts
View file

@ -228,8 +228,9 @@ export class ImportWorkflowsCommand extends BaseCommand {
['workflowId', 'userId'], ['workflowId', 'userId'],
); );
if (config.getEnv('database.type') === 'postgresdb') { if (config.getEnv('database.type') === 'postgresdb') {
const tablePrefix = config.getEnv('database.tablePrefix');
await this.transactionManager.query( await this.transactionManager.query(
"SELECT setval('workflow_entity_id_seq', (SELECT MAX(id) from workflow_entity))", `SELECT setval('${tablePrefix}workflow_entity_id_seq', (SELECT MAX(id) from "${tablePrefix}workflow_entity"))`,
); );
} }
} }