database/tidb
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #703 from pingcap/morefreeze/fit_hbase

Browse Source 
[DNM] fit for hbase refactor
This commit is contained in:
qiuyesuifeng
2015-12-12 11:37:49 +08:00
parent 0cc8d2e599 9382219130
commit 683f8afa94
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
store/hbase/kv.go
View File

@ -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)