diff --git a/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlan.java b/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlan.java
index 236e7fb397..76dd8fb6f6 100644
--- a/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlan.java
+++ b/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlan.java
@@ -9,5 +9,5 @@ public interface ExecutePlan {
 
     HBaseResultSet executeQuery(HBasePreparedStatement statement) throws SQLException;
 
-    void execute(HBasePreparedStatement statement);
+    void execute(HBasePreparedStatement statement) throws SQLException;
 }
diff --git a/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlanAdapter.java b/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlanAdapter.java
index 4179975f3f..e556128268 100644
--- a/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlanAdapter.java
+++ b/src/main/java/com/alibaba/druid/hbase/exec/ExecutePlanAdapter.java
@@ -13,7 +13,7 @@ public class ExecutePlanAdapter implements ExecutePlan {
     }
 
     @Override
-    public void execute(HBasePreparedStatement statement) {
+    public void execute(HBasePreparedStatement statement) throws SQLException {
         throw new UnsupportedOperationException();
     }
 
diff --git a/src/main/java/com/alibaba/druid/hbase/exec/InsertExecutePlan.java b/src/main/java/com/alibaba/druid/hbase/exec/InsertExecutePlan.java
index aa628b54f7..0665e252db 100644
--- a/src/main/java/com/alibaba/druid/hbase/exec/InsertExecutePlan.java
+++ b/src/main/java/com/alibaba/druid/hbase/exec/InsertExecutePlan.java
@@ -1,14 +1,26 @@
 package com.alibaba.druid.hbase.exec;
 
+import java.sql.SQLException;
+
+import org.apache.hadoop.hbase.client.HTableInterface;
+
+import com.alibaba.druid.hbase.HBaseConnection;
 import com.alibaba.druid.hbase.HBasePreparedStatement;
 
-
-
 public class InsertExecutePlan extends SingleTableExecutePlan {
 
     @Override
-    public void execute(HBasePreparedStatement statement) {
-        throw new UnsupportedOperationException();
+    public void execute(HBasePreparedStatement statement) throws SQLException {
+        try {
+            HBaseConnection connection = statement.getConnection();
+            HTableInterface htable = connection.getHTable(getTableName());
+
+            throw new UnsupportedOperationException();
+        } catch (SQLException e) {
+            throw e;
+        } catch (Exception e) {
+            throw new SQLException("executeQuery error", e);
+        }
     }
-    
+
 }