hbase support

src/main/java/com/alibaba/druid/hbase/HBasePreparedStatement.java

@@ -12,6 +12,7 @@ import com.alibaba.druid.sql.SQLUtils;
 import com.alibaba.druid.sql.ast.SQLStatement;
 import com.alibaba.druid.sql.ast.expr.SQLIdentifierExpr;
 import com.alibaba.druid.sql.ast.statement.SQLExprTableSource;
+import com.alibaba.druid.sql.ast.statement.SQLInsertStatement;
 import com.alibaba.druid.sql.ast.statement.SQLSelectQueryBlock;
 import com.alibaba.druid.sql.ast.statement.SQLSelectStatement;
 
@@ -53,6 +54,12 @@ public class HBasePreparedStatement extends PreparedStatementBase implements Pre
             singleTableQueryExecuetePlan.setTableName(tableName);
 
             this.executePlan = singleTableQueryExecuetePlan;
+        } else if (sqlStmt instanceof SQLInsertStatement) {
+            SQLInsertStatement insertStmt = (SQLInsertStatement) sqlStmt;
+            
+            String tableName = ((SQLIdentifierExpr) insertStmt.getTableSource().getExpr()).getName();
+            
+            throw new SQLException("TODO");
         } else {
             throw new SQLException("TODO");
         }

src/main/java/com/alibaba/druid/hbase/exec/ExecutePlan.java

@@ -6,5 +6,8 @@ import com.alibaba.druid.hbase.HBasePreparedStatement;
 import com.alibaba.druid.hbase.HBaseResultSet;
 
 public interface ExecutePlan {
+
     HBaseResultSet executeQuery(HBasePreparedStatement statement) throws SQLException;
+
+    void execute(HBasePreparedStatement statement);
 }

src/main/java/com/alibaba/druid/hbase/exec/ExecutePlanAdapter.java

@@ -0,0 +1,20 @@
+package com.alibaba.druid.hbase.exec;
+
+import java.sql.SQLException;
+
+import com.alibaba.druid.hbase.HBasePreparedStatement;
+import com.alibaba.druid.hbase.HBaseResultSet;
+
+public class ExecutePlanAdapter implements ExecutePlan {
+
+    @Override
+    public HBaseResultSet executeQuery(HBasePreparedStatement statement) throws SQLException {
+        throw new UnsupportedOperationException();
+    }
+
+    @Override
+    public void execute(HBasePreparedStatement statement) {
+        throw new UnsupportedOperationException();
+    }
+
+}

src/main/java/com/alibaba/druid/hbase/exec/InsertExecutePlan.java

@@ -0,0 +1,14 @@
+package com.alibaba.druid.hbase.exec;
+
+import com.alibaba.druid.hbase.HBasePreparedStatement;
+
+
+
+public class InsertExecutePlan extends SingleTableExecutePlan {
+
+    @Override
+    public void execute(HBasePreparedStatement statement) {
+        throw new UnsupportedOperationException();
+    }
+    
+}

src/main/java/com/alibaba/druid/hbase/exec/SingleTableExecutePlan.java

@@ -0,0 +1,14 @@
+package com.alibaba.druid.hbase.exec;
+
+
+public class SingleTableExecutePlan extends ExecutePlanAdapter {
+    private String tableName;
+
+    public String getTableName() {
+        return tableName;
+    }
+
+    public void setTableName(String tableName) {
+        this.tableName = tableName;
+    }
+}

src/main/java/com/alibaba/druid/hbase/exec/SingleTableQueryExecutePlan.java

@@ -10,27 +10,17 @@ import com.alibaba.druid.hbase.HBaseConnection;
 import com.alibaba.druid.hbase.HBasePreparedStatement;
 import com.alibaba.druid.hbase.HBaseResultSet;
 
-public class SingleTableQueryExecutePlan implements ExecutePlan {
-
-    private String tableName;
-
-    public String getTableName() {
-        return tableName;
-    }
-
-    public void setTableName(String tableName) {
-        this.tableName = tableName;
-    }
+public class SingleTableQueryExecutePlan extends SingleTableExecutePlan {
 
     @Override
     public HBaseResultSet executeQuery(HBasePreparedStatement statement) throws SQLException {
         try {
             HBaseConnection connection = statement.getConnection();
-            HTableInterface htable = connection.getHTable(tableName);
-            
+            HTableInterface htable = connection.getHTable(getTableName());
+
             Scan scan = new Scan();
             ResultScanner scanner = htable.getScanner(scan);
-            
+
             return new HBaseResultSet(statement, htable, scanner);
         } catch (SQLException e) {
             throw e;