fix(core): Set postgres search_path to the desired schema on every connection

packages/@n8n/nodes-langchain/package.json

@@ -146,7 +146,7 @@
     "@langchain/pinecone": "0.0.6",
     "@langchain/redis": "0.0.5",
     "@langchain/textsplitters": "0.0.2",
-    "@n8n/typeorm": "0.3.20-9",
+    "@n8n/typeorm": "0.3.20-10",
     "@n8n/vm2": "3.9.20",
     "@pinecone-database/pinecone": "2.2.1",
     "@qdrant/js-client-rest": "1.9.0",

packages/cli/package.json

@@ -98,7 +98,7 @@
     "@n8n/localtunnel": "2.1.0",
     "@n8n/n8n-nodes-langchain": "workspace:*",
     "@n8n/permissions": "workspace:*",
-    "@n8n/typeorm": "0.3.20-9",
+    "@n8n/typeorm": "0.3.20-10",
     "@n8n_io/license-sdk": "2.12.0",
     "@oclif/core": "3.18.1",
     "@pinecone-database/pinecone": "2.1.0",
@@ -165,7 +165,7 @@
     "prom-client": "13.2.0",
     "psl": "1.9.0",
     "raw-body": "2.5.1",
-    "reflect-metadata": "0.2.1",
+    "reflect-metadata": "0.2.2",
     "replacestream": "4.0.3",
     "samlify": "2.8.9",
     "semver": "7.5.4",

packages/cli/src/Db.ts

@@ -4,7 +4,6 @@ import type { EntityManager } from '@n8n/typeorm';
 import { DataSource as Connection } from '@n8n/typeorm';
 import { ErrorReporterProxy as ErrorReporter } from 'n8n-workflow';
 
-import config from '@/config';
 import { inTest } from '@/constants';
 import { wrapMigration } from '@db/utils/migrationHelpers';
 import type { Migration } from '@db/types';
@@ -48,30 +47,14 @@ export async function transaction<T>(fn: (entityManager: EntityManager) => Promi
 	return await connection.transaction(fn);
 }
 
-export async function setSchema(conn: Connection) {
-	const schema = config.getEnv('database.postgresdb.schema');
-	const searchPath = ['public'];
-	if (schema !== 'public') {
-		await conn.query(`CREATE SCHEMA IF NOT EXISTS ${schema}`);
-		searchPath.unshift(schema);
-	}
-	await conn.query(`SET search_path TO ${searchPath.join(',')};`);
-}
-
 export async function init(): Promise<void> {
 	if (connectionState.connected) return;
 
-	const dbType = config.getEnv('database.type');
 	const connectionOptions = getConnectionOptions();
-
 	connection = new Connection(connectionOptions);
 	Container.set(Connection, connection);
 	await connection.initialize();
 
-	if (dbType === 'postgresdb') {
-		await setSchema(connection);
-	}
-
 	connectionState.connected = true;
 }
 

packages/cli/src/commands/db/revert.ts

@@ -3,11 +3,9 @@ import type { DataSourceOptions as ConnectionOptions } from '@n8n/typeorm';
 import { MigrationExecutor, DataSource as Connection } from '@n8n/typeorm';
 import { Container } from 'typedi';
 import { Logger } from '@/Logger';
-import { setSchema } from '@/Db';
 import { getConnectionOptions } from '@db/config';
 import type { Migration } from '@db/types';
 import { wrapMigration } from '@db/utils/migrationHelpers';
-import config from '@/config';
 
 // This function is extracted to make it easier to unit test it.
 // Mocking turned into a mess due to this command using typeorm and the db
@@ -88,9 +86,6 @@ export class DbRevertMigrationCommand extends Command {
 		const connection = new Connection(connectionOptions);
 		await connection.initialize();
 
-		const dbType = config.getEnv('database.type');
-		if (dbType === 'postgresdb') await setSchema(connection);
-
 		const migrationExecutor = new MigrationExecutor(connection);
 
 		(connectionOptions.migrations as Migration[]).forEach(wrapMigration);