excel-jdbc-driver up

budo-excel-jdbc-driver/pom.xml

@@ -55,6 +55,12 @@
             <version>0.0.2-dr-SNAPSHOT</version>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>com.github.jsqlparser</groupId>
+            <artifactId>jsqlparser</artifactId>
+            <version>1.0</version>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 
     <build>

budo-excel-jdbc-driver/src/main/java/org/budo/excel/jdbc/driver/parser/jsqlparser/JSqlParserExcelStatementParser.java

@@ -4,9 +4,20 @@ import java.sql.SQLException;
 
 import org.budo.excel.jdbc.driver.statement.impl.SHOW_FULL_TABLES;
 import org.budo.excel.jdbc.driver.statement.impl.SHOW_TABLE_STATUS;
+import org.budo.excel.jdbc.driver.statement.impl.SelectStatement;
+import org.budo.jdbc.driver.exception.BudoJdbcDriverNotSupportedException;
 import org.budo.jdbc.driver.parser.AbstractSqlStatementParser;
 import org.budo.jdbc.driver.statement.JdbcStatement;
 
+import net.sf.jsqlparser.parser.CCJSqlParserUtil;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.delete.Delete;
+import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.select.PlainSelect;
+import net.sf.jsqlparser.statement.select.Select;
+import net.sf.jsqlparser.statement.select.SelectBody;
+import net.sf.jsqlparser.statement.update.Update;
+
 /**
  * @author lmw
  */
@@ -24,9 +35,57 @@ public class JSqlParserExcelStatementParser extends AbstractSqlStatementParser {
 
         return super.parse(sql);
     }
-    
+
     @Override
     protected JdbcStatement doParseSql(String sql) throws Throwable {
-        return super.doParseSql(sql);
+        Statement statement = CCJSqlParserUtil.parse(sql);
+
+        if (statement instanceof Insert) {
+            return this.parseInsert(sql, (Insert) statement);
+        }
+
+        if (statement instanceof Update) {
+            return this.parseUpdate(sql, (Update) statement);
+        }
+
+        if (statement instanceof Delete) {
+            return this.parseDelete(sql, (Delete) statement);
+        }
+
+        if (statement instanceof Select) {
+            return this.parseSelect(sql, statement);
+        }
+
+        throw new BudoJdbcDriverNotSupportedException("#106 not supported sql : " + sql //
+                + ", statement=" + statement + ", type=" + statement.getClass());
+    }
+
+    private JdbcStatement parseSelect(String sql, Statement statement) {
+        Select select = (Select) statement;
+        SelectBody selectBody = select.getSelectBody();
+
+        if (selectBody instanceof PlainSelect) {
+            return this.parsePlainSelect(sql, statement, selectBody);
+        }
+
+        throw new BudoJdbcDriverNotSupportedException("#70 not supported sql(selectBody) : sql=" + sql //
+                + ", statement=" + statement + ", type=" + statement.getClass() //
+                + ", selectBody=" + selectBody + ", selectBody.type=" + selectBody.getClass());
+    }
+
+    private JdbcStatement parsePlainSelect(String sql, Statement statement, SelectBody selectBody) {
+        return new SelectStatement();
+    }
+
+    private JdbcStatement parseDelete(String sql, Delete statement) {
+        throw new RuntimeException();
+    }
+
+    private JdbcStatement parseUpdate(String sql, Update statement) {
+        throw new RuntimeException();
+    }
+
+    private JdbcStatement parseInsert(String sql, Insert statement) {
+        throw new RuntimeException();
     }
 }

budo-excel-jdbc-driver/src/main/java/org/budo/excel/jdbc/driver/statement/impl/SelectStatement.java

@@ -0,0 +1,8 @@
+package org.budo.excel.jdbc.driver.statement.impl;
+
+import org.budo.excel.jdbc.driver.statement.AbstractExcelStatement;
+
+/**
+ * @author limingwei
+ */
+public class SelectStatement extends AbstractExcelStatement {}

budo-jdbc-driver/src/main/java/org/budo/jdbc/driver/parser/AbstractSqlStatementParser.java

@@ -85,6 +85,7 @@ public abstract class AbstractSqlStatementParser implements SqlStatementParser {
 
     protected JdbcStatement doParseSql(String sql) throws Throwable {
         log.error("#82 this=" + this + ", sql=" + sql);
+
         throw new RuntimeException("#83 this=" + this + ", sql=" + sql);
     }
 }