diff --git a/tdrive/backend/node/src/core/platform/services/database/services/orm/connectors/postgres/postgres.ts b/tdrive/backend/node/src/core/platform/services/database/services/orm/connectors/postgres/postgres.ts index 209bc206..663f06fd 100644 --- a/tdrive/backend/node/src/core/platform/services/database/services/orm/connectors/postgres/postgres.ts +++ b/tdrive/backend/node/src/core/platform/services/database/services/orm/connectors/postgres/postgres.ts @@ -72,9 +72,10 @@ export class PostgresConnector extends AbstractConnector { // eslint-disable-next-line @typescript-eslint/no-explicit-any - const safeRequest = async (query: string, values?: any[]) => { + const safeRequest = async (query: string, values?: any[], singleRow = false) => { try { - return (await this.client.query(query, values)).rows; + const rows = (await this.client.query(query, values)).rows; + return singleRow && rows?.length === 1 ? rows[0] : rows; } catch (err) { const logId = "pg-diags-error-" + Math.floor(process.uptime() * 1000); logger.error( @@ -94,9 +95,11 @@ export class PostgresConnector extends AbstractConnector