golang hbase数据库基本操作笔记

不屈真实 · · 3766 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

HBase是一个面向列的分布式数据库,适合一些需要实时随机地访问超大规模数据集的场合,hbase可以提供高并发读写操作的支持。表是由Key-Value组成的,下面主要介绍一下golang下hbase的一些基本操作。本文用到的库主要有:

“github.com/tsuna/gohbase”

“github.com/tsuna/gohbase/filter”

“github.com/tsuna/gohbase/hrpc”

1、Hbase的连接

var client gohbase.Client

func ConnectHBase() {

     hbaseUrl := beego.AppConfig.String("hbaseHost")

     user := beego.AppConfig.String("userName")

     option := gohbase.EffectiveUser(user)

     client = gohbase.NewClient(hbaseUrl, option)

}

2,向表中添加数据

func PutsByRowkey(table, rowKey string, values map[string]map[string][]byte) (err error) {

     putRequest, err := hrpc.NewPutStr(context.Background(), table, rowKey, values)

     if err != nil {

         log4go.Error("hrpc.NewPutStr: %s", err.Error())

     }

     _, err = client.Put(putRequest)

     if err != nil {

         log4go.Error("hbase clients: %s", err.Error())

     }

     return

}

例如在hbase中建表hbase_table

hbase(main):041:0> create 'hbase_table',  {NAME=>'CF1'}, {NAME=>'CF2'}

此表此表中Key为NAME,有两个列族CF1和CF2,其中CF1和CF2下分别有两个列name和gender,Chinese和Math

values := map[string]map[string][]byte{

"CF1": map[string][]byte{

"name": []byte("TigerwolfC"),

"gender":[]byte("man")},

"CF2": map[string][]byte{

"Chinese":  []byte("99"),

"Math": []byte("100")}}

PutsByRowkey(table, rowkey, values)

3,更新表中数据

func UpdataHbase(table, rowKey string, values map[string]map[string][]byte) (err error) {

     putRequest, err := hrpc.NewPutStr(context.Background(), table, rowKey, values)

     if err != nil {

         log4go.Error("hrpc.NewPutStr: %s", err.Error())

     }

     res, err := client.Put(putRequest)

     fmt.Println(res)

     if err != nil {

         log4go.Error("hbase clients: %s", err.Error())

     }

     return

}

4、查看数据

func Gets(table, rowKey string) (*hrpc.Result, error) {

     getRequest, err := hrpc.NewGetStr(context.Background(), table, rowKey)

     if err != nil {

         log4go.Error("hrpc.NewGetStr: %s", err.Error())

     }

     res, err := 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

}

5、查看rowkey是否存在

func IsExistRowkey(table, rowKey string) bool {

     getRequest, err := hrpc.NewGetStr(context.Background(), table, rowKey)

     if err != nil {

         log4go.Error("hrpc.NewGetStr: %s", err.Error())

     }

     res, err := client.Get(getRequest)

     if err != nil {

         log4go.Error("get from hbase: %s", err.Error())

     }

     if len(res.Cells) > 0 {

         return true

     } else {

         return false

     }

}

6,删除数据

func DeleteByRowkey(table, rowkey string, value map[string]map[string][]byte) (err error) {

     deleteRequest, err := hrpc.NewDelStr(context.Background(), table, rowkey, value)

     if err != nil {

         log4go.Error("hrpc.NewDelStrRef: %s", err.Error())

     }

    //fmt.Println("deleteRequest:", deleteRequest)

     res, err := client.Delete(deleteRequest)

     fmt.Println(res)

    if err != nil {

         log4go.Error("hrpc.Scan: %s", err.Error())

     }

     return

}

按照rowkey删除整条记录可以如下操作

DeleteByRowkey(table, rowkey, nil)

如有不对欢迎指正,相互学习,共同进步。


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:不屈真实

查看原文:golang hbase数据库基本操作笔记

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

3766 次点击  ∙  1 赞  
加入收藏 微博
下一篇:服务器结构
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传