From 93822191305b3ecccbe70b54abb1648a671d9c10 Mon Sep 17 00:00:00 2001
From: morefreeze <morefreeze@gmail.com>
Date: Thu, 10 Dec 2015 15:26:41 +0800
Subject: [PATCH] hbase/kv: fit for hbase refactor

---
 store/hbase/kv.go | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/store/hbase/kv.go b/store/hbase/kv.go
index 6ad45a8d90..3e7e6d0eec 100644
--- a/store/hbase/kv.go
+++ b/store/hbase/kv.go
@@ -156,7 +156,8 @@ func (d Driver) Open(dsn string) (kv.Storage, error) {
 	// it's OK to redistribute to transactions.
 	conns := make([]hbase.HBaseClient, 0, hbaseConnPoolSize)
 	for i := 0; i < hbaseConnPoolSize; i++ {
-		c, err := hbase.NewClient(zks, "/hbase")
+		var c hbase.HBaseClient
+		c, err = hbase.NewClient(zks, "/hbase")
 		if err != nil {
 			return nil, errors.Trace(err)
 		}
@@ -164,7 +165,12 @@ func (d Driver) Open(dsn string) (kv.Storage, error) {
 	}
 
 	c := conns[0]
-	if !c.TableExists(tableName) {
+	var b bool
+	b, err = c.TableExists(tableName)
+	if err != nil {
+		return nil, errors.Trace(err)
+	}
+	if !b {
 		// Create new hbase table for store.
 		t := hbase.NewTableDesciptor(hbase.NewTableNameWithDefaultNS(tableName))
 		cf := hbase.NewColumnFamilyDescriptor(hbaseColFamily)