diff --git a/lib/prisma.js b/lib/prisma.js index af2408d5..b93afafa 100644 --- a/lib/prisma.js +++ b/lib/prisma.js @@ -180,7 +180,7 @@ async function rawQuery(query, params = []) { return prisma.$queryRawUnsafe.apply(prisma, [sql, ...params]); } -async function multiQuery(queries) { +async function transaction(queries) { return prisma.$transaction(queries); } @@ -195,5 +195,5 @@ export default { getFilterQuery, parseFilters, rawQuery, - multiQuery, + transaction, }; diff --git a/queries/admin/website/deleteWebsite.js b/queries/admin/website/deleteWebsite.js index 15030444..e09f7ebb 100644 --- a/queries/admin/website/deleteWebsite.js +++ b/queries/admin/website/deleteWebsite.js @@ -2,9 +2,9 @@ import prisma from 'lib/prisma'; import redis from 'lib/redis'; export async function deleteWebsite(website_id) { - const { client, multiQuery } = prisma; + const { client, transaction } = prisma; - return multiQuery([ + return transaction([ client.pageview.deleteMany({ where: { session: { website: { website_id } } }, }), diff --git a/queries/admin/website/resetWebsite.js b/queries/admin/website/resetWebsite.js index 661cd65c..4e7adc7a 100644 --- a/queries/admin/website/resetWebsite.js +++ b/queries/admin/website/resetWebsite.js @@ -2,9 +2,9 @@ import prisma from 'lib/prisma'; import redis from 'lib/redis'; export async function resetWebsite(website_id) { - const { client, multiQuery } = prisma; + const { client, transaction } = prisma; - return multiQuery([ + return transaction([ client.pageview.deleteMany({ where: { session: { website: { website_id } } }, }),