1.version
2.table_help
3.whoami

创建表

  1. import java.io.IOException;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.HColumnDescriptor;
  4. import org.apache.hadoop.hbase.HTableDescriptor;
  5. import org.apache.hadoop.hbase.client.HBaseAdmin;
  6. import org.apache.hadoop.hbase.TableName;
  8. import org.apache.hadoop.conf.Configuration;
  10. public class CreateTable {
  12.    public static void main(String[] args) throws IOException {
  14.    // Instantiating configuration class
  15.    Configuration con = HBaseConfiguration.create();
  17.    // Instantiating HbaseAdmin class
  18.    HBaseAdmin admin = new HBaseAdmin(con);
  20.    // Instantiating table descriptor class
  21.    HTableDescriptor tableDescriptor = new
  22.    TableDescriptor(TableName.valueOf("emp"));
  24.    // Adding column families to table descriptor
  25.    tableDescriptor.addFamily(new HColumnDescriptor("personal"));
  26.    tableDescriptor.addFamily(new HColumnDescriptor("professional"));
  29.    // Execute the table through admin
  30.    admin.createTable(tableDescriptor);
  31.    System.out.println(" Table created ");
  32.    }
  33. }

HBase列出表

list

  1. import java.io.IOException;
  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.HTableDescriptor;
  5. import org.apache.hadoop.hbase.MasterNotRunningException;
  6. import org.apache.hadoop.hbase.client.HBaseAdmin;
  9. public class ListTables {
  11.    public static void main(String args[])throws MasterNotRunningException, IOException{
  13.    // Instantiating a configuration class
  14.    Configuration conf = HBaseConfiguration.create();
  16.    // Instantiating HBaseAdmin class
  17.    HBaseAdmin admin = new HBaseAdmin(conf);
  19.    // Getting all the list of tables using HBaseAdmin object
  20.    HTableDescriptor[] tableDescriptor =admin.listTables();
  22.    // printing all the table names.
  23.    for (int i=0; i<tableDescriptor.length;i++ ){
  24.       System.out.println(tableDescriptor[i].getNameAsString());
  25.    }
  26.   }
  27. }

HBase禁用表

is_disabled
is_disabled ‘table name’
disable_all ‘r.*’

  1. import java.io.IOException;
  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.MasterNotRunningException;
  5. import org.apache.hadoop.hbase.client.HBaseAdmin;
  7. public class DisableTable{
  9.    public static void main(String args[]) throws MasterNotRunningException, IOException{
  10.    // Instantiating configuration class
  11.    Configuration conf = HBaseConfiguration.create();
  13.    // Instantiating HBaseAdmin class
  14.    HBaseAdmin admin = new HBaseAdmin(conf);
  16.    // Verifying weather the table is disabled
  17.    Boolean bool = admin.isTableDisabled("emp");
  18.    System.out.println(bool);
  20.    // Disabling the table using HBaseAdmin object
  21.    if(!bool){
  22.       admin.disableTable("emp");
  23.       System.out.println("Table disabled");
  24.    }
  25.   }
  26. }

HBase启用表

enable ‘emp’
scan ‘emp’

is_enabled ‘table name’
is_enabled ‘emp’

  1. import java.io.IOException;
  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.MasterNotRunningException;
  5. import org.apache.hadoop.hbase.client.HBaseAdmin;
  7. public class EnableTable{
  8.    public static void main(String args[]) throws MasterNotRunningException, IOException{
  9.    // Instantiating configuration class
  10.    Configuration conf = HBaseConfiguration.create();
  12.    // Instantiating HBaseAdmin class
  13.    HBaseAdmin admin = new HBaseAdmin(conf);
  15.    // Verifying weather the table is disabled
  16.    Boolean bool = admin.isTableEnabled("emp");
  17.    System.out.println(bool);
  19.    // Disabling the table using HBaseAdmin object
  20.    if(!bool){
  21.       admin.enableTable("emp");
  22.       System.out.println("Table Enabled");
  23.    }
  24.    }
  25. }

HBase表描述和修改
describe ‘emp’

