add second try test with mat view
This commit is contained in:
parent
ec052f5f15
commit
a0bae358aa
@ -53,14 +53,14 @@ type PipeLineStatsResp [][]struct {
|
|||||||
QuestionID int64
|
QuestionID int64
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *StatisticClick) GetPipelinesStatistics(ctx context.Context, from uint64, to uint64) ([]PipeLineStatsResp, error) {
|
func (s *StatisticClick) GetPipelinesStatistics(ctx context.Context, quizID int64, from uint64, to uint64) ([]PipeLineStatsResp, error) {
|
||||||
query := `
|
query := `
|
||||||
SELECT
|
SELECT
|
||||||
ctxsession,ctxquestionid,count(*) as session_count
|
ctxsession,ctxquestionid,count(*) as session_count
|
||||||
FROM mv_last_answers_events WHERE event_time BETWEEN ? AND ?
|
FROM mv_last_answers_events WHERE ctxquizid = ? AND event_time BETWEEN ? AND ?
|
||||||
GROUP BY ctxsession, ctxquestionid ORDER BY ctxsession, ctxquestionid
|
GROUP BY ctxsession, ctxquestionid ORDER BY ctxsession, ctxquestionid
|
||||||
`
|
`
|
||||||
rows, err := s.conn.QueryContext(ctx, query, from, to)
|
rows, err := s.conn.QueryContext(ctx, query, quizID, from, to)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user