Fix MySQL query.

This commit is contained in:
Mike Cao 2020-08-18 18:33:59 -07:00
parent 41eeb1a5f1
commit 2d69b3087f

View File

@ -369,14 +369,34 @@ export function getRankings(website_id, start_at, end_at, type, table) {
} }
export function getActiveVisitors(website_id) { export function getActiveVisitors(website_id) {
return prisma.$queryRaw( const db = getDatabase();
` const date = subMinutes(new Date(), 5);
if (db === POSTGRESQL) {
return prisma.$queryRaw(
`
select count(distinct session_id) x select count(distinct session_id) x
from pageview from pageview
where website_id=$1 where website_id=$1
and created_at >= $2 and created_at >= $2
`, `,
website_id, website_id,
subMinutes(new Date(), 5), date,
); );
}
if (db === MYSQL) {
return prisma.$queryRaw(
`
select count(distinct session_id) x
from pageview
where website_id=?
and created_at >= ?
`,
website_id,
date,
);
}
return Promise.resolve([]);
} }