Skip to content

Commit 4745fdb

Browse files
committed
get rid of raw query
1 parent 5afb338 commit 4745fdb

File tree

2 files changed

+7
-9
lines changed

2 files changed

+7
-9
lines changed

src/api/repository/paymentMethod.repo.ts

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,14 +36,13 @@ export class PaymentMethodRepository {
3636
* @returns payment methods
3737
*/
3838
private async findPaymentMethodByUserId(userId: string, tx?) {
39-
const query = `
39+
const db = tx || this.prisma;
40+
const ret = await db.$queryRaw`
4041
SELECT pm.payment_method_id, pm.payment_method_type, pm.name, pm.description, upm.status, upm.id
4142
FROM payment_method pm
4243
JOIN user_payment_methods upm ON pm.payment_method_id = upm.payment_method_id
43-
WHERE upm.user_id = '${userId}'
44+
WHERE upm.user_id=${userId}
4445
`;
45-
const db = tx || this.prisma;
46-
const ret = await db.$queryRawUnsafe(query);
4746
return (ret || []) as PaymentMethodQueryResult[];
4847
}
4948
}

src/api/repository/taxForm.repo.ts

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,15 +34,14 @@ export class TaxFormRepository {
3434
userId: string,
3535
tx?,
3636
): Promise<TaxFormQueryResult[]> {
37-
const query = `
37+
const db = tx || this.prisma;
38+
39+
const ret = await db.$queryRaw`
3840
SELECT u.id, u.user_id, t.tax_form_id, t.name, t.text, t.description, u.date_filed, u.withholding_amount, u.withholding_percentage, u.status_id::text, u.use_percentage
3941
FROM user_tax_form_associations AS u
4042
JOIN tax_forms AS t ON u.tax_form_id = t.tax_form_id
41-
WHERE u.user_id = '${userId}'
43+
WHERE u.user_id=${userId}
4244
`;
43-
const db = tx || this.prisma;
44-
45-
const ret = await db.$queryRawUnsafe(query);
4645
return (ret || []) as TaxFormQueryResult[];
4746
}
4847
}

0 commit comments

Comments
 (0)