goHbase库的使用

import库：

import ("context""errors""fmt""github.com/jeanphorn/log4go""github.com/tsuna/gohbase""github.com/tsuna/gohbase/hrpc""io"
)

数据结构：

type HBHelper struct {HbaseUrl  stringZookeeperRoot stringOption  string_client   gohbase.Client
}

连接hbase函数：

func (hb *HBHelper) ConnectHBase(hbaseurl string,zkroot string) {hb.HbaseUrl = hbaseurlhb.ZookeeperRoot = zkroothb._client = gohbase.NewClient(hbaseurl,gohbase.ZookeeperRoot(zkroot))
}

指定时间戳写入一行数据：

//通过hb.PutsByRowkeyVersion(table, rowkey, values, hrpc.Timestamp(timestamp))调用，其中timestamp是time.Time类型，options也可以是其他 func(hrpc.Call)的函数
func (hb *HBHelper) PutsByRowkeyVersion(table, rowKey string, values map[string]map[string][]byte,options func(hrpc.Call) error) (err error) {putRequest, err := hrpc.NewPutStr(context.Background(), table, rowKey, values,options)if err != nil {log4go.Error("hrpc.NewPutStr: %s", err.Error())}_, err = hb._client.Put(putRequest)if err != nil {log4go.Error("hbase clients: %s", err.Error())}return
}

指定列按rowkey读取一条数据：

//指定表，通过options筛选数据，例如Families函数，或者filter函数
func (hb *HBHelper) GetsByOption(table string ,rowkey string, options func(hrpc.Call) error)(*hrpc.Result, error){getRequest, err := hrpc.NewGetStr(context.Background(), table,rowkey, options)if err != nil {log4go.Error("hrpc.NewGetStr: %s", err.Error())}res, err :=  hb._client.Get(getRequest)if err != nil {log4go.Error("hbase clients: %s", err.Error())}defer func() {if errs := recover(); errs != nil {switch fmt.Sprintf("%v", errs) {case "runtime error: index out of range":err = errors.New("NoSuchRowKeyOrQualifierException")case "runtime error: invalid memory address or nil pointer dereference":err = errors.New("NoSuchColFamilyException")default:err = fmt.Errorf("%v", errs)}}}()return res, nil
}

返回*hrpc.Result数据，使用方式如下:

 f := map[string][]string{"cf": []string{"name"}}getres, err := hb.GetsByOption("test",rowkey, hrpc.Families(f))if err != nil {fmt.Println(err)return}for i, v := range getres.Cells {row := string(v.Row[:])fam := string(v.Family[:])qua := string(v.Qualifier[:])value := string(v.Value[:])str := fmt.Sprintf("index:%d      Rowkey: %s      family: %s      qualifies:%s        value:%s", i, row, fam, qua, value)fmt.Println(str)}

package hrpc
// Result holds a slice of Cells as well as miscellaneous information about the response.
type Result struct {Cells   []*CellStale   boolPartial bool// Exists is only set if existance_only was set in the request query.Exists *bool
}type Cell pb.Cellpackage pbtype Cell struct {Row              []byte    `protobuf:"bytes,1,opt,name=row" json:"row,omitempty"`Family           []byte    `protobuf:"bytes,2,opt,name=family" json:"family,omitempty"`Qualifier        []byte    `protobuf:"bytes,3,opt,name=qualifier" json:"qualifier,omitempty"`Timestamp        *uint64   `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"`CellType         *CellType `protobuf:"varint,5,opt,name=cell_type,json=cellType,enum=pb.CellType" json:"cell_type,omitempty"`Value            []byte    `protobuf:"bytes,6,opt,name=value" json:"value,omitempty"`Tags             []byte    `protobuf:"bytes,7,opt,name=tags" json:"tags,omitempty"`XXX_unrecognized []byte    `json:"-"`
}

以上为源码的数据结构

Scan读取一列：

func (hb *HBHelper) ScanCol(table string, option1 func(hrpc.Call) error) (rsp []*hrpc.Result, err error) {var (scanRequest *hrpc.Scanres         *hrpc.Result)scanRequest, err = hrpc.NewScanStr(context.Background(), table, option1)if err != nil {log4go.Error("hrpc.NewScanStr: %s", err.Error())}scanner := hb._client.Scan(scanRequest)for {res, err = scanner.Next()if err == io.EOF || res == nil {break}if err != nil {log4go.Error("hrpc.Scan: %s", err.Error())}rsp = append(rsp, res)}return rsp, err
}

使用：

scanres, err := hb.ScanCol("test", hrpc.Families(f))
for i, arr := range scanres {for j, v := range arr.Cells {row := string(v.Row[:])fam := string(v.Family[:])qua := string(v.Qualifier[:])value := string(v.Value[:])str := fmt.Sprintf("indexA:%d        indexA:%d       Rowkey: %s      family: %s      qualifies:%s        value:%s", i, j, row, fam, qua, value)fmt.Println(str)}}

gohbase的使用相关推荐

golang开发需要掌握的核心包以及中间件，涵盖项目的各个领域
常用包常用包说明 fmt 实现格式化的输入输出操作,其中的fmt.Printf()和fmt.Println()是开发者使用最为频繁的函数. io 实现了一系列非平台相关的IO相关接口和实现,比如提 ...

gohbase的使用

goHbase库的使用

import库：

数据结构：

连接hbase函数：

指定时间戳写入一行数据：

指定列按rowkey读取一条数据：

Scan读取一列：

gohbase的使用相关推荐

最新文章

热门文章