From e467d0615cd846510a38584432ec79d80f02b5ad Mon Sep 17 00:00:00 2001 From: nikitas-novatix Date: Tue, 6 May 2025 18:27:47 +0200 Subject: [PATCH] Fix(PostgresRecordManager): Handle time correctly and ensure schema creation (#4381) added pgvector check and time handling for postgresql record manager --- .../PostgresRecordManager/PostgresRecordManager.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/packages/components/nodes/recordmanager/PostgresRecordManager/PostgresRecordManager.ts b/packages/components/nodes/recordmanager/PostgresRecordManager/PostgresRecordManager.ts index 6294429df..ebb429af0 100644 --- a/packages/components/nodes/recordmanager/PostgresRecordManager/PostgresRecordManager.ts +++ b/packages/components/nodes/recordmanager/PostgresRecordManager/PostgresRecordManager.ts @@ -227,6 +227,8 @@ class PostgresRecordManager implements RecordManagerInterface { const queryRunner = dataSource.createQueryRunner() const tableName = this.sanitizeTableName(this.tableName) + await queryRunner.query('CREATE EXTENSION IF NOT EXISTS pgcrypto;') + await queryRunner.manager.query(` CREATE TABLE IF NOT EXISTS "${tableName}" ( uuid UUID PRIMARY KEY DEFAULT gen_random_uuid(), @@ -258,9 +260,9 @@ class PostgresRecordManager implements RecordManagerInterface { const dataSource = await this.getDataSource() try { const queryRunner = dataSource.createQueryRunner() - const res = await queryRunner.manager.query('SELECT EXTRACT(EPOCH FROM CURRENT_TIMESTAMP)') + const res = await queryRunner.manager.query('SELECT EXTRACT(EPOCH FROM CURRENT_TIMESTAMP) AS now') await queryRunner.release() - return Number.parseFloat(res[0].extract) + return Number.parseFloat(res[0].now) } catch (error) { console.error('Error getting time in PostgresRecordManager:') throw error