[Feature] Support trino current_catalog and current_schema function (…

…backport #41319) (#41495)

Co-authored-by: hongyu guo <[email protected]>

fe/fe-core/src/main/java/com/starrocks/connector/parser/trino/AstBuilder.java

@@ -101,6 +101,8 @@
 import io.trino.sql.tree.CoalesceExpression;
 import io.trino.sql.tree.ComparisonExpression;
 import io.trino.sql.tree.Cube;
+import io.trino.sql.tree.CurrentCatalog;
+import io.trino.sql.tree.CurrentSchema;
 import io.trino.sql.tree.CurrentTime;
 import io.trino.sql.tree.CurrentUser;
 import io.trino.sql.tree.DataType;
@@ -1099,6 +1101,16 @@ protected ParseNode visitCurrentTime(CurrentTime node, ParseTreeContext context)
         return new FunctionCallExpr(node.getFunction().getName(), new ArrayList<>());
     }
 
+    @Override
+    protected ParseNode visitCurrentCatalog(CurrentCatalog node, ParseTreeContext context) {
+        return new InformationFunction(FunctionSet.CATALOG.toUpperCase());
+    }
+
+    @Override
+    protected ParseNode visitCurrentSchema(CurrentSchema node, ParseTreeContext context) {
+        return new InformationFunction(FunctionSet.SCHEMA.toUpperCase());
+    }
+
     @Override
     protected ParseNode visitSearchedCaseExpression(SearchedCaseExpression node, ParseTreeContext context) {
         return new CaseExpr(null, visit(node.getWhenClauses(), context, CaseWhenClause.class),

fe/fe-core/src/test/java/com/starrocks/connector/parser/trino/TrinoFunctionTransformTest.java

@@ -404,4 +404,13 @@ public void testIsNullFunction() throws Exception {
         sql = "select isnotnull(1, 2)";
         analyzeFail(sql, "isnotnull function must have 1 argument");
     }
+
+    @Test
+    public void testUtilityFunction() throws Exception {
+        String sql = "select current_catalog";
+        assertPlanContains(sql, "<slot 2> : CATALOG()");
+
+        sql = "select current_schema";
+        assertPlanContains(sql, "<slot 2> : 'test'");
+    }
 }