From eed3cd6db7f4a611c31d8cf2d3ae9afa7b8ee3f1 Mon Sep 17 00:00:00 2001 From: cs1317 <1317784049@qq.com> Date: Tue, 8 Aug 2023 23:10:14 +0800 Subject: [PATCH] feat:add single party func abs --- pkg/expression/expression_to_stmt.go | 2 +- pkg/planner/core/testdata/runsql_in.json | 5 +++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/expression/expression_to_stmt.go b/pkg/expression/expression_to_stmt.go index aa51d0a0..cfae008e 100644 --- a/pkg/expression/expression_to_stmt.go +++ b/pkg/expression/expression_to_stmt.go @@ -121,7 +121,7 @@ func (c ExprConverter) convertScalarFunction(dialect format.Dialect, expr *Scala return &ast.FuncCallExpr{FnName: model.NewCIStr(dialect.GetSpecialFuncName(ast.Ifnull)), Args: children}, nil case ast.If: return &ast.FuncCallExpr{FnName: model.NewCIStr(ast.If), Args: children}, nil - case ast.Cos: + case ast.Cos, ast.Abs: return &ast.FuncCallExpr{FnName: model.NewCIStr(expr.FuncName.L), Args: children}, nil } switch expr.Function.(type) { diff --git a/pkg/planner/core/testdata/runsql_in.json b/pkg/planner/core/testdata/runsql_in.json index 4d6f07a9..c2db2db6 100644 --- a/pkg/planner/core/testdata/runsql_in.json +++ b/pkg/planner/core/testdata/runsql_in.json @@ -290,6 +290,11 @@ "sql": "select cos(aggregate_float_0) as a from alice.tbl_1", "skip_projection": false, "rewritten_sql": "select cos(tbl_1.aggregate_float_0) as a from alice.tbl_1" + }, + { + "sql": "select abs(aggregate_float_0) as a from alice.tbl_1", + "skip_projection": false, + "rewritten_sql": "select abs(tbl_1.aggregate_float_0) as a from alice.tbl_1" } ] }