|
4,
"cell_type": 4,
"value": "Mi4w"
},
{
"row": "YzAwMQ==",
"family": "Q19DcmVkaXQ=",
"qualifier": "bmV3",
"timestamp": 1680432352886,
"cell_type": 4,
"value": "NS4w"
},
{
"row": "YzAwMQ==",
"family": "Q19OYW1l",
"timestamp": 1680431640279,
"cell_type": 4,
"value": "TWF0aA=="
},
{
"row": "YzAwMQ==",
"family": "Q19Obw==",
"timestamp": 1680431640250,
"cell_type": 4,
"value": "MTIzMDAx"
}
],
[
{
"row": "YzAwMg==",
"family": "Q19DcmVkaXQ=",
"timestamp": 1680431640328,
"cell_type": 4,
"value": "NS4w"
},
{
"row": "YzAwMg==",
"family": "Q19OYW1l",
"timestamp": 1680431640318,
"cell_type": 4,
"value": "Q29tcHV0ZXI="
},
{
"row": "YzAwMg==",
"family": "Q19Obw==",
"timestamp": 1680431640305,
"cell_type": 4,
"value": "MTIzMDAy"
}
],
[
{
"row": "YzAwMw==",
"family": "Q19DcmVkaXQ=",
"timestamp": 1680431640363,
"cell_type": 4,
"value": "My4w"
},
{
"row": "YzAwMw==",
"family": "Q19OYW1l",
"timestamp": 1680431640352,
"cell_type": 4,
"value": "RW5nbGlzaA=="
},
{
"row": "YzAwMw==",
"family": "Q19Obw==",
"timestamp": 1680431640343,
"cell_type": 4,
"value": "MTIzMDAz"
}
]
]
1.3 向已创建好的表添加和删除指定的列族或列
HBase Shell 对应代码
put 'course','c001','C_Credit:new','5.0'
delete 'course','c001','C_Credit:new'
使用普通客户端进行put操作，需要准备一个item数据包含当前操作的列族或列以及对应的值。支持覆盖重写与新增。
func TableInsertRowCol(c *gin.Context) {
table := c.PostForm("table")
rowKey := c.PostForm("rowKey")
colFamily := c.PostForm("colFamily")
col := c.PostForm("col")
val := c.PostForm("val")
var item map[string]map[string][]byte = make(map[string]map[string][]byte)
item[colFamily] = make(map[string][]byte)
item[colFamily][col] = []byte(val)
fmt.Println(item)
t, err := hrpc.NewPutStr(context.Background(), table, rowKey, item)
checkError(err, c)
res, err := variable.Client.Put(t)
checkError(err, c)
c.JSON(200, res)
}
测试结果
{
"Cells": null,
"Stale": false,
"Partial": false,
"Exists": null
}
删除列族或列，不需要val数据。列可以为空字符串，仅删除列族，不为空时则删除指定的列
func TableDeleteRowCol(c *gin.Context) {
table := c.PostForm("table")
rowKey := c.PostForm("rowKey")
colFamily := c.PostForm("colFamily")
col := c.PostForm("col")
// val := c.PostForm("val")
var item map[string]map[string][]byte = make(map[string]map[string][]byte)
item[colFamily] = make(map[s
|