hbase中创建表、插入数据，更新数据，删除数据

川长思鸟来 2022-06-12 10:36 209阅读 0赞

所需要的包有：

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][Java].util.ArrayList;  
import java.util.List;  
import org.apache.[hadoop][Hadoop].conf.Configuration;  
import org.apache.hadoop.[hbase][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<Put> putuser = new ArrayList<Put>();  
       
         
       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<Delete> deld = new ArrayList<Delete>();  
      deld.add(new Delete(new String("用户C").getBytes()));  
      table.delete(deld);  
       
      table.flushCommits();  
      //HBaseBasic.selectByRowKey("riapguh");  
    \}  
   
\}

[Hadoop]: http://lib.csdn.net/base/hadoop
[Hbase]: http://lib.csdn.net/base/hbase
[Java]: http://lib.csdn.net/base/java