更改列族单元格的最大数目
单元的最大数目设置为5
alter ‘emp’, NAME => ‘personal data’, VERSIONS => 5

设置只读
alter ‘emp’, READONLY

删除表范围运算符
alter ‘t1’, METHOD => ‘table_att_unset’, NAME => ‘MAX_FILESIZE’

删除列族
使用alter删除列族的语法
alter ‘ table name ’, ‘delete’ => ‘ column family ’

  1. alter 'employee','delete'=>'professional'

使用Java API添加一列族

  1. import java.io.IOException;
  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.HColumnDescriptor;
  5. import org.apache.hadoop.hbase.MasterNotRunningException;
  6. import org.apache.hadoop.hbase.client.HBaseAdmin;
  8. public class AddColoumn{
  10.    public static void main(String args[]) throws MasterNotRunningException, IOException{
  12.       // Instantiating configuration class.
  13.       Configuration conf = HBaseConfiguration.create();
  15.       // Instantiating HBaseAdmin class.
  16.       HBaseAdmin admin = new HBaseAdmin(conf);
  18.       // Instantiating columnDescriptor class
  19.       HColumnDescriptor columnDescriptor = new HColumnDescriptor("contactDetails");
  21.       // Adding column family
  22.       admin.addColumn("employee", columnDescriptor);
  23.       System.out.println("coloumn added");
  24.    }
  25. }

使用Java API删除列族

  1. import java.io.IOException;
  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.MasterNotRunningException;
  5. import org.apache.hadoop.hbase.client.HBaseAdmin;
  7. public class DeleteColoumn{
  9.    public static void main(String args[]) throws MasterNotRunningException, IOException{
  11.       // Instantiating configuration class.
  12.       Configuration conf = HBaseConfiguration.create();
  14.       // Instantiating HBaseAdmin class.
  15.       HBaseAdmin admin = new HBaseAdmin(conf);
  17.       // Deleting a column family
  18.       admin.deleteColumn("employee","contactDetails");
  19.       System.out.println("coloumn deleted"); 
  20.    }
  21. }

HBase Exists

exists ‘student’

  1. import java.io.IOException;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.conf.Configuration;
  4. import org.apache.hadoop.hbase.client.HBaseAdmin;
  6. public class TableExists{
  8.    public static void main(String args[])throws IOException{
  10.    // Instantiating configuration class
  11.    Configuration conf = HBaseConfiguration.create();
  13.    // Instantiating HBaseAdmin class
  14.    HBaseAdmin admin = new HBaseAdmin(conf);
  16.    // Verifying the existance of the table
  17.    boolean bool = admin.tableExists("emp");
  18.    System.out.println( bool);
  19.    }
  20. }

HBase关闭

  1. import java.io.IOException;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.conf.Configuration;
  4. import org.apache.hadoop.hbase.client.HBaseAdmin;
  5. public class ShutDownHbase{
  7.    public static void main(String args[])throws IOException {
  9.       // Instantiating configuration class
  10.       Configuration conf = HBaseConfiguration.create();
  12.       // Instantiating HBaseAdmin class
  13.       HBaseAdmin admin = new HBaseAdmin(conf);
  15.       // Shutting down HBase
  16.       System.out.println("Shutting down hbase");
  17.       admin.shutdown();
  18.    }
  19. }

