From 5b71632f8a0a9a57178e70f935138277ac7d9542 Mon Sep 17 00:00:00 2001
From: Ben Wilson <ben@registrationmax.com>
Date: Thu, 7 Dec 2023 09:55:07 -0500
Subject: [PATCH] postgres doesn't support read UNCOMMITTED

---
 .../client-statistics.service.ts              | 27 ++++++++-----------
 1 file changed, 11 insertions(+), 16 deletions(-)

diff --git a/src/ORM/client-statistics/client-statistics.service.ts b/src/ORM/client-statistics/client-statistics.service.ts
index 9db40dc..de288d7 100644
--- a/src/ORM/client-statistics/client-statistics.service.ts
+++ b/src/ORM/client-statistics/client-statistics.service.ts
@@ -1,27 +1,20 @@
-import { Injectable, OnModuleDestroy } from '@nestjs/common';
+import { Injectable } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
-import { DataSource, QueryRunner, Repository } from 'typeorm';
+import { Repository } from 'typeorm';
 
 import { ClientStatisticsEntity } from './client-statistics.entity';
 
 
 @Injectable()
-export class ClientStatisticsService implements OnModuleDestroy {
-
-    private readUncommittedQueryRunner: QueryRunner;
+export class ClientStatisticsService {
 
     constructor(
 
-        private readonly dataSource: DataSource,
+
         @InjectRepository(ClientStatisticsEntity)
         private clientStatisticsRepository: Repository<ClientStatisticsEntity>,
     ) {
-        this.readUncommittedQueryRunner = this.dataSource.createQueryRunner();
-        this.readUncommittedQueryRunner.query('SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;')
-    }
 
-    onModuleDestroy() {
-        this.readUncommittedQueryRunner.release();
     }
 
     public async save(clientStatistic: Partial<ClientStatisticsEntity>) {
@@ -54,9 +47,9 @@ export class ClientStatisticsService implements OnModuleDestroy {
 
         var yesterday = new Date(new Date().getTime() - (24 * 60 * 60 * 1000));
 
+        const query = `
+            SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
 
-        var result = await this.readUncommittedQueryRunner.query(
-            `
             SELECT
                 time AS label,
                 ROUND(((SUM(shares) * 4294967296) / 600)) AS data
@@ -68,9 +61,11 @@ export class ClientStatisticsService implements OnModuleDestroy {
                 time
             ORDER BY
                 time
-            LIMIT 144;        
-    `
-        );
+            LIMIT 144;
+        
+    `;
+
+        const result: any[] = await this.clientStatisticsRepository.query(query);
 
 
         return result.map(res => {