Fixed queries.

This commit is contained in:
Mike Cao 2024-08-19 10:53:31 -07:00
parent e98bc3bd74
commit 8d92509f71
4 changed files with 15 additions and 8 deletions

View file

@ -17,12 +17,11 @@ async function relationalQuery(websiteId: string, filters: QueryFilters, pagePar
const { query } = pageParams;
const where = {
...filters,
id: websiteId,
...prisma.getSearchParameters(query, [{ eventName: 'contains' }, { urlPath: 'contains' }]),
};
return pagedQuery('website_event', { where }, pageParams);
return pagedQuery('WebsiteEvent', { where }, pageParams);
}
async function clickhouseQuery(websiteId: string, filters: QueryFilters, pageParams?: PageParams) {

View file

@ -22,9 +22,13 @@ async function relationalQuery(
{ pageviews: number; visitors: number; visits: number; bounces: number; totaltime: number }[]
> {
const { getTimestampDiffSQL, parseFilters, rawQuery } = prisma;
const { filterQuery, joinSession, params } = await parseFilters(websiteId, {
...filters,
});
const { filterQuery, joinSession, params } = await parseFilters(
websiteId,
{
...filters,
},
{ joinSession: true },
);
return rawQuery(
`
@ -34,7 +38,7 @@ async function relationalQuery(
count(distinct t.visit_id) as "visits",
count(distinct t.country) as "countries",
sum(case when t.c = 1 then 1 else 0 end) as "bounces",
sum(${getTimestampDiffSQL('t.min_time', 't.max_time')}) as "totaltime",
sum(${getTimestampDiffSQL('t.min_time', 't.max_time')}) as "totaltime"
from (
select
website_event.session_id,