refactor

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

@@ -35,7 +35,7 @@ public class SingleTableQueryExecutePlan extends SingleTableExecutePlan {
 
     private HResultSetMetaData resultMetaData;
 
-    private HMappingTable           mapping;
+    private HMappingTable      mapping;
 
     public SingleTableQueryExecutePlan(){
 

src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java

@@ -1,6 +1,14 @@
 package com.alibaba.druid.hbase.mapping;
 
+import org.apache.hadoop.hbase.client.Result;
 
 public interface HMapping {
 
+    byte[] getFamily(String columnName);
+
+    byte[] getQualifier(String columnName);
+    
+    boolean isRow(String columnName);
+
+    Object getObject(Result result, String name);
 }

src/main/java/com/alibaba/druid/hbase/mapping/HMappingDefaultImpl.java

@@ -0,0 +1,42 @@
+package com.alibaba.druid.hbase.mapping;
+
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.util.Bytes;
+
+public class HMappingDefaultImpl implements HMapping {
+
+    private byte[] family = Bytes.toBytes("d");
+
+    @Override
+    public Object getObject(Result result, String columnName) {
+        byte[] family = this.getFamily(columnName);
+
+        byte[] bytes;
+        if (isRow(columnName)) {
+            bytes = result.getRow();
+        } else {
+            byte[] qualifier = Bytes.toBytes(columnName);
+            bytes = result.getValue(family, qualifier);
+        }
+
+        return bytes;
+    }
+
+    public byte[] getFamily(String columnName) {
+        return family;
+    }
+
+    @Override
+    public byte[] getQualifier(String columnName) {
+        return Bytes.toBytes(columnName);
+    }
+
+    @Override
+    public boolean isRow(String columnName) {
+        if ("id".equals(columnName)) {
+            return true;
+        }
+
+        return false;
+    }
+}