首页 > 编程语言 >HBase Java客户端编程

HBase Java客户端编程

时间:2023-07-26 13:07:13浏览次数:45  
标签:Java String tablename System kv new HBase out 客户端


本文以HBase 0.90.2为例,介绍如何在Windows系统,Eclipse IDE集成环境下,使用Java语言,进行HBase客户端编程,包含建立表、删除表、插入记录、删除记录、各种方式下的查询操作等。

1. 准备工作

1、下载后安装jdk包(这里使用的是jdk-6u10-rc2-bin-b32-windows-i586-p-12_sep_2008);

2、下载eclipse,解压到本地(这里使用的是eclipse-java-helios-SR2-win32);

3、下载HBase包,解压安装包到本地(这里使用的是hbase-0.90.2)。

2. 搭建开发环境

1、运行Eclipse,创建一个新的Java工程“HBaseClient”,右键项目根目录,选择 “Properties”->“Java Build Path”->“Library”->“Add External JARs”,将HBase解压后根目录下的hbase-0.90.2.jar、hbase-0.90.2-tests.jar和lib子目录下所有jar 包添加到本工程的Classpath下。

2、按照步骤1中的操作,将自己所连接的HBase的配置文件hbase-site.xml添加到本工程的Classpath中,如下所示为配置文件的一个示例:




1 <configuration> 2 <property> 3 <name>hbase.rootdir</name> 4 <value>hdfs://hostname:9000/hbase</value> 5 </property> 6 <property> 7 <name>hbase.cluster.distributed</name> 8 <value>true</value> 9 </property>10 <property>11 <name>hbase.zookeeper.quorum</name>12 <value>*.*.*.*, *.*.*.*, *.*.*.*</value>13 </property>14 <property skipInDoc="true">15 <name>hbase.defaults.for.version</name>16 <value>0.90.2</value>17 </property>18 </configuration>




3、下面可以在Eclipse环境下进行HBase编程了。

3. HBase基本操作代码示例

3.1 初始化配置




1 privatestatic Configuration conf =null;
2 /**3  * 初始化配置
4 */5 static {
6     conf = HBaseConfiguration.create();
7 }




3.2 创建表




1 /** 2  * 创建表操作
 3  * @throws IOException
 4 */ 5 publicvoid createTable(String tablename, String[] cfs) throws IOException {
 6     HBaseAdmin admin =new HBaseAdmin(conf);
 7 if (admin.tableExists(tablename)) {
 8         System.out.println("表已经存在!");
 9     }
10 else {
11         HTableDescriptor tableDesc =new HTableDescriptor(tablename);
12 for (int i =0; i < cfs.length; i++) {
13             tableDesc.addFamily(new HColumnDescriptor(cfs[i]));
14         }
15         admin.createTable(tableDesc);
16         System.out.println("表创建成功!");
17     }
18 }




3.3 删除表





1 /** 2  * 删除表操作
 3  * @param tablename
 4  * @throws IOException
 5 */ 6 publicvoid deleteTable(String tablename) throws IOException {
 7 try {
 8         HBaseAdmin admin =new HBaseAdmin(conf);
 9         admin.disableTable(tablename);
10         admin.deleteTable(tablename);
11         System.out.println("表删除成功!");
12     } catch (MasterNotRunningException e) {
13         e.printStackTrace();
14     } catch (ZooKeeperConnectionException e) {
15         e.printStackTrace();
16     }
17 }




3.4 插入一行记录




1 /** 2  * 插入一行记录
 3  * @param tablename
 4  * @param cfs
 5 */ 6 publicvoid writeRow(String tablename, String[] cfs) {
 7 try {
 8         HTable table =new HTable(conf, tablename);
 9         Put put =new Put(Bytes.toBytes("rows1"));
10 for (int j =0; j < cfs.length; j++) {
11             put.add(Bytes.toBytes(cfs[j]),
12                     Bytes.toBytes(String.valueOf(1)),
13                     Bytes.toBytes("value_1"));
14             table.put(put);
15         }
16     } catch (IOException e) {
17         e.printStackTrace();
18     }
19 }




3.5 删除一行记录




1 /** 2  * 删除一行记录
 3  * @param tablename
 4  * @param rowkey
 5  * @throws IOException
 6 */ 7 publicvoid deleteRow(String tablename, String rowkey) throws IOException {
 8     HTable table =new HTable(conf, tablename);
 9     List list =new ArrayList();
10     Delete d1 =new Delete(rowkey.getBytes());
11     list.add(d1);
12     table.delete(list);
13     System.out.println("删除行成功!");
14 }




3.6 查找一行记录




1 /** 2  * 查找一行记录
 3  * @param tablename
 4  * @param rowkey
 5 */ 6 publicstaticvoid selectRow(String tablename, String rowKey)
 7 throws IOException {
 8     HTable table =new HTable(conf, tablename);
 9     Get g =new Get(rowKey.getBytes());
10     Result rs = table.get(g);
11 for (KeyValue kv : rs.raw()) {
12         System.out.print(new String(kv.getRow()) +"");
13         System.out.print(new String(kv.getFamily()) +":");
14         System.out.print(new String(kv.getQualifier()) +"");
15         System.out.print(kv.getTimestamp() +"");
16         System.out.println(new String(kv.getValue()));
17     }
18 }




