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

fix(Postgres Node): Tunnel doesn't always close (#7087)

Browse source
This commit is contained in:
Michael Kret 2023-09-04 13:26:02 +03:00 committed by GitHub
parent 400949daa4
commit 58e55ba669
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/nodes-base/nodes/Postgres/v2/actions/database/insert.operation.ts
View file

@ -135,7 +135,7 @@ const properties: INodeProperties[] = [
}, },
displayOptions: { displayOptions: {
show: { show: {
'@version': [2.2], '@version': [2.2, 2.3],
}, },
}, },
}, },

2
packages/nodes-base/nodes/Postgres/v2/actions/database/update.operation.ts
View file

@ -172,7 +172,7 @@ const properties: INodeProperties[] = [
}, },
displayOptions: { displayOptions: {
show: { show: {
'@version': [2.2], '@version': [2.2, 2.3],
}, },
}, },
}, },

2
packages/nodes-base/nodes/Postgres/v2/actions/database/upsert.operation.ts
View file

@ -171,7 +171,7 @@ const properties: INodeProperties[] = [
}, },
displayOptions: { displayOptions: {
show: { show: {
'@version': [2.2], '@version': [2.2, 2.3],
}, },
}, },
}, },

7
packages/nodes-base/nodes/Postgres/v2/methods/resourceMapping.ts
View file

@ -47,7 +47,7 @@ export async function getMappingColumns(
): Promise<ResourceMapperFields> { ): Promise<ResourceMapperFields> {
const credentials = await this.getCredentials('postgres'); const credentials = await this.getCredentials('postgres');
const { db } = await configurePostgres(credentials); const { db, sshClient } = await configurePostgres(credentials);
const schema = this.getNodeParameter('schema', 0, { const schema = this.getNodeParameter('schema', 0, {
extractValue: true, extractValue: true,
@ -88,5 +88,10 @@ export async function getMappingColumns(
return { fields }; return { fields };
} catch (error) { } catch (error) {
throw error; throw error;
} finally {
if (sshClient) {
sshClient.end();
}
await db.$pool.end();
} }
} }