• 大小: 66.55MB
    文件类型: .zip
    金币: 2
    下载: 1 次
    发布日期: 2023-05-27
  • 语言: Java
  • 标签: hbase  大数据  CRUD  hbase  

资源简介

本代码是java链接并对hbase进行增删改查操作的实例代码,并包括批量插入,范围查询等,并包含所需jar包.

资源截图

代码片段和文件信息

/**
 * 
 */
package whg.hbase;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HbaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.NamespaceDescriptor;
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.Table;
import org.apache.hadoop.hbase.util.Bytes;

/**
 * 
 * 

类描述:hbase 增删改查操作  


 * 

创建人:wanghonggang  


 * 

创建时间:2018年11月27日 下午3:18:10  


 */
public class HbaseCRUD {

//hbase 链接
static Connection conn;

// 数据库元数据操作对象
    static Admin admin;

/**
 * @param args
 */
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
System.out.println(“---------------  开始!    -----------------“);
setup();//初始化
createTable();//创建表
insert();//插入数据
update();//更新数据
delete();//删除数据
select();//查询数据
deleteTable();//删除表
closeConnection();//关闭连接
System.out.println(“---------------  结束!    -----------------“);
} catch (Exception e) {
e.printStackTrace();
}
}

/**
 * 初始化
 * @throws Exception
 */
public static void setup() throws Exception{
System.out.println(“---------------  开始初始化  -----------------“);

//取得一个数据库连接的配置参数对象
Configuration conf = HbaseConfiguration.create();
//设置连接参数:Hbase数据库所在的主机IP
conf.set(“hbase.zookeeper.quorum“ “datanode1datanode2datanode3“);
//设置连接参数:Hbase数据库使用的端口
conf.set(“hbase.zookeeper.property.clientPort“ “2181“);
// conf.set(“hbase.master“ “manager:16000“);
conf.set(“hbase.master.port“ “16000“);
conf.set(“hbase.zookeeper.useMulti“ “true“);
conf.set(“hbase.regionserver.info.port“ “16030“);
conf.set(“hbase.regionserver.port“ “16020“);
conf.set(“zookeeper.znode.parent“ “/hbase-unsecure“);

//取得一个数据库连接对象
conn=ConnectionFactory.createConnection(conf);
//取得一个数据库元数据操作对象
admin=conn.getAdmin();

System.out.println(“---------------  初始化完成   -----------------“);
}

/**
 * 创建表
 * @throws Exception
 */
public static void createTable()throws Exception{
System.out.println(“---------------创建表 START-----------------“);

//创建namespace 
admin.createNamespace(NamespaceDescriptor.create(“WHG“).build());

// 数据表表名
String tableName=“WHG:TB1“;

// 新建一个数据表表名对象
TableName tn = TableName.valueOf(tableName);

//判断表是否存在
if(admin.tableExists(tn)){
System.out.println(tableName+“表已经存在!“);
}else{
System.out.println(tableName+“表不存在,开始

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        8230  2018-11-27 16:05  .classpath
     文件         385  2018-11-27 16:04  .project
     目录           0  2018-11-27 16:04  .settings\
     文件         598  2018-11-27 16:04  .settings\org.eclipse.jdt.core.prefs
     目录           0  2018-11-27 16:05  bin\
     目录           0  2018-11-27 16:05  bin\whg\
     目录           0  2018-11-27 16:05  bin\whg\hbase\
     文件        7757  2018-11-27 16:05  bin\whg\hbase\HbaseCRUD.class
     目录           0  2018-11-27 16:05  lib\
     文件       62983  2018-03-09 15:28  lib\activation-1.1.jar
     文件       71717  2018-03-09 15:28  lib\antisamy-1.4.3.jar
     文件        4467  2018-03-09 15:28  lib\aopalliance-1.0.jar
     文件       44925  2018-03-09 15:28  lib\apacheds-i18n-2.0.0-M15.jar
     文件      691479  2018-03-09 15:28  lib\apacheds-kerberos-codec-2.0.0-M15.jar
     文件       16560  2018-03-09 15:28  lib\api-asn1-api-1.0.0-M20.jar
     文件       79912  2018-03-09 15:28  lib\api-util-1.0.0-M20.jar
     文件       43033  2018-03-09 15:28  lib\asm-3.1.jar
     文件      303139  2018-03-09 15:28  lib\avro-1.7.4.jar
     文件      317060  2018-03-09 15:28  lib\batik-css-1.7.jar
     文件       10267  2018-03-09 15:28  lib\batik-ext-1.7.jar
     文件      130304  2018-03-09 15:28  lib\batik-util-1.7.jar
     文件      143992  2018-03-09 15:28  lib\bsh-core-2.0b4.jar
     文件      188671  2018-03-09 15:28  lib\commons-beanutils-1.7.0.jar
     文件      168760  2018-03-09 15:28  lib\commons-beanutils-core-1.7.0.jar
     文件       41123  2018-03-09 15:28  lib\commons-cli-1.2.jar
     文件      263965  2018-03-09 15:28  lib\commons-codec-1.9.jar
     文件      588337  2018-03-09 15:28  lib\commons-collections-3.2.2.jar
     文件      241367  2018-03-09 15:28  lib\commons-compress-1.4.1.jar
     文件      298829  2018-03-09 15:28  lib\commons-configuration-1.6.jar
     文件       24239  2018-03-09 15:28  lib\commons-daemon-1.0.13.jar
     文件      143602  2018-03-09 15:28  lib\commons-digester-1.8.jar
............此处省略103个文件信息

评论

共有 条评论