Fix jacoco test

Signed-off-by: Chen Dai <[email protected]>

Author: dai-chen

async-query-core/src/main/java/org/opensearch/sql/spark/utils/SQLQueryUtils.java

@@ -267,31 +267,6 @@ public Void visitDropMaterializedViewStatement(
       return super.visitDropMaterializedViewStatement(ctx);
     }
 
-    @Override
-    public Void visitVacuumSkippingIndexStatement(
-        FlintSparkSqlExtensionsParser.VacuumSkippingIndexStatementContext ctx) {
-      indexQueryDetailsBuilder.indexQueryActionType(IndexQueryActionType.VACUUM);
-      indexQueryDetailsBuilder.indexType(FlintIndexType.SKIPPING);
-      return super.visitVacuumSkippingIndexStatement(ctx);
-    }
-
-    @Override
-    public Void visitVacuumCoveringIndexStatement(
-        FlintSparkSqlExtensionsParser.VacuumCoveringIndexStatementContext ctx) {
-      indexQueryDetailsBuilder.indexQueryActionType(IndexQueryActionType.VACUUM);
-      indexQueryDetailsBuilder.indexType(FlintIndexType.COVERING);
-      return super.visitVacuumCoveringIndexStatement(ctx);
-    }
-
-    @Override
-    public Void visitVacuumMaterializedViewStatement(
-        FlintSparkSqlExtensionsParser.VacuumMaterializedViewStatementContext ctx) {
-      indexQueryDetailsBuilder.indexQueryActionType(IndexQueryActionType.VACUUM);
-      indexQueryDetailsBuilder.indexType(FlintIndexType.MATERIALIZED_VIEW);
-      indexQueryDetailsBuilder.mvName(ctx.mvName.getText());
-      return super.visitVacuumMaterializedViewStatement(ctx);
-    }
-
     @Override
     public Void visitDescribeCoveringIndexStatement(
         FlintSparkSqlExtensionsParser.DescribeCoveringIndexStatementContext ctx) {

async-query-core/src/test/java/org/opensearch/sql/spark/utils/SQLQueryUtilsTest.java

@@ -142,7 +142,6 @@ void testExtractionFromFlintSkippingIndexQueries() {
           + " WHERE elb_status_code = 500 "
           + " WITH (auto_refresh = true)",
       "DROP SKIPPING INDEX ON myS3.default.alb_logs",
-      "VACUUM SKIPPING INDEX ON myS3.default.alb_logs",
       "ALTER SKIPPING INDEX ON myS3.default.alb_logs WITH (auto_refresh = false)",
     };
 
@@ -171,7 +170,6 @@ void testExtractionFromFlintCoveringIndexQueries() {
           + " WHERE elb_status_code = 500 "
           + " WITH (auto_refresh = true)",
       "DROP INDEX elb_and_requestUri ON myS3.default.alb_logs",
-      "VACUUM INDEX elb_and_requestUri ON myS3.default.alb_logs",
       "ALTER INDEX elb_and_requestUri ON myS3.default.alb_logs WITH (auto_refresh = false)"
     };
 
@@ -203,9 +201,7 @@ void testExtractionFromCreateMVQuery() {
   @Test
   void testExtractionFromFlintMVQuery() {
     String[] mvQueries = {
-      "DROP MATERIALIZED VIEW mv_1",
-      "VACUUM MATERIALIZED VIEW mv_1",
-      "ALTER MATERIALIZED VIEW mv_1 WITH (auto_refresh = false)",
+      "DROP MATERIALIZED VIEW mv_1", "ALTER MATERIALIZED VIEW mv_1 WITH (auto_refresh = false)",
     };
 
     for (String query : mvQueries) {

async-query/src/test/java/org/opensearch/sql/spark/flint/OpenSearchFlintIndexClientTest.java

@@ -0,0 +1,42 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.opensearch.sql.spark.flint;
+
+import static org.mockito.Answers.RETURNS_DEEP_STUBS;
+import static org.mockito.Mockito.any;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.opensearch.action.admin.indices.delete.DeleteIndexRequest;
+import org.opensearch.action.support.master.AcknowledgedResponse;
+import org.opensearch.client.Client;
+
+@ExtendWith(MockitoExtension.class)
+public class OpenSearchFlintIndexClientTest {
+
+  @Mock(answer = RETURNS_DEEP_STUBS)
+  private Client client;
+
+  @Mock private AcknowledgedResponse acknowledgedResponse;
+
+  @InjectMocks private OpenSearchFlintIndexClient openSearchFlintIndexClient;
+
+  @Test
+  public void testDeleteIndex() {
+    when(client.admin().indices().delete(any(DeleteIndexRequest.class)).actionGet())
+        .thenReturn(acknowledgedResponse);
+    when(acknowledgedResponse.isAcknowledged()).thenReturn(true);
+
+    openSearchFlintIndexClient.deleteIndex("test-index");
+    verify(client.admin().indices()).delete(any(DeleteIndexRequest.class));
+    verify(acknowledgedResponse).isAcknowledged();
+  }
+}