Add parser support for refreshing view

Author: Praveen2112

core/trino-grammar/src/main/antlr4/io/trino/grammar/sql/SqlBase.g4

@@ -114,6 +114,7 @@ statement
         SET PROPERTIES propertyAssignments                             #setMaterializedViewProperties
     | DROP VIEW (IF EXISTS)? qualifiedName                             #dropView
     | ALTER VIEW from=qualifiedName RENAME TO to=qualifiedName         #renameView
+    | ALTER VIEW viewName=qualifiedName REFRESH                        #refreshView
     | CALL qualifiedName '(' (callArgument (',' callArgument)*)? ')'   #call
     | CREATE (OR REPLACE)? functionSpecification                       #createFunction
     | DROP FUNCTION (IF EXISTS)? functionDeclaration                   #dropFunction

core/trino-parser/src/main/java/io/trino/sql/SqlFormatter.java

@@ -119,6 +119,7 @@
 import io.trino.sql.tree.QueryPeriod;
 import io.trino.sql.tree.QuerySpecification;
 import io.trino.sql.tree.RefreshMaterializedView;
+import io.trino.sql.tree.RefreshView;
 import io.trino.sql.tree.Relation;
 import io.trino.sql.tree.RenameColumn;
 import io.trino.sql.tree.RenameMaterializedView;
@@ -1273,6 +1274,15 @@ protected Void visitRefreshMaterializedView(RefreshMaterializedView node, Intege
             return null;
         }
 
+        @Override
+        protected Void visitRefreshView(RefreshView node, Integer indent)
+        {
+            builder.append("ALTER VIEW ");
+            builder.append(formatName(node.getName()));
+            builder.append(" REFRESH");
+            return null;
+        }
+
         @Override
         protected Void visitDropMaterializedView(DropMaterializedView node, Integer indent)
         {

core/trino-parser/src/main/java/io/trino/sql/parser/AstBuilder.java

@@ -219,6 +219,7 @@
 import io.trino.sql.tree.QuerySpecification;
 import io.trino.sql.tree.RangeQuantifier;
 import io.trino.sql.tree.RefreshMaterializedView;
+import io.trino.sql.tree.RefreshView;
 import io.trino.sql.tree.Relation;
 import io.trino.sql.tree.RenameColumn;
 import io.trino.sql.tree.RenameMaterializedView;
@@ -628,6 +629,14 @@ public Node visitRefreshMaterializedView(SqlBaseParser.RefreshMaterializedViewCo
                 new Table(getQualifiedName(context.qualifiedName())));
     }
 
+    @Override
+    public Node visitRefreshView(SqlBaseParser.RefreshViewContext context)
+    {
+        return new RefreshView(
+                getLocation(context),
+                getQualifiedName(context.qualifiedName()));
+    }
+
     @Override
     public Node visitDropMaterializedView(SqlBaseParser.DropMaterializedViewContext context)
     {

core/trino-parser/src/main/java/io/trino/sql/tree/AstVisitor.java

@@ -732,6 +732,11 @@ protected R visitRefreshMaterializedView(RefreshMaterializedView node, C context
         return visitStatement(node, context);
     }
 
+    protected R visitRefreshView(RefreshView node, C context)
+    {
+        return visitStatement(node, context);
+    }
+
     protected R visitCall(Call node, C context)
     {
         return visitStatement(node, context);

core/trino-parser/src/main/java/io/trino/sql/tree/RefreshView.java

@@ -0,0 +1,78 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.trino.sql.tree;
+
+import com.google.common.collect.ImmutableList;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static java.util.Objects.requireNonNull;
+
+public final class RefreshView
+        extends Statement
+{
+    private final QualifiedName name;
+
+    public RefreshView(NodeLocation location, QualifiedName name)
+    {
+        super(location);
+        this.name = requireNonNull(name, "name is null");
+    }
+
+    public QualifiedName getName()
+    {
+        return name;
+    }
+
+    @Override
+    public <R, C> R accept(AstVisitor<R, C> visitor, C context)
+    {
+        return visitor.visitRefreshView(this, context);
+    }
+
+    @Override
+    public List<Node> getChildren()
+    {
+        return ImmutableList.of();
+    }
+
+    @Override
+    public int hashCode()
+    {
+        return Objects.hash(name);
+    }
+
+    @Override
+    public boolean equals(Object obj)
+    {
+        if (this == obj) {
+            return true;
+        }
+        if ((obj == null) || (getClass() != obj.getClass())) {
+            return false;
+        }
+        RefreshView o = (RefreshView) obj;
+        return Objects.equals(name, o.name);
+    }
+
+    @Override
+    public String toString()
+    {
+        return toStringHelper(this)
+                .add("name", name)
+                .toString();
+    }
+}

core/trino-parser/src/test/java/io/trino/sql/TestSqlFormatter.java

@@ -32,6 +32,7 @@
 import io.trino.sql.tree.Property;
 import io.trino.sql.tree.QualifiedName;
 import io.trino.sql.tree.Query;
+import io.trino.sql.tree.RefreshView;
 import io.trino.sql.tree.ShowCatalogs;
 import io.trino.sql.tree.ShowColumns;
 import io.trino.sql.tree.ShowFunctions;
@@ -554,6 +555,14 @@ public void testCommentOnColumn()
                 .isEqualTo("COMMENT ON COLUMN test.a IS '攻殻機動隊'");
     }
 
+    @Test
+    public void testRefreshView()
+    {
+        assertThat(formatSql(
+                new RefreshView(new NodeLocation(1, 1), QualifiedName.of("catalog", "schema", "view"))))
+                .isEqualTo("ALTER VIEW catalog.schema.view REFRESH");
+    }
+
     @Test
     public void testExecuteImmediate()
     {

core/trino-parser/src/test/java/io/trino/sql/parser/TestSqlParser.java

@@ -161,6 +161,7 @@
 import io.trino.sql.tree.QuerySpecification;
 import io.trino.sql.tree.RangeQuantifier;
 import io.trino.sql.tree.RefreshMaterializedView;
+import io.trino.sql.tree.RefreshView;
 import io.trino.sql.tree.Relation;
 import io.trino.sql.tree.RenameColumn;
 import io.trino.sql.tree.RenameMaterializedView;
@@ -3533,6 +3534,15 @@ public void testRenameView()
                         QualifiedName.of(ImmutableList.of(new Identifier(location(1, 24), "b", false)))));
     }
 
+    @Test
+    public void testRefreshView()
+    {
+        assertThat(statement("ALTER VIEW a REFRESH"))
+                .isEqualTo(new RefreshView(
+                        location(1, 1),
+                        QualifiedName.of(ImmutableList.of(new Identifier(location(1, 12), "a", false)))));
+    }
+
     @Test
     public void testAlterViewSetAuthorization()
     {