Hbase数据库常见操作
admin
2023-02-21 03:00:08
0次
1、创建maven工程
自动导包（需要从cloudera仓库下载，耗时较长，耐心等待）
如下内容作为maven工程中pom.xml的repositories的内容
cloudera
https://repository.cloudera.com/artifactory/cloudera-repos/
org.apache.hadoop
hadoop-client
2.6.0-mr1-cdh6.14.2
org.apache.hbase
hbase-client
1.2.0-cdh6.14.2
org.apache.hbase
hbase-server
1.2.0-cdh6.14.2
junit
junit
4.12
test
org.testng
testng
6.14.3
test
org.apache.maven.plugins
maven-compiler-plugin
3.0
1.8
1.8
UTF-8
org.apache.maven.plugins
maven-shade-plugin
2.2
package
shade
*:*
META-INF/*.SF
META-INF/*.DSA
META-INF/*/RSA
2、创建表
- 创建myuser表，此表有两个列族f1和f2
/**
* 操作数据库 第一步：获取连接 第二步：获取客户端对象 第三步：操作数据库 第四步：关闭
* 创建myuser表，有两个列族 f1 f2
* @throws IOException
*/
@Test
public void createTable() throws IOException {
//获得连接
Configuration configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "node01:2181,node02:2181,node03:2181");
//创建连接对象
Connection connection = ConnectionFactory.createConnection(configuration);
//操作：建表、删除表、修改表 -> 管理员；创建管理员对象
Admin admin = connection.getAdmin();
//添加了表名信息
HTableDescriptor myuser = new HTableDescriptor(TableName.valueOf("myuser"));
//给表添加列族
myuser.addFamily(new HColumnDescriptor("f1"));
myuser.addFamily(new HColumnDescriptor("f2"));
//创建表
admin.createTable(myuser);
//关闭连接
admin.close();
connection.close();
}3、添加数据
private Connection connection;
private Table table;
//建立连接
@BeforeTest
public void init() throws IOException {
//获得连接
Configuration configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "node01:2181,node02:2181,node03:2181");
//configuration.set("zookeeper.znode.parent", "/HBase");
connection = ConnectionFactory.createConnection(configuration);
//获得表
table = connection.getTable(TableName.valueOf("myuser"));
}
@AfterTest
public void close() throws IOException {
table.close();
connection.close();
}
//向表中添加数据
@Test
public void putData() throws IOException {
Put put = new Put("0001".getBytes());//创建Put对象，并指定rowkey值
//添加cell值：列族名称+列名+值
put.addColumn("f1".getBytes(), "name".getBytes(), "zhangsan".getBytes());
put.addColumn("f1".getBytes(), "age".getBytes(), Bytes.toBytes(18));
put.addColumn("f1".getBytes(),"id".getBytes(), Bytes.toBytes(25));
put.addColumn("f1".getBytes(),"address".getBytes(), Bytes.toBytes("地球人"));
table.put(put);
}4、查询数据
- 初始化一批数据到HBase表当中，用于查询
@Test
public void batchInsert() throws IOException {
//创建put对象，并指定rowkey
Put put = new Put("0002".getBytes());
//向f1列族添加数据
put.addColumn("f1".getBytes(),"id".getBytes(),Bytes.toBytes(1));
put.addColumn("f1".getBytes(),"name".getBytes(),Bytes.toBytes("曹操"));
put.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(30));
//向f2列族添加数据
put.addColumn("f2".getBytes(),"sex".getBytes(),Bytes.toBytes("1"));
put.addColumn("f2".getBytes(),"address".getBytes(),Bytes.toBytes("沛国谯县"));
put.addColumn("f2".getBytes(),"phone".getBytes(),Bytes.toBytes("16888888888"));
put.addColumn("f2".getBytes(),"say".getBytes(),Bytes.toBytes("helloworld"));
Put put2 = new Put("0003".getBytes());
put2.addColumn("f1".getBytes(),"id".getBytes(),Bytes.toBytes(2));
put2.addColumn("f1".getBytes(),"name".getBytes(),Bytes.toBytes("刘备"));
put2.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(32));
put2.addColumn("f2".getBytes(),"sex".getBytes(),Bytes.toBytes("1"));
put2.addColumn("f2".getBytes(),"address".getBytes(),Bytes.toBytes("幽州涿郡涿县"));
put2.addColumn("f2".getBytes(),"phone".getBytes(),Bytes.toBytes("17888888888"));
put2.addColumn("f2".getBytes(),"say".getBytes(),Bytes.toBytes("talk is cheap , show me the code"));
Put put3 = new Put("0004".getBytes());
put3.addColumn("f1".getBytes(),"id".getBytes(),Bytes.toBytes(3));
put3.addColumn("f1".getBytes(),"name".getBytes(),Bytes.toBytes("孙权"));
put3.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(35));
put3.addColumn("f2".getBytes(),"sex".getBytes(),Bytes.toBytes("1"));
put3.addColumn("f2".getBytes(),"address".getBytes(),Bytes.toBytes("下邳"));
put3.addColumn("f2".getBytes(),"phone".getBytes(),Bytes.toBytes("12888888888"));
put3.addColumn("f2".getBytes(),"say".getBytes(),Bytes.toBytes("what are you 弄啥嘞！"));
Put put4 = new Put("0005".getBytes());
put4.addColumn("f1".getBytes(),"id".getBytes(),Bytes.toBytes(4));
put4.addColumn("f1".getBytes(),"name".getBytes(),Bytes.toBytes("诸葛亮"));
put4.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(28));
put4.addColumn("f2".getBytes(),"sex".getBytes(),Bytes.toBytes("1"));
put4.addColumn("f2".getBytes(),"address".getBytes(),Bytes.toBytes("四川隆中"));
put4.addColumn("f2".getBytes(),"phone".getBytes(),Bytes.toBytes("14888888888"));
put4.addColumn("f2".getBytes(),"say".getBytes(),Bytes.toBytes("出师表你背了嘛"));
Put put5 = new Put("0006".getBytes());
put5.addColumn("f1".getBytes(),"id".getBytes(),Bytes.toBytes(5));
put5.addColumn("f1".getBytes(),"name".getBytes(),Bytes.toBytes("司马懿"));
put5.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(27));
put5.addColumn("f2".getBytes(),"sex".getBytes(),Bytes.toBytes("1"));
put5.addColumn("f2".getBytes(),"address".getBytes(),Bytes.toBytes("哪里人有待考究"));
put5.addColumn("f2".getBytes(),"phone".getBytes(),Bytes.toBytes("15888888888"));
put5.addColumn("f2".getBytes(),"say".getBytes(),Bytes.toBytes("跟诸葛亮死掐"));
Put put6 = new Put("0007".getBytes());
put6.addColumn("f1".getBytes(),"id".getBytes(),Bytes.toBytes(5));
put6.addColumn("f1".getBytes(),"name".getBytes(),Bytes.toBytes("xiaobubu—吕布"));
put6.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(28));
put6.addColumn("f2".getBytes(),"sex".getBytes(),Bytes.toBytes("1"));
put6.addColumn("f2".getBytes(),"address".getBytes(),Bytes.toBytes("内蒙人"));
put6.addColumn("f2".getBytes(),"phone".getBytes(),Bytes.toBytes("15788888888"));
put6.addColumn("f2".getBytes(),"say".getBytes(),Bytes.toBytes("貂蝉去哪了"));
List listPut = new ArrayList();
listPut.add(put);
listPut.add(put2);
listPut.add(put3);
listPut.add(put4);
listPut.add(put5);
listPut.add(put6);
table.put(listPut);
} 4.1 Get查询
- 按照rowkey进行查询，获取所有列的所有值
- 查询主键rowkey为0003的人
//查询rowkey为0003的数据
@Test
public void getDataByRowkey() throws IOException {
//通过get对象，指定rowkey
Get get = new Get("0003".getBytes());
//获取某列族
get.addFamily("f1".getBytes());//限定查询f1列族下面所有列的值
get.addColumn("f2".getBytes(), "say".getBytes());//查询f2列族say列的值
//通过get查询，返回0003行，f1列族、f2:say列的所有cell的值，封装到一个Result对象
Result result = table.get(get);
//获得Result中的所有Cell
List| cells = result.listCells();
//遍历Cell
for(Cell cell: cells) {
//cell单元格
//获得rowkey
byte[] rowkey_bytes = CellUtil.cloneRow(cell);
//获得列族
byte[] family_bytes = CellUtil.cloneFamily(cell);
//获得列
byte[] qualifier_bytes = CellUtil.cloneQualifier(cell);
//获得值
byte[] cell_bytes = CellUtil.cloneValue(cell);
if("age".equals(Bytes.toString(qualifier_bytes)) || "id".equals(Bytes.toString(qualifier_bytes))) {
System.out.println(Bytes.toString(rowkey_bytes));
System.out.println(Bytes.toString(family_bytes));
System.out.println(Bytes.toString(qualifier_bytes));
System.out.println(Bytes.toInt(cell_bytes));//age或id的值是int类型，得用Bytes.toInt
} else {
System.out.println(Bytes.toString(rowkey_bytes));
System.out.println(Bytes.toString(family_bytes));
System.out.println(Bytes.toString(qualifier_bytes));
System.out.println(Bytes.toString(cell_bytes));
}
}
} | 4.2 Scan查询
/**
* 不知道rowkey的具体值，我想查询rowkey范围值是0003 到0006
* select * from myuser where age > 30 and id < 8 and name like 'zhangsan'
*/
@Test
public void scanData() throws IOException {
Scan scan = new Scan();//若没有指定startRow以及stopRow，则全表扫描
//扫描f1列族
scan.addFamily("f1".getBytes());
//扫描 f2列族 phone列
scan.addColumn("f2".getBytes(),"phone".getBytes());
//设置起始结束rowkey，前闭后开
scan.setStartRow("0003".getBytes());
scan.setStopRow("0007".getBytes());
//设置每批次返回客户端的数据条数
scan.setBatch(20);
//从cacheBlock中读取数据
scan.setCacheBlocks(true);
scan.setMaxResultSize(4);
scan.setMaxVersions(2);//获取历史2个版本
//通过getScanner查询获取到了表里面所有的数据，是多条数据
ResultScanner scanner = table.getScanner(scan);
//遍历ResultScanner 得到每一条数据，每一条数据都是封装在result对象里面了
for (Result result : scanner) {
List| cells = result.listCells();
for (Cell cell : cells) {
byte[] family_name = CellUtil.cloneFamily(cell);
byte[] qualifier_name = CellUtil.cloneQualifier(cell);
byte[] rowkey = CellUtil.cloneRow(cell);
byte[] value = CellUtil.cloneValue(cell);
//判断id和age字段，这两个字段是整形值
if("age".equals(Bytes.toString(qualifier_name)) || "id".equals(Bytes.toString(qualifier_name))){
System.out.println("数据的rowkey为" + Bytes.toString(rowkey) +"======数据的列族为" + Bytes.toString(family_name)+"======数据的列名为" + Bytes.toString(qualifier_name) + "==========数据的值为" +Bytes.toInt(value));
}else{
System.out.println("数据的rowkey为" + Bytes.toString(rowkey) +"======数据的列族为" + Bytes.toString(family_name)+"======数据的列名为" + Bytes.toString(qualifier_name) + "==========数据的值为" +Bytes.toString(value));
}
}
}
} | 5、HBase的删除操作
5.1、根据rowkey删除数据
- 删除rowkey为003的数据
/**
* 删除数据
*/
@Test
public void deleteData() throws IOException {
Delete delete = new Delete("0003".getBytes());
delete.addFamily("f1".getBytes());
delete.addColumn("f2".getBytes(), "phone".getBytes());
table.delete(delete);
}5.2、删除表操作
/**
* 删除表
*/
@Test
public void deleteTable() throws IOException {
//获取管理员对象，用于表的删除
Admin admin = connection.getAdmin();
//删除一张表之前，需要先禁用表
admin.disableTable(TableName.valueOf("myuser"));
admin.deleteTable(TableName.valueOf("myuser"));
}e(delete);
}
## 5.2、删除表操作
```java
/**
* 删除表
*/
@Test
public void deleteTable() throws IOException {
//获取管理员对象，用于表的删除
Admin admin = connection.getAdmin();
//删除一张表之前，需要先禁用表
admin.disableTable(TableName.valueOf("myuser"));
admin.deleteTable(TableName.valueOf("myuser"));
}
相关内容
热门资讯
玩家最新攻略“微信链接牛牛.到...
有 亲，根据资深记者爆料微信链接牛牛是可以开挂的，确实有挂（咨询软件无需...
终于明白“大富豪.究竟有挂吗？...
有 亲，根据资深记者爆料大富豪是可以开挂的，确实有挂（咨询软件无需打开直...
【第一财经】“天天微友炸金花....
家人们！今天小编来为大家解答天天微友炸金花透视挂怎么安装这个问题咨询软件客服徽9784099的挂在哪...
【第一消息】“问鼎娱乐.有挂吗...
【第一消息】“问鼎娱乐.有挂吗？”太坑了原来有挂您好，问鼎娱乐这个游戏其实有挂的，确实是有挂的，需要...
重磅消息“微信小程序麻将.开挂...
您好：微信小程序麻将这款游戏可以开挂，确实是有挂的，需要了解加客服微信【4282891】很多玩家在这...
今日重大消息“推大石.到底有挂...
今日重大消息“推大石.到底有挂吗？”透视曝光猫腻您好，推大石这个游戏其实有挂的，确实是有挂的，需要了...
今日重大通报“微乐陕西三代一....
家人们！今天小编来为大家解答微乐陕西三代一透视挂怎么安装这个问题咨询软件客服徽4282891的挂在哪...
玩家最新攻略“琼雀海南麻将.开...
家人们！今天小编来为大家解答琼雀海南麻将透视挂怎么安装这个问题咨询软件客服徽9784099的挂在哪里...
今日重磅消息“YY棋牌.有没有...
有 亲，根据资深记者爆料YY棋牌是可以开挂的，确实有挂（咨询软件无需打开...
玩家最新攻略“同城游比鸡.辅助...
网上科普关于“同城游比鸡有没有挂”话题很是火热，小编也是针对同城游比鸡作*弊开挂的方法以及开挂对应的...