mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-25 04:34:06 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(Postgres Node): Fix automatic column mapping (#7121)

Browse source 
NODE-757
This commit is contained in:
कारतोफ्फेलस्क्रिप्ट™ 2023-09-06 16:32:50 +02:00 committed by GitHub
parent 36a8e911e6
commit 92af1314fe
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
packages/nodes-base/nodes/Postgres/test/v2/operations.test.ts
View file

@ -89,7 +89,7 @@ describe('Test PostgresV2, deleteTable operation', () => {
}, },
], ],
}, },
options: { typeVersion: 2.1 }, options: { nodeVersion: 2.1 },
}; };
const nodeOptions = nodeParameters.options as IDataObject; const nodeOptions = nodeParameters.options as IDataObject;
@ -168,7 +168,7 @@ describe('Test PostgresV2, deleteTable operation', () => {
cachedResultName: 'my_table', cachedResultName: 'my_table',
}, },
deleteCommand: 'drop', deleteCommand: 'drop',
options: { typeVersion: 2.1 }, options: { nodeVersion: 2.1 },
}; };
const nodeOptions = nodeParameters.options as IDataObject; const nodeOptions = nodeParameters.options as IDataObject;
@ -256,7 +256,7 @@ describe('Test PostgresV2, insert operation', () => {
}, },
], ],
}, },
options: { typeVersion: 2.1 }, options: { nodeVersion: 2.1 },
}; };
const columnsInfo: ColumnInfo[] = [ const columnsInfo: ColumnInfo[] = [
{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' }, { column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },
@ -299,7 +299,7 @@ describe('Test PostgresV2, insert operation', () => {
mode: 'list', mode: 'list',
}, },
dataMode: 'autoMapInputData', dataMode: 'autoMapInputData',
options: { typeVersion: 2.1 }, options: { nodeVersion: 2.1 },
}; };
const columnsInfo: ColumnInfo[] = [ const columnsInfo: ColumnInfo[] = [
{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' }, { column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },
@ -509,7 +509,7 @@ describe('Test PostgresV2, update operation', () => {
}, },
options: { options: {
outputColumns: ['json', 'foo'], outputColumns: ['json', 'foo'],
typeVersion: 2.1, nodeVersion: 2.1,
}, },
}; };
const columnsInfo: ColumnInfo[] = [ const columnsInfo: ColumnInfo[] = [
@ -566,7 +566,7 @@ describe('Test PostgresV2, update operation', () => {
}, },
dataMode: 'autoMapInputData', dataMode: 'autoMapInputData',
columnToMatchOn: 'id', columnToMatchOn: 'id',
options: { typeVersion: 2.1 }, options: { nodeVersion: 2.1 },
}; };
const columnsInfo: ColumnInfo[] = [ const columnsInfo: ColumnInfo[] = [
{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' }, { column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },
@ -669,7 +669,7 @@ describe('Test PostgresV2, upsert operation', () => {
}, },
options: { options: {
outputColumns: ['json'], outputColumns: ['json'],
typeVersion: 2.1, nodeVersion: 2.1,
}, },
}; };
const columnsInfo: ColumnInfo[] = [ const columnsInfo: ColumnInfo[] = [
@ -726,7 +726,7 @@ describe('Test PostgresV2, upsert operation', () => {
}, },
dataMode: 'autoMapInputData', dataMode: 'autoMapInputData',
columnToMatchOn: 'id', columnToMatchOn: 'id',
options: { typeVersion: 2.1 }, options: { nodeVersion: 2.1 },
}; };
const columnsInfo: ColumnInfo[] = [ const columnsInfo: ColumnInfo[] = [
{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' }, { column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },

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

@ -162,7 +162,7 @@ export async function execute(
db: PgpDatabase, db: PgpDatabase,
): Promise<INodeExecutionData[]> { ): Promise<INodeExecutionData[]> {
items = replaceEmptyStringsByNulls(items, nodeOptions.replaceEmptyStrings as boolean); items = replaceEmptyStringsByNulls(items, nodeOptions.replaceEmptyStrings as boolean);
const nodeVersion = nodeOptions.typeVersion as number; const nodeVersion = nodeOptions.nodeVersion as number;
let schema = this.getNodeParameter('schema', 0, undefined, { let schema = this.getNodeParameter('schema', 0, undefined, {
extractValue: true, extractValue: true,

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

@ -199,7 +199,7 @@ export async function execute(
db: PgpDatabase, db: PgpDatabase,
): Promise<INodeExecutionData[]> { ): Promise<INodeExecutionData[]> {
items = replaceEmptyStringsByNulls(items, nodeOptions.replaceEmptyStrings as boolean); items = replaceEmptyStringsByNulls(items, nodeOptions.replaceEmptyStrings as boolean);
const nodeVersion = nodeOptions.typeVersion as number; const nodeVersion = nodeOptions.nodeVersion as number;
let schema = this.getNodeParameter('schema', 0, undefined, { let schema = this.getNodeParameter('schema', 0, undefined, {
extractValue: true, extractValue: true,

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

@ -198,7 +198,7 @@ export async function execute(
db: PgpDatabase, db: PgpDatabase,
): Promise<INodeExecutionData[]> { ): Promise<INodeExecutionData[]> {
items = replaceEmptyStringsByNulls(items, nodeOptions.replaceEmptyStrings as boolean); items = replaceEmptyStringsByNulls(items, nodeOptions.replaceEmptyStrings as boolean);
const nodeVersion = nodeOptions.typeVersion as number; const nodeVersion = nodeOptions.nodeVersion as number;
let schema = this.getNodeParameter('schema', 0, undefined, { let schema = this.getNodeParameter('schema', 0, undefined, {
extractValue: true, extractValue: true,