limit for aggregations

iuwqyir · iuwqyir · commit 80b4abe29b92 · 2025-05-16T20:02:23.000+03:00
diff --git a/internal/storage/clickhouse.go b/internal/storage/clickhouse.go
@@ -504,6 +504,14 @@ func (c *ClickHouseConnector) GetAggregations(table string, qf QueryFilter) (Que
 		query += fmt.Sprintf(" ORDER BY %s %s", qf.SortBy, qf.SortOrder)
 	}
 
+	// Add limit clause
+	if qf.Page > 0 && qf.Limit > 0 {
+		offset := (qf.Page - 1) * qf.Limit
+		query += fmt.Sprintf(" LIMIT %d OFFSET %d", qf.Limit, offset)
+	} else if qf.Limit > 0 {
+		query += fmt.Sprintf(" LIMIT %d", qf.Limit)
+	}
+
 	if err := common.ValidateQuery(query); err != nil {
 		return QueryResult[interface{}]{}, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -504,6 +504,14 @@ func (c *ClickHouseConnector) GetAggregations(table string, qf QueryFilter) (Que`
`504`	`504`	`query += fmt.Sprintf(" ORDER BY %s %s", qf.SortBy, qf.SortOrder)`
`505`	`505`	`}`
`506`	`506`
	`507`	`+ // Add limit clause`
	`508`	`+ if qf.Page > 0 && qf.Limit > 0 {`
	`509`	`+ offset := (qf.Page - 1) * qf.Limit`
	`510`	`+ query += fmt.Sprintf(" LIMIT %d OFFSET %d", qf.Limit, offset)`
	`511`	`+ } else if qf.Limit > 0 {`
	`512`	`+ query += fmt.Sprintf(" LIMIT %d", qf.Limit)`
	`513`	`+ }`
	`514`	`+`
`507`	`515`	`if err := common.ValidateQuery(query); err != nil {`
`508`	`516`	`return QueryResult[interface{}]{}, err`
`509`	`517`	`}`