GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-07-30 18:01:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

parser updated

Browse Source
This commit is contained in:
nityanandagohain 2022-07-21 18:32:11 +05:30
parent 2132d1059c
commit 6ac7cb1022
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
pkg/query-service/app/logs/parser.go
View File

@ -243,16 +243,32 @@ func GenerateSQLWhere(allFields *model.GetFieldsResponse, params *model.LogsFilt
}
if params.TimestampStart != nil {
tokens = append(tokens, fmt.Sprintf("and timestamp >= '%d' ", *params.TimestampStart))
filter := fmt.Sprintf("timestamp >= '%d' ", *params.TimestampStart)
if len(tokens) > 0 {
filter = "and " + filter
}
tokens = append(tokens, filter)
}
if params.TimestampEnd != nil {
tokens = append(tokens, fmt.Sprintf("and timestamp <= '%d' ", *params.TimestampEnd))
filter := fmt.Sprintf("timestamp <= '%d' ", *params.TimestampEnd)
if len(tokens) > 0 {
filter = "and " + filter
}
tokens = append(tokens, filter)
}
if params.IdStart != nil {
tokens = append(tokens, fmt.Sprintf("and id > '%v' ", *params.IdStart))
filter := fmt.Sprintf("id > '%v' ", *params.IdStart)
if len(tokens) > 0 {
filter = "and " + filter
}
tokens = append(tokens, filter)
}
if params.IdEnd != nil {
tokens = append(tokens, fmt.Sprintf("and id < '%v' ", *params.IdEnd))
filter := fmt.Sprintf("id < '%v' ", *params.IdEnd)
if len(tokens) > 0 {
filter = "and " + filter
}
tokens = append(tokens, filter)
}
sqlWhere := strings.Join(tokens, "")