Skip to content

Commit e467d06

Browse files
authored
Fix(PostgresRecordManager): Handle time correctly and ensure schema creation (#4381)
added pgvector check and time handling for postgresql record manager
1 parent ac9d732 commit e467d06

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

packages/components/nodes/recordmanager/PostgresRecordManager/PostgresRecordManager.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,8 @@ class PostgresRecordManager implements RecordManagerInterface {
227227
const queryRunner = dataSource.createQueryRunner()
228228
const tableName = this.sanitizeTableName(this.tableName)
229229

230+
await queryRunner.query('CREATE EXTENSION IF NOT EXISTS pgcrypto;')
231+
230232
await queryRunner.manager.query(`
231233
CREATE TABLE IF NOT EXISTS "${tableName}" (
232234
uuid UUID PRIMARY KEY DEFAULT gen_random_uuid(),
@@ -258,9 +260,9 @@ class PostgresRecordManager implements RecordManagerInterface {
258260
const dataSource = await this.getDataSource()
259261
try {
260262
const queryRunner = dataSource.createQueryRunner()
261-
const res = await queryRunner.manager.query('SELECT EXTRACT(EPOCH FROM CURRENT_TIMESTAMP)')
263+
const res = await queryRunner.manager.query('SELECT EXTRACT(EPOCH FROM CURRENT_TIMESTAMP) AS now')
262264
await queryRunner.release()
263-
return Number.parseFloat(res[0].extract)
265+
return Number.parseFloat(res[0].now)
264266
} catch (error) {
265267
console.error('Error getting time in PostgresRecordManager:')
266268
throw error

0 commit comments

Comments
 (0)