log.info('Selecting how many PageViews has a user')
    query = (
        connection.query(
            User.email,
            func.count(distinct(Session.id)).label('ses_count'),
            func.count(PageView.id).label('pv_count'),
        )
        .join(Session)
        .join(PageView)
        .group_by(User.email)
        .all()
    )

log.info('Selecting how many PageViews has a user grouped by url')
    query = (
        connection.query(
            User.email,
            PageView.url,
            func.count(distinct(Session.id)).label('ses_count'),
            func.count(PageView.id).label('pv_count'),
        )
        .join(Session)
        .join(PageView)
        .group_by(User.email, PageView.url)
        .order_by(User.email)
        .all()
    )

log.info('Selecting users which came to /two url more then 19000 times ')
    row = func.count(PageView.id)
    query = (
        connection.query(
            User.email,
            PageView.url,
            row.label('pv_count'),
        )
        .join(Session)
        .join(PageView)
        .group_by(User.email, PageView.url)
        .order_by(User.email)
        .filter(
            PageView.url == '/two',
        )
        .having(
            "pv_count" > 19000
        )
        .all()
    )