put

  1. package com.hfqx.decodelpd.dao;
  3. import com.hfqx.decodelpd.utils.HBaseUtil;
  4. import com.stumbleupon.async.Deferred;
  5. import org.apache.hadoop.conf.Configuration;
  6. import org.apache.hadoop.hbase.HBaseConfiguration;
  7. import org.apache.hadoop.hbase.HColumnDescriptor;
  8. import org.apache.hadoop.hbase.HTableDescriptor;
  9. import org.apache.hadoop.hbase.TableName;
  10. import org.apache.hadoop.hbase.client.HBaseAdmin;
  11. import org.hbase.async.HBaseClient;
  12. import org.hbase.async.PutRequest;
  14. import java.io.IOException;
  15. import java.util.List;
  17. /**
  18.  * description
  19.  *
  20.  * @author ${user}
  21.  * @Time 2019-06-21
  22.  */
  23. public class HbaseDao {
  25.     private static String hbaseip = null;
  26.     private static String zkhost = null;
  27.     private static String zkport = null;
  29.     private static HBaseClient hBaseClient = null;
  31.     private static Configuration config = null;
  33.     static {
  35.         hbaseip = HBaseUtil.getHbaseMaster();
  36.         zkhost = HBaseUtil.getZkhost();
  37.         zkport = HBaseUtil.getZkport();
  39.         config = HBaseConfiguration.create();// 配置
  40.         config.set("hbase.zookeeper.quorum", zkhost); // zookeeper地址
  41.         config.set("hbase.zookeeper.property.clientPort", zkport);// zookeeper端口
  43.         hBaseClient = new HBaseClient(hbaseip);
  44.     }
  47.     /**
  48.      * check table that is exists or not
  49.      * @param tablename
  50.      * @return
  51.      */
  52.     public boolean checkTable(String tablename) {
  53.         HBaseAdmin admin = null; // hbase表管理
  55.         try {
  56.             admin = new HBaseAdmin(config);
  57.             String[]tablenames = admin.getTableNames();
  59.             for( String table1:tablenames){
  60.                 if ( table1.equals(tablename)){
  61.                     System.out.println("表已经存在");
  62.                     return true;
  63.                 }
  64.             }
  65.         } catch (IOException e) {
  66.             e.printStackTrace();
  67.         }
  68.         try {
  69.             admin.close();
  70.         } catch (IOException e) {
  71.             e.printStackTrace();
  72.         }
  73.         return false;
  74.     }
  76.     public boolean checkTable(HBaseAdmin admin, String tablename) {
  77.         try {
  78.             String[]tablenames = admin.getTableNames();
  79.             for( String table1:tablenames){
  80.                 if ( table1.equals(tablename)){
  81.                     System.out.println("表已经存在");
  82.                     return true;
  83.                 }
  84.             }
  85.         } catch (IOException e) {
  86.             e.printStackTrace();
  87.         }
  89.         return false;
  90.     }
  92.     /**
  93.      * create table that is exists or not
  94.      * @param tablename
  95.      * @param columnfamily
  96.      * @return
  97.      */
  98.     public boolean createTable(String tablename, String columnfamily) {
  100.         HBaseAdmin admin = null; // hbase表管理
  102.         try {
  103.             admin = new HBaseAdmin(config);
  104.         } catch (IOException e) {
  105.             e.printStackTrace();
  106.         }
  110.         if ( checkTable(admin, tablename) ) {
  111.             return true;
  112.         }
  114.         // 创建表描述类
  115.         TableName tableName = TableName.valueOf(tablename); // 表名称
  116.         HTableDescriptor desc = new HTableDescriptor(tableName);
  118.         HColumnDescriptor[] hColumnDescriptors = desc.getColumnFamilies();
  119.         System.out.println(hColumnDescriptors.toString());
  120.         // 创建列族的描述类
  121.         HColumnDescriptor family = new HColumnDescriptor(columnfamily); // 列族
  122.         // 将列族添加到表中
  123.         desc.addFamily(family);
  126.         // 创建表
  127.         try {
  128.             admin.createTable(desc); // 创建表
  129.             admin.close();
  130.         } catch (IOException e) {
  131.             e.printStackTrace();
  132.         }
  133.         System.out.println("创建表成功！");
  134.         return true;
  135.     }
  139.     public Deferred<Object> Put(PutRequest putRequest) {
  140.         return hBaseClient.put(putRequest);
  141.     }
  144.     public void Put(List<PutRequest> putRequestList) {
  145.         for(PutRequest putRequest: putRequestList) {
  147.             try {
  148.                 Put(putRequest).join();
  149.             } catch (Exception e) {
  150.                 e.printStackTrace();
  151.             }
  152.         }
  153.     }
  156.     public static void main(String[] args) {
  157.         HbaseDao hbaseDao = new HbaseDao();
  158.         hbaseDao.createTable("QX_LPD","f");
  159.     }
  161. }