锐客网

  1. 首页 > 生活百科 > it技术 > >

hbasejava代码 hbase_classpath

IT技术hbase

如何在java中实现hbase接口使用maven idea进行管理
maven
dependency groupIdlog4j/groupId artifactIdlog4j/artifactId version1.2.17/version /dependency
dependency groupIdorg.apache.hbase/groupId artifactIdhbase-shaded-client/artifactId version1.2.3/version /dependency
hbase javahbase java是什么，让我们一起了解一下？
HBase是一个分布式的、面向列的开源数据库，具有高可靠性、高性能、面向列、可伸缩的分布式存储系统，利用HBase技术可在廉价PC Server上搭建起大规模结构化存储集群 。
如何使用JAVA语言操作Hbase、整合Hbase？
可分为五步骤：
步骤1：新创建一个Java Project。
步骤2：导入JAR包，在工程根目录下新建一个“lib”文件夹，将官方文档中的lib目录下的jar全部导入 。
步骤3：修改开发机的hosts文件，在文件莫为增加一行虚拟机IP的映射信息 。
步骤4：修改虚拟机的配置文件 ， 修改虚拟机的设备名称，名称需要与之前两个配置文件的映射名称一致 。
步骤5：实现查询、新建、删除等 。
案例代码展示如下：
package hbase;import java.io.IOException;import java.util.ArrayList;import java.util.List;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.Cell;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;import org.apache.hadoop.hbase.TableName;import org.apache.hadoop.hbase.client.Admin;import org.apache.hadoop.hbase.client.Connection;import org.apache.hadoop.hbase.client.ConnectionFactory;import org.apache.hadoop.hbase.client.Delete;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.Put;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.apache.hadoop.hbase.client.Table;import org.apache.hadoop.hbase.exceptions.DeserializationException;import org.apache.hadoop.hbase.filter.Filter;import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;import org.apache.hadoop.hbase.util.Bytes;import org.junit.Before;import org.junit.Test;public class HBaseDemo {// 与HBase数据库的连接对象Connection connection;// 数据库元数据操作对象Admin admin;@Beforepublic void setUp() throws Exception {// 取得一个数据库连接的配置参数对象Configuration conf = HBaseConfiguration.create();// 设置连接参数：HBase数据库所在的主机IPconf.set("hbase.zookeeper.quorum", "192.168.137.13");// 设置连接参数：HBase数据库使用的端口conf.set("hbase.zookeeper.property.clientPort", "2181");// 取得一个数据库连接对象connection = ConnectionFactory.createConnection(conf);// 取得一个数据库元数据操作对象admin = connection.getAdmin();}/*** 创建表*/public void createTable() throws IOException{System.out.println("---------------创建表 START-----------------");// 数据表表名String tableNameString = "t_book";// 新建一个数据表表名对象TableName tableName = TableName.valueOf(tableNameString);// 如果需要新建的表已经存在if(admin.tableExists(tableName)){System.out.println("表已经存在！");}// 如果需要新建的表不存在else{// 数据表描述对象HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);// 列族描述对象HColumnDescriptor family= new HColumnDescriptor("base");;// 在数据表中新建一个列族hTableDescriptor.addFamily(family);// 新建数据表admin.createTable(hTableDescriptor);}System.out.println("---------------创建表 END-----------------");}/*** 查询整表数据*/@Testpublic void queryTable() throws IOException{System.out.println("---------------查询整表数据 START-----------------");// 取得数据表对象Table table = connection.getTable(TableName.valueOf("t_book"));// 取得表中所有数据ResultScanner scanner = table.getScanner(new Scan());// 循环输出表中的数据for (Result result : scanner) {byte[] row = result.getRow();System.out.println("row key is:"new String(row));ListlistCells = result.listCells();for (Cell cell : listCells) {byte[] familyArray = cell.getFamilyArray();byte[] qualifierArray = cell.getQualifierArray();byte[] valueArray = cell.getValueArray();System.out.println("row value is:"new String(familyArray)new String(qualifierArray)new String(valueArray));}}System.out.println("---------------查询整表数据 END-----------------");}/*** 按行键查询表数据*/@Testpublic void queryTableByRowKey() throws IOException{System.out.println("---------------按行键查询表数据 START-----------------");// 取得数据表对象Table table = connection.getTable(TableName.valueOf("t_book"));// 新建一个查询对象作为查询条件Get get = new Get("row8".getBytes());// 按行键查询数据Result result = table.get(get);byte[] row = result.getRow();System.out.println("row key is:"new String(row));ListlistCells = result.listCells();for (Cell cell : listCells) {byte[] familyArray = cell.getFamilyArray();byte[] qualifierArray = cell.getQualifierArray();byte[] valueArray = cell.getValueArray();System.out.println("row value is:"new String(familyArray)new String(qualifierArray)new String(valueArray));}System.out.println("---------------按行键查询表数据 END-----------------");}/*** 按条件查询表数据*/@Testpublic void queryTableByCondition() throws IOException{System.out.println("---------------按条件查询表数据 START-----------------");// 取得数据表对象Table table = connection.getTable(TableName.valueOf("t_book"));// 创建一个查询过滤器Filter filter = new SingleColumnValueFilter(Bytes.toBytes("base"), Bytes.toBytes("name"),CompareOp.EQUAL, Bytes.toBytes("bookName6"));// 创建一个数据表扫描器Scan scan = new Scan();// 将查询过滤器加入到数据表扫描器对象scan.setFilter(filter);// 执行查询操作，并取得查询结果ResultScanner scanner = table.getScanner(scan);// 循环输出查询结果for (Result result : scanner) {byte[] row = result.getRow();System.out.println("row key is:"new String(row));ListlistCells = result.listCells();for (Cell cell : listCells) {byte[] familyArray = cell.getFamilyArray();byte[] qualifierArray = cell.getQualifierArray();byte[] valueArray = cell.getValueArray();System.out.println("row value is:"new String(familyArray)new String(qualifierArray)new String(valueArray));}}System.out.println("---------------按条件查询表数据 END-----------------");}/*** 清空表*/@Testpublic void truncateTable() throws IOException{System.out.println("---------------清空表 START-----------------");// 取得目标数据表的表名对象TableName tableName = TableName.valueOf("t_book");// 设置表状态为无效admin.disableTable(tableName);// 清空指定表的数据admin.truncateTable(tableName, true);System.out.println("---------------清空表 End-----------------");}/*** 删除表*/@Testpublic void deleteTable() throws IOException{System.out.println("---------------删除表 START-----------------");// 设置表状态为无效admin.disableTable(TableName.valueOf("t_book"));// 删除指定的数据表admin.deleteTable(TableName.valueOf("t_book"));System.out.println("---------------删除表 End-----------------");}/*** 删除行*/@Testpublic void deleteByRowKey() throws IOException{System.out.println("---------------删除行 START-----------------");// 取得待操作的数据表对象Table table = connection.getTable(TableName.valueOf("t_book"));// 创建删除条件对象Delete delete = new Delete(Bytes.toBytes("row2"));// 执行删除操作table.delete(delete);System.out.println("---------------删除行 End-----------------");}/*** 删除行（按条件）*/@Testpublic void deleteByCondition() throws IOException, DeserializationException{System.out.println("---------------删除行（按条件） START-----------------");// 步骤1：调用queryTableByCondition()方法取得需要删除的数据列表// 步骤2：循环步骤1的查询结果，对每个结果调用deleteByRowKey()方法System.out.println("---------------删除行（按条件） End-----------------");}/*** 新建列族*/@Testpublic void addColumnFamily() throws IOException{System.out.println("---------------新建列族 START-----------------");// 取得目标数据表的表名对象TableName tableName = TableName.valueOf("t_book");// 创建列族对象HColumnDescriptor columnDescriptor = new HColumnDescriptor("more");// 将新创建的列族添加到指定的数据表admin.addColumn(tableName, columnDescriptor);System.out.println("---------------新建列族 END-----------------");}/*** 删除列族*/@Testpublic void deleteColumnFamily() throws IOException{System.out.println("---------------删除列族 START-----------------");// 取得目标数据表的表名对象TableName tableName = TableName.valueOf("t_book");// 删除指定数据表中的指定列族admin.deleteColumn(tableName, "more".getBytes());System.out.println("---------------删除列族 END-----------------");}/*** 插入数据*/@Testpublic void insert() throws IOException{System.out.println("---------------插入数据 START-----------------");// 取得一个数据表对象Table table = connection.getTable(TableName.valueOf("t_book"));// 需要插入数据库的数据集合ListputList = new ArrayList ();Put put;// 生成数据集合for(int i = 0; i
如何使用Java API操作Hbase一般情况下，我们使用Linux的shell命令，就可以非常轻松的操作Hbase ， 例如一些建表，建列簇，插值，显示所有表，统计数量等等，但有时为了提高灵活性，我们也需要使用编程语言来操作Hbase，当然Hbase通过Thrift接口提供了对大多数主流编程语言的支持，例如C,PHP ， Python，Ruby等等，那么本篇，散仙给出的例子是基于Java原生的API操作Hbase ， 相比其他的一些编程语言，使用Java操作Hbase，会更加高效一些，因为Hbase本身就是使用Java语言编写的 。转载
下面 ， 散仙给出源码，以供参考:
package com.hbase;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
【hbasejava代码 hbase_classpath】import org.apache.hadoop.hbase.client.HTable;
hbasejava代码的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于hbase_classpath、hbasejava代码的信息别忘了在本站进行查找喔 。

    推荐阅读


    上一篇：linux中z的命令，linux cz命令

    下一篇：voxakuma直播回放b站，wb直播回放