Skip to content

Commit 22fabdf

Browse files
committed
fix: resolve pr review comments
Signed-off-by: Yeganathan S <63534555+skwowet@users.noreply.github.com>
1 parent 47300f2 commit 22fabdf

1 file changed

Lines changed: 12 additions & 4 deletions

File tree

  • services/libs/data-access-layer/src/member_merge

services/libs/data-access-layer/src/member_merge/index.ts

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,15 +14,23 @@ export async function removeMemberToMerge(
1414
("memberId" = $(toMergeId) AND "toMergeId" = $(memberId))
1515
`
1616

17-
for (const table of ['memberToMerge', 'memberToMergeRaw']) {
18-
await qx.result(
17+
await qx.tx(async (tx) => {
18+
await tx.result(
1919
`
20-
DELETE FROM "${table}"
20+
DELETE FROM "memberToMerge"
2121
${whereClause}
2222
`,
2323
replacements,
2424
)
25-
}
25+
26+
await tx.result(
27+
`
28+
DELETE FROM "memberToMergeRaw"
29+
${whereClause}
30+
`,
31+
replacements,
32+
)
33+
})
2634
}
2735

2836
export async function insertMemberNoMerge(

0 commit comments

Comments
 (0)