database/hbase

config := &hbase.Config{Zookeeper: &hbase.ZKConfig{Addrs: []string{"localhost"}}}
client := hbase.NewClient(config)

package main

import (
	"context"
	"fmt"
    
    "gitee.com/djienet/kratos/pkg/database/hbase"
)

func main() {
    config := &hbase.Config{Zookeeper: &hbase.ZKConfig{Addrs: []string{"localhost"}}}
    client := hbase.NewClient(config)

    // 
    values := map[string]map[string][]byte{"name": {"firstname": []byte("hello"), "lastname": []byte("world")}}
    ctx := context.Background()

    // 写入信息
    // table: user
    // rowkey: user1
    // values["family"] = columns
    _, err := client.PutStr(ctx, "user", "user1", values)
    if err != nil {
        panic(err)
    }

    // 读取信息
    // table: user
    // rowkey: user1
    result, err := client.GetStr(ctx, "user", "user1")
    if err != nil {
        panic(err)
    }
    fmt.Printf("%v", result)
}