13518219792
本篇内容介绍了“hbase中创建表、插入数据，更新数据，删除数据的操作”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
从网站建设到定制行业解决方案，为提供网站建设、成都网站设计服务体系，各种行业企业客户提供网站建设解决方案，助力业务快速发展。创新互联将不断加快创新步伐，提供优质的建站服务。
所需要的包有：
commons-codec-1.4.jar
commons-logging-1.1.1.jar
hadoop-0.20.2-core.jar
hbase-0.90.2.jar
log4j-1.2.16.jar
zookeeper-3.3.2.jar
背景：
假设有一个不知道是干什么表：）
表里需要存入人员和其相对应的部门信息
代码：
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.client.Delete;import org.apache.hadoop.hbase.client.HBaseAdmin;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.Put; public class HbaseAddEdtDel { public static Configuration configuration=null; static { configuration = HBaseConfiguration.create(); configuration.set("hbase.master", "192.168.0.201:60000"); configuration.set("hbase.zookeeper.quorum","192.168.0.201,192.168.0.202,192.168.0.203"); configuration.set("hbase.zookeeper.property.clientPort", "2181"); } public static void main(String[] args) throws Exception { HBaseAdmin admin = new HBaseAdmin(configuration); if (admin.tableExists("riapguh")) { System.out.println("删除 table"); admin.disableTable("riapguh"); admin.deleteTable("riapguh"); } //创建riapguh表 System.out.println("创建 table"); HTableDescriptor tableDescripter = new HTableDescriptor("riapguh".getBytes());//创建表 tableDescripter.addFamily(new HColumnDescriptor("user"));//创建列簇user tableDescripter.addFamily(new HColumnDescriptor("dpt"));//创建列簇dpt admin.createTable(tableDescripter); HTable table = new HTable(configuration, "riapguh"); //插入数据 System.out.println("add riapguh data"); List putuser = new ArrayList(); Put user1 = new Put(new String("用户A").getBytes()); //写入用户员信息 user1.add(new String("user").getBytes(), new String("user_code").getBytes(), new String("u_0001").getBytes()); user1.add(new String("user").getBytes(), new String("user_name").getBytes(), new String("u_用户A").getBytes()); //写入部门信息 user1.add(new String("dpt").getBytes(), new String("dpt_code").getBytes(), new String("d_001").getBytes()); user1.add(new String("dpt").getBytes(), new String("dpt_name").getBytes(), new String("d_部门A").getBytes()); putuser.add(user1); Put user2 = new Put(new String("用户B").getBytes()); //写入用户员信息 user2.add(new String("user").getBytes(), new String("user_code").getBytes(), new String("u_0002").getBytes()); user2.add(new String("user").getBytes(), new String("user_name").getBytes(), new String("u_用户B").getBytes()); //写入部门信息 user2.add(new String("dpt").getBytes(), new String("dpt_code").getBytes(), new String("d_002").getBytes()); user2.add(new String("dpt").getBytes(), new String("dpt_name").getBytes(), new String("d_部门B").getBytes()); putuser.add(user2); Put user3 = new Put(new String("用户C").getBytes()); //写入用户员信息 user3.add(new String("user").getBytes(), new String("user_code").getBytes(), new String("u_0003").getBytes()); user3.add(new String("user").getBytes(), new String("user_name").getBytes(), new String("u_用户C").getBytes()); //写入部门信息 user3.add(new String("dpt").getBytes(), new String("dpt_code").getBytes(), new String("d_003").getBytes()); user3.add(new String("dpt").getBytes(), new String("dpt_name").getBytes(), new String("d_部门C").getBytes()); putuser.add(user3); table.put(putuser); table.flushCommits(); //更新用户B Put updateb = new Put(new String("用户B").getBytes()); //写入用户员信息 updateb.add(new String("user").getBytes(), new String("user_code").getBytes(), new String("u_000xsx").getBytes()); updateb.add(new String("user").getBytes(), new String("user_name").getBytes(), new String("u_用户xsx").getBytes()); //写入部门信息 updateb.add(new String("dpt").getBytes(), new String("dpt_code").getBytes(), new String("d_00xsx").getBytes()); updateb.add(new String("dpt").getBytes(), new String("dpt_name").getBytes(), new String("d_部门xsx").getBytes()); table.put(updateb); table.flushCommits(); //HBaseBasic.selectByRowKey("riapguh"); System.out.println("-------------删除用户C---------------------"); //删除用户C //able.delete(new Delete(new String("用户C").getBytes())); List deld = new ArrayList(); deld.add(new Delete(new String("用户C").getBytes())); table.delete(deld); table.flushCommits(); //HBaseBasic.selectByRowKey("riapguh"); } } “hbase中创建表、插入数据，更新数据，删除数据的操作”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站，小编将为大家输出更多高质量的实用文章！
