feat: g4测试编写

boot-base/boot-basic-io/pom.xml

@@ -44,6 +44,24 @@
             <version>32.1.1-jre</version>
         </dependency>
 
+        <!-- https://mvnrepository.com/artifact/org.antlr/antlr4-runtime -->
+        <dependency>
+            <groupId>org.antlr</groupId>
+            <artifactId>antlr4-runtime</artifactId>
+            <version>4.7</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.spark</groupId>
+            <artifactId>spark-catalyst_2.12</artifactId>
+            <version>3.0.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
     </dependencies>
 
     <build>

boot-base/boot-basic-io/src/main/java/com/iyang/bootbasicio/sql/IcebergVisitor.java

@@ -0,0 +1,72 @@
+package com.iyang.bootbasicio.sql;
+
+import lombok.extern.slf4j.Slf4j;
+import org.antlr.v4.runtime.tree.ParseTree;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/***
+ * @author: yang_bao
+ * @date: 2023/10/30
+ * @desc:
+ ***/
+
+@Slf4j
+public class IcebergVisitor extends SqlBaseBaseVisitor {
+
+
+    private List<String> tableList = new ArrayList<>();
+
+    @Override
+    public List<String> visitSingleStatement(SqlBaseParser.SingleStatementContext ctx) {
+        super.visitSingleStatement(ctx);
+
+
+        return tableList;
+    }
+
+
+    @Override
+    public List<String> visitTableIdentifier(SqlBaseParser.TableIdentifierContext ctx) {
+        String db = ctx.db.getText();
+        String table = ctx.table.getText();
+
+        System.out.println("1111");
+        log.info("the visitTableIdentifier db value is --> {} , table is ---> {} " , db, table);
+        return tableList;
+    }
+
+
+    @Override
+    public Object visitInsertOverwriteTable(SqlBaseParser.InsertOverwriteTableContext ctx) {
+
+        return super.visitInsertOverwriteTable(ctx);
+    }
+
+/*    @Override
+    public Object visitSingleInsertQuery(SqlBaseParser.SingleInsertQueryContext ctx) {
+        String queryTermText = ctx.queryTerm().getText();
+        String queryStart = ctx.queryTerm().getStart().getText();
+        String queryStop = ctx.queryTerm().getStop().getText();
+
+
+        SqlBaseParser.QueryTermContext termContext = ctx.queryTerm();
+
+        log.info("the visitSingleInsertQuery.queryTerm() --> {}, start ---> {} , stop ---> {} ", queryTermText, queryStart, queryStop);
+        return super.visitSingleInsertQuery(ctx);
+    }*/
+
+    @Override
+    public Object visitUpdateTable(SqlBaseParser.UpdateTableContext ctx) {
+
+
+        return super.visitUpdateTable(ctx);
+    }
+
+
+    @Override
+    public Object visitDeleteFromTable(SqlBaseParser.DeleteFromTableContext ctx) {
+        return super.visitDeleteFromTable(ctx);
+    }
+}