highperfocused/public-pool
1
0
Fork 0
mirror of https://github.com/benjamin-wilson/public-pool.git synced 2025-04-04 01:48:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

deadlock?

Browse Source
This commit is contained in:
Ben Wilson 2023-12-07 08:16:48 -05:00
parent 017978d250
commit 1089e6210c
1 changed files with 49 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
src/ORM/client-statistics/client-statistics.service.ts
View File

@ -17,18 +17,56 @@ export class ClientStatisticsService {
}
public async save(clientStatistic: Partial<ClientStatisticsEntity>) {
const res1 = await this.clientStatisticsRepository.createQueryBuilder()
.update(ClientStatisticsEntity)
.set({
shares: () => `"shares" + ${clientStatistic.shares}`, // Use the actual value of shares here
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 })
.execute();
// public async save(clientStatistic: Partial<ClientStatisticsEntity>) {
// const res1 = await this.clientStatisticsRepository.createQueryBuilder()
// .update(ClientStatisticsEntity)
// .set({
// shares: () => `"shares" + ${clientStatistic.shares}`, // Use the actual value of shares here
// 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 })
// .execute();
if (res1.affected == 0) {
await this.clientStatisticsRepository.insert(clientStatistic);
// if (res1.affected == 0) {
// await this.clientStatisticsRepository.insert(clientStatistic);
// }
// }
public async save(clientStatistic: Partial<ClientStatisticsEntity>) {
const queryRunner = this.clientStatisticsRepository.manager.connection.createQueryRunner();
await queryRunner.connect();
await queryRunner.startTransaction();
try {
// Acquire a lock on the selected rows
const selectedRows = await queryRunner.manager.getRepository(ClientStatisticsEntity)
.createQueryBuilder()
.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 })
.getMany();
// Update the rows
if (selectedRows.length > 0) {
await queryRunner.manager.getRepository(ClientStatisticsEntity)
.createQueryBuilder()
.update(ClientStatisticsEntity)
.set({
shares: () => `"shares" + ${clientStatistic.shares}`,
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 })
.execute();
} else {
// If no rows were found, insert a new record
await queryRunner.manager.getRepository(ClientStatisticsEntity).insert(clientStatistic);
}
await queryRunner.commitTransaction();
} catch (error) {
await queryRunner.rollbackTransaction();
throw error;
} finally {
await queryRunner.release();
}
}