86
}
87
88
>
func (p *queryParser) convertParenExpr(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery) error {
query_parser.go
89
>
return p.convertWhereExpr(parenExpr.Expr, parsedQuery)
90
>
}
91
92
>
func (p *queryParser) convertAndExpr(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery) error {
query_parser.go
93
>
if err := p.convertWhereExpr(andExpr.Left, parsedQuery); err != nil {
94
return err
95
}
97
}
98
99
>
func (p *queryParser) convertComparisonExpr(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery) error {
query_parser.go
100
>
colName, ok := compExpr.Left.(*sqlparser.ColName)
101
>
if !ok {
102
return fmt.Errorf("invalid filter name: %s", sqlparser.String(compExpr.Left))
103
}
105
>
op := compExpr.Operator
106
>
valExpr, ok := compExpr.Right.(*sqlparser.SQLVal)
107
>
if !ok {
108
return fmt.Errorf("invalid value: %s", sqlparser.String(compExpr.Right))
109
}
111
>
112
>
switch colNameStr {
113
case WorkflowID:
114
val, err := sqlquery.ExtractStringValue(valStr)