3.7 查询表中所有行




1 /** 2  * 查询表中所有行
 3  * @param tablename
 4 */ 5 publicvoid scaner(String tablename) {
 6 try {
 7         HTable table =new HTable(conf, tablename);
 8         Scan s =new Scan();
 9         ResultScanner rs = table.getScanner(s);
10 for (Result r : rs) {
11             KeyValue[] kv = r.raw();
12 for (int i =0; i < kv.length; i++) {
13                 System.out.print(new String(kv[i].getRow()) +"");
14                 System.out.print(new String(kv[i].getFamily()) +":");
15                 System.out.print(new String(kv[i].getQualifier()) +"");
16                 System.out.print(kv[i].getTimestamp() +"");
17                 System.out.println(new String(kv[i].getValue()));
18             }
19         }
20     } catch (IOException e) {
21         e.printStackTrace();
22     }
23 }


标签:Java,String,tablename,System,kv,new,HBase,out,客户端
From: https://blog.51cto.com/u_2650279/6855119

相关文章

  • JavaScript学习 -- Base64编码
    Base64编码是一种常用的将二进制数据转换为文本数据的方式。在JavaScript中,我们可以通过使用Base64编码算法,将二进制数据转换为可读的文本数据,以便于在网络传输、文件传输等场景下使用。在本篇博客中,我们将介绍Base64编码的基本原理和相关技术,并提供一些实例来演示如何在JavaScript......
  • 看漫画学Java,这本书带你从青铜成为Java王者
    小白兔一直想学习Java,在它学习了一些Java知识后,想通过Java来完成实际操作,但是还不是很懂,于是它询问了这方面的大牛——大牛哥。小白兔:“我打算在某当网买几本畅销书,想找一些畅销书封面。可是花了很长时间,用Java有比较快的方法吗?”大牛哥:“可以用Java 通过‘网络爬虫’来爬......
  • java 文件名中文乱码解决
    java文件名中文乱码解决StringjsonFileName="";jsonFileName=newString(file.getName().getBytes(),"gb2312");System.out.println("1====="+jsonFileName);jsonFileName......
  • java zipfile解压文件乱码
    JDK提供了构造函数,我们指定zip文件的字符集。//根据ZIP文件创建ZipFile对象zipfile解压文件乱码,可指定编码ZipFilezipFile=newZipFile(zipFileName,"gb2312");//ZipFilezipFile=newZipFile(zipFileName,"GBK");//Z......
  • JAVA 序列化(创建可复用的 Java 对象)
    保存(持久化)对象及其状态到内存或者磁盘Java平台允许我们在内存中创建可复用的Java对象,但一般情况下,只有当JVM处于运行时,这些对象才可能存在,即,这些对象的生命周期不会比JVM的生命周期更长。但在现实应用中,就可能要求在JVM停止运行之后能够保存(持久化)指定的对象,并在将......
  • java笔记_11_JVM调优参数(转载)
    -Xms2048m//设置jvm的初始内存。这个值最好设置的跟-Xmx相同,以避免每次垃圾回收完成后JVM都要重新分配内存-Xmx2048m//JVM最大可用内存-XX:PermSize=256M//设置持久代大小-XX:MaxPermSize=512M//设置最大持久代大小-XX:+PrintGCDetails-XX:+PrintGCDat......
  • java后台接收ajax发送的参数
    1、前台发送数据到服务端,以及接受后台数据前台发送数据到服务端,有两种方法:(1)使用表单发送同步请求      参数inputStr:   参数intputInt:(2)使用ajax发送异步请求,发送的数据为json对象      参数username:      参数password:<scriptt......
  • Java的File类解析
    File类File类注:Windows的路径分隔符使用反斜线“\”,而Java程序中的反斜线表示转义字符,所以如果需要在Windows的路径下包括反斜线,则应该使用两条反斜线或直接使用斜线“/”也可以。Java程序支持将斜线当成平台无关的路径分隔符。1.描述java.io.File类∶代表文件和目录。在......
  • Java解决高并发秒杀商品
    在看本文章之前,需要了解Springboot搭建和使用,本篇文章核心问题是如何解决高并发问题。开发环境:redis缓存4.0.1,Rabbitmq消息队列,Erlang(这个跟MQ环境有关,先安装Erlang,再安装MQ),mysql5.7,JDK1.8(Springboot要用1.8以上的版本)开发框架:Springboot2.0.4,mybatis,前端页面:thym......
  • Java面试题 P5:简述final作用
    1、简述final作用?final含义是最终的。(1)修饰类:表示类不可被继承,不可以有子类;(2)修饰方法:表示方法不可以被子类覆盖,但是可以重载;(3)修饰变量:表示变量一旦被赋值就不可以更改它的值。(4)修饰成员变量如果final修饰的是类变量,只能在静态初始化块中指定初始值或者声明该类变量时指定初......