使用idea操作Hbase数据库

首先创建一个maven项目，然后再pom.xml文件中添加

<id>cloudera</id>

<url>https://repository.cloudera.com/artifactory/cloudera-repos</url>

</repository>

</repositories>

<groupId>org.apache.hbase</groupId>

<artifactId>hbase-server</artifactId>

</dependency>

<groupId>org.apache.hbase</groupId>

<artifactId>hbase-client</artifactId>

</dependency>

<groupId>org.apache.hbase</groupId>

<artifactId>hbase</artifactId>

</dependency>

<groupId>org.apache.hbase</groupId>

<artifactId>hbase-client</artifactId>

</dependency>

<groupId>org.junit.jupiter</groupId>

<artifactId>junit-jupiter-api</artifactId>

<scope>compile</scope>

</dependency>

</dependencies>

~~修改表定义：~~

package cn.bdqn.hbase;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.*;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.client.*;

import org.apache.hadoop.hbase.regionserver.BloomType;

import org.junit.Before;

import org.junit.Test;

public class Demo {

Connectionconn=null;

@Before

public void getConn()throws Exception{

Configuration conf=HBaseConfiguration.create();//会自动加载hbase-site.xml

conf.set("hbase.zookeeper.quorum","pro01:2181,pro02:2181,pro03:2181,pro04:2181");

conn =ConnectionFactory.createConnection(conf);

}

/**

* DDl

@Test

public void tetsCreate()throws Exception{

//构建连接对象

;

//从连接中构造一个DDl操作器

Admin admin=conn.getAdmin();

//创建一个表定义描述对象

HTableDescriptor hTableDescriptor=new HTableDescriptor(TableName.valueOf("userlmj_info"));

//创建列族定义描述对象

HColumnDescriptor hColumnDescriptor_1=new HColumnDescriptor("baselmj_info");

HColumnDescriptor hColumnDescriptor_2=new HColumnDescriptor("extralmj_info");

hColumnDescriptor_1.setMaxVersions(3);//设置列族中存储数据的最大版本数，默认是1

//将列族定义信息对象放入表定义对象中

hTableDescriptor.addFamily(hColumnDescriptor_1);

hTableDescriptor.addFamily(hColumnDescriptor_2);

//用ddl操作器对象：admin 来建表

admin.createTable(hTableDescriptor);

//关闭连接

admin.close();

conn.close();

}

/**

* 删除表

@Test

public void deleted()throws Exception{

Admin admin=conn.getAdmin();

//停用表

admin.disableTable(TableName.valueOf("userlmj_info"));

//删除表

admin.deleteTable(TableName.valueOf("userlmj_info"));

admin.close();

conn.close();

}

/**

* 修改表--添加列族

@Test

public void uodateser()throws Exception{

Admin admin=conn.getAdmin();

//取出旧的表定义信息

HTableDescriptor tableDescriptor=admin.getTableDescriptor(TableName.valueOf("user_info"));

//新构造一个列族定义

HColumnDescriptor hColumnDescriptor=new HColumnDescriptor("other_info");

hColumnDescriptor.setBloomFilterType(BloomType.ROW);//设置该列族的布隆过滤器类型

//将列族添加到表定义中

tableDescriptor.addFamily(hColumnDescriptor);

admin.modifyTable(TableName.valueOf("user_info"),tableDescriptor);

}

~~修改表数据：~~

~~package cn.bdqn.hbase;~~

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.Cell;

import org.apache.hadoop.hbase.CellScanner;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.*;

import org.apache.hadoop.hbase.util.Bytes;

import org.junit.Before;

import org.junit.Test;

import java.util.ArrayList;

public class Demo2 {

Connectionconn=null;

@Before

public void getConn()throws Exception{

Configuration conf= HBaseConfiguration.create();//会自动加载hbase-site.xml

conf.set("hbase.zookeeper.quorum","pro01:2181,pro02:2181,pro03:2181,pro04:2181");

conn = ConnectionFactory.createConnection(conf);

}

/**

* 增

@Test

public void testPut()throws Exception{

//获取一个指定操作表的table对象

Table table=conn.getTable(TableName.valueOf("user_info"));

//构造要插入的数据为一个put类型的对象

Put put =new Put(Bytes.toBytes(007));

put.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("李明京"));

put.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes(18));

put.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("北京海淀"));

Put put2 =new Put(Bytes.toBytes("005"));

put2.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("lmj"));

put2.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes("19"));

put2.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("山西临汾"));

Put put3 =new Put(Bytes.toBytes("008"));

put3.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("laoli"));

put3.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes("89"));

put3.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("山东菏泽"));

ArrayList puts =new ArrayList();

//插入数据

puts.add(put2);

puts.add(put);

puts.add(put3);

table.put(puts);

table.close();

conn.close();

}

/**

* 删

@Test

public void delete()throws Exception{

Table table=conn.getTable(TableName.valueOf("user_info"));

//构造一个对象封装要删除的信息

Delete delete1=new Delete(Bytes.toBytes(007));

Delete delete2=new Delete(Bytes.toBytes("008"));

delete2.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"));

ArrayList dels=new ArrayList();

dels.add(delete1);

dels.add(delete2);

table.delete(dels);

table.close();

conn.close();

}

/**

* 改

* (put来覆盖)

@Test

public void testPuts()throws Exception{

//获取一个指定操作表的table对象

Table table=conn.getTable(TableName.valueOf("user_info"));

//构造要插入的数据为一个put类型的对象

Put put =new Put(Bytes.toBytes(007));

put.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("李明京"));

put.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes(18));

put.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("北京海淀"));

Put put2 =new Put(Bytes.toBytes("005"));

put2.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("lmj"));

put2.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes("19"));

put2.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("山西临汾"));

Put put3 =new Put(Bytes.toBytes("008"));

put3.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("laoli"));

put3.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes("89"));

put3.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("山东菏泽"));

ArrayList puts =new ArrayList();

//插入数据

puts.add(put2);

puts.add(put);

puts.add(put3);

table.put(puts);

table.close();

conn.close();

}

/**

*查

@Test

public void selects()throws Exception{

Table table=conn.getTable(TableName.valueOf("user_info"));

Get get =new Get("001".getBytes());

Result result = table.get(get);

//从结果中取用户指定的某个key的value

byte[] value = result.getValue("base_info".getBytes(),"age".getBytes());

System.out.println(value.toString());

System.out.println("-----------");

//遍历整行所有的单元格

CellScanner cellScanner = result.cellScanner();

while (cellScanner.advance()){

Cell current = cellScanner.current();

byte[] rowArray = current.getRowArray();

byte[] familyArray = current.getFamilyArray();

byte[] qualifierArray = current.getQualifierArray();

byte[] valueArray = current.getValueArray();

System.out.println("行键"+new String(rowArray,current.getRowOffset(),current.getRowLength()));

System.out.println("列族名"+new String(familyArray,current.getFamilyOffset(),current.getFamilyLength()));

System.out.println("列名"+new String(qualifierArray,current.getQualifierOffset(),current.getQualifierLength()));

System.out.println("value"+new String(valueArray,current.getValueOffset(),current.getValueLength()));

}

table.close();

conn.close();

}

/**

* 大范围插入数据

@Test

public void testPlus()throws Exception{

Table table=conn.getTable(TableName.valueOf("user_info"));

ArrayList puts=new ArrayList();

for (int i=0;i<1000;i++){

Put put=new Put(Bytes.toBytes(""+i));

put.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("username"),Bytes.toBytes("李明京"+i));

put.addColumn(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes(18+i));

put.addColumn(Bytes.toBytes("extra_info"),Bytes.toBytes("addr"),Bytes.toBytes("北京海淀"));

puts.add(put);

}

table.put(puts);

table.close();

conn.close();

}

/**

* 大范围查询数据

* @throws Exception

@Test

public void hangjian()throws Exception{

Table table=conn.getTable(TableName.valueOf("user_info"));

//包含起始行，不包含结束行，如果真的想查询末尾的话可以在后面添加一个不可见字节

Scan scan =new Scan("10".getBytes(),"20\000".getBytes());

ResultScanner scanner = table.getScanner(scan);

Iterator iterator = scanner.iterator();

while(iterator.hasNext()){

Result next = iterator.next();

while (next.advance()){

Cell current = next.current();

byte[] rowArray = current.getRowArray();

byte[] familyArray = current.getFamilyArray();

byte[] qualifierArray = current.getQualifierArray();

byte[] valueArray = current.getValueArray();

System.out.println("行键"+new String(rowArray,current.getRowOffset(),current.getRowLength()));

System.out.println("列族名"+new String(familyArray,current.getFamilyOffset(),current.getFamilyLength()));

System.out.println("列名"+new String(qualifierArray,current.getQualifierOffset(),current.getQualifierLength()));

System.out.println("value"+new String(valueArray,current.getValueOffset(),current.getValueLength()));

}

System.out.println("---------------");

}

最后编辑于：2019.08.22 16:13:44

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 216,258评论 6赞 498
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 92,335评论 3赞 392
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 162,225评论 0赞 353
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 58,126评论 1赞 292
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 67,140评论 6赞 388
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,098评论 1赞 295
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,018评论 3赞 417
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,857评论 0赞 273
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 45,298评论 1赞 310
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,518评论 2赞 332
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,678评论 1赞 348
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,400评论 5赞 343
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,993评论 3赞 325
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,638评论 0赞 22
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,801评论 1赞 268
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,661评论 2赞 368
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,558评论 2赞 352

使用idea操作Hbase数据库

推荐阅读更多精彩内容