Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

n8n-3671-node-improvement-postgres-types-in-output #3360

Merged
merged 3 commits into from
Jul 10, 2022
Merged

n8n-3671-node-improvement-postgres-types-in-output #3360

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
4f4699c
:hammer: fix
michael-radency May 23, 2022
ca87eb0
Merge branch 'master' of https://github.com/n8n-io/n8n into n8n-3671-…
michael-radency May 24, 2022
30a6310
:zap: ui update
michael-radency May 24, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 28 additions & 0 deletions packages/nodes-base/nodes/Postgres/Postgres.node.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -227,6 +227,24 @@ export class Postgres implements INodeType {
default: 'multiple',
description: 'The way queries should be sent to database. Can be used in conjunction with <b>Continue on Fail</b>. See <a href="https://docs.n8n.io/nodes/n8n-nodes-base.postgres/">the docs</a> for more examples',
},
{
displayName: 'Output Large-Format Numbers As',
name: 'largeNumbersOutput',
type: 'options',
options: [
{
name: 'Numbers',
value: 'numbers',
},
{
name: 'Text',
value: 'text',
description: 'Use this if you expect numbers longer than 16 digits (otherwise numbers may be incorrect)',
},
],
hint: 'Applies to NUMERIC and BIGINT columns only',
default: 'text',
},
{
displayName: 'Query Parameters',
name: 'queryParams',
Expand All @@ -249,9 +267,19 @@ export class Postgres implements INodeType {

async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const credentials = await this.getCredentials('postgres');
const largeNumbersOutput = this.getNodeParameter('additionalFields.largeNumbersOutput', 0, '') as string;

const pgp = pgPromise();

if (largeNumbersOutput === 'numbers') {
pgp.pg.types.setTypeParser(20, (value: string) => {
return parseInt(value, 10);
});
pgp.pg.types.setTypeParser(1700, (value: string) => {
return parseFloat(value);
});
}

const config: IDataObject = {
host: credentials.host as string,
port: credentials.port as number,
Expand Down