gravatite/public-pool
1
0
Fork 0
mirror of https://github.com/benjamin-wilson/public-pool.git synced 2026-09-29 09:05:06 -07:00
Code Issues Packages Projects Releases Wiki Activity

row names

Browse Source
This commit is contained in:
Ben Wilson
2023-12-07 08:19:51 -05:00
parent 1089e6210c
commit 4736eadf7b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ORM/client-statistics/client-statistics.service.ts
+2 -2
View File
@@ -42,7 +42,7 @@ export class ClientStatisticsService {
const selectedRows = await queryRunner.manager.getRepository(ClientStatisticsEntity) const selectedRows = await queryRunner.manager.getRepository(ClientStatisticsEntity)
.createQueryBuilder() .createQueryBuilder()
.setLock('pessimistic_write') // Acquire a write lock .setLock('pessimistic_write') // Acquire a write lock
.where('address = :address AND clientName = :clientName AND sessionId = :sessionId AND time = :time', { address: clientStatistic.address, clientName: clientStatistic.clientName, sessionId: clientStatistic.sessionId, time: clientStatistic.time }) .where('address = :address AND "clientName" = :clientName AND "sessionId" = :sessionId AND time = :time', { address: clientStatistic.address, clientName: clientStatistic.clientName, sessionId: clientStatistic.sessionId, time: clientStatistic.time })
.getMany(); .getMany();
// Update the rows // Update the rows
@@ -54,7 +54,7 @@ export class ClientStatisticsService {
shares: () => `"shares" + ${clientStatistic.shares}`, shares: () => `"shares" + ${clientStatistic.shares}`,
acceptedCount: () => `"acceptedCount" + 1` acceptedCount: () => `"acceptedCount" + 1`
}) })
.where('address = :address AND clientName = :clientName AND sessionId = :sessionId AND time = :time', { address: clientStatistic.address, clientName: clientStatistic.clientName, sessionId: clientStatistic.sessionId, time: clientStatistic.time }) .where('address = :address AND "clientName" = :clientName AND "sessionId" = :sessionId AND time = :time', { address: clientStatistic.address, clientName: clientStatistic.clientName, sessionId: clientStatistic.sessionId, time: clientStatistic.time })
.execute(); .execute();
} else { } else {
// If no rows were found, insert a new record // If no rows were found, insert a new record