refactor

argan · May 21, 2012 · 7a8e973 · 7a8e973
1 parent 90b680e
commit 7a8e973
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/main/java/com/alibaba/druid/hdriver/HConnection.java b/src/main/java/com/alibaba/druid/hdriver/HConnection.java
@@ -7,4 +7,6 @@
 
 public interface HConnection extends Connection {
     HPreparedStatementImpl prepareStatement(String sql) throws SQLException;
+
+    HStatement createStatement() throws SQLException;;
 }
diff --git a/src/main/java/com/alibaba/druid/hdriver/impl/HBaseConnectionImpl.java b/src/main/java/com/alibaba/druid/hdriver/impl/HBaseConnectionImpl.java
@@ -13,7 +13,6 @@
 import java.sql.SQLFeatureNotSupportedException;
 import java.sql.SQLXML;
 import java.sql.Savepoint;
-import java.sql.Statement;
 import java.sql.Struct;
 import java.util.Map;
 import java.util.Properties;
@@ -22,6 +21,7 @@
 import org.apache.hadoop.hbase.client.HTableInterface;
 
 import com.alibaba.druid.hdriver.HConnection;
+import com.alibaba.druid.hdriver.HStatement;
 import com.alibaba.druid.util.jdbc.ConnectionBase;
 
 public class HBaseConnectionImpl extends ConnectionBase implements HConnection {
@@ -76,17 +76,17 @@ public SQLXML createSQLXML() throws SQLException {
     }
 
     @Override
-    public Statement createStatement() throws SQLException {
+    public HStatement createStatement() throws SQLException {
         return new HStatementImpl(this);
     }
 
     @Override
-    public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException {
+    public HStatement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException {
         throw new SQLFeatureNotSupportedException();
     }
 
     @Override
-    public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
+    public HStatement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
                                                                                                            throws SQLException {
         throw new SQLFeatureNotSupportedException();
     }