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

NODE-757
n8n-io · Sep 6, 2023 · 92af131 · 92af131
1 parent 36a8e91
commit 92af131
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 11 deletions.
diff --git a/packages/nodes-base/nodes/Postgres/test/v2/operations.test.ts b/packages/nodes-base/nodes/Postgres/test/v2/operations.test.ts
@@ -89,7 +89,7 @@ describe('Test PostgresV2, deleteTable operation', () => {
 					},
 				],
 			},
-			options: { typeVersion: 2.1 },
+			options: { nodeVersion: 2.1 },
 		};
 		const nodeOptions = nodeParameters.options as IDataObject;
 
@@ -168,7 +168,7 @@ describe('Test PostgresV2, deleteTable operation', () => {
 				cachedResultName: 'my_table',
 			},
 			deleteCommand: 'drop',
-			options: { typeVersion: 2.1 },
+			options: { nodeVersion: 2.1 },
 		};
 		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[] = [
 			{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },
@@ -299,7 +299,7 @@ describe('Test PostgresV2, insert operation', () => {
 				mode: 'list',
 			},
 			dataMode: 'autoMapInputData',
-			options: { typeVersion: 2.1 },
+			options: { nodeVersion: 2.1 },
 		};
 		const columnsInfo: ColumnInfo[] = [
 			{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },
@@ -509,7 +509,7 @@ describe('Test PostgresV2, update operation', () => {
 			},
 			options: {
 				outputColumns: ['json', 'foo'],
-				typeVersion: 2.1,
+				nodeVersion: 2.1,
 			},
 		};
 		const columnsInfo: ColumnInfo[] = [
@@ -566,7 +566,7 @@ describe('Test PostgresV2, update operation', () => {
 			},
 			dataMode: 'autoMapInputData',
 			columnToMatchOn: 'id',
-			options: { typeVersion: 2.1 },
+			options: { nodeVersion: 2.1 },
 		};
 		const columnsInfo: ColumnInfo[] = [
 			{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },
@@ -669,7 +669,7 @@ describe('Test PostgresV2, upsert operation', () => {
 			},
 			options: {
 				outputColumns: ['json'],
-				typeVersion: 2.1,
+				nodeVersion: 2.1,
 			},
 		};
 		const columnsInfo: ColumnInfo[] = [
@@ -726,7 +726,7 @@ describe('Test PostgresV2, upsert operation', () => {
 			},
 			dataMode: 'autoMapInputData',
 			columnToMatchOn: 'id',
-			options: { typeVersion: 2.1 },
+			options: { nodeVersion: 2.1 },
 		};
 		const columnsInfo: ColumnInfo[] = [
 			{ column_name: 'id', data_type: 'integer', is_nullable: 'NO', udt_name: '' },

diff --git a/packages/nodes-base/nodes/Postgres/v2/actions/database/insert.operation.ts b/packages/nodes-base/nodes/Postgres/v2/actions/database/insert.operation.ts
@@ -162,7 +162,7 @@ export async function execute(
 	db: PgpDatabase,
 ): Promise<INodeExecutionData[]> {
 	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, {
 		extractValue: true,

diff --git a/packages/nodes-base/nodes/Postgres/v2/actions/database/update.operation.ts b/packages/nodes-base/nodes/Postgres/v2/actions/database/update.operation.ts
@@ -199,7 +199,7 @@ export async function execute(
 	db: PgpDatabase,
 ): Promise<INodeExecutionData[]> {
 	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, {
 		extractValue: true,

diff --git a/packages/nodes-base/nodes/Postgres/v2/actions/database/upsert.operation.ts b/packages/nodes-base/nodes/Postgres/v2/actions/database/upsert.operation.ts
@@ -198,7 +198,7 @@ export async function execute(
 	db: PgpDatabase,
 ): Promise<INodeExecutionData[]> {
 	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, {
 		extractValue: true,