1.首先导入HBase Java API所需的所有jar包

导入以下两个目录中的所有 jar 包
/usr/local/hbase/lib/.jar
/usr/local/hbase/lib/client-facing-thirdparty/.jar
注意！！此处不再需要导入Hadoop安装目录下的JAR包，这样可以避免由于Hadoop和HBase的版本冲突而引起的错误。否则运行HBase程序时将会报很多不兼容的错误。

2.测试代码运行

在运行代码前必须先启动 hadoop 和 hbase

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.*;
  3. import org.apache.hadoop.hbase.client.*;
  4. import org.apache.hadoop.hbase.util.Bytes;
  6. import java.io.IOException;
  8. import com.thoughtworks.paranamer.JavadocParanamer;
  9. public class ExampleForHBase {
  10.     public static Configuration configuration; //管理 HBase 的配置信息
  11.     public static Connection connection; //管理 HBase连接
  12.     public static Admin admin; //管理 HBase数据库的表信息
  13.     public static void main(String[] args)throws IOException{
  14.         init(); //建立连接
  15.         createTable("student",new String[]{"score"}); //建表
  16.         insertData("student","zhangsan","score","English","69"); //插入单元格数据
  17.         insertData("student","zhangsan","score","Math","86"); //同上
  18.         insertData("student","zhangsan","score","Computer","77"); //同上
  19.         getData("student", "zhangsan", "score","English"); //浏览单元格数据
  20.         close(); //关闭连接
  21.     }
  22.     //建立连接
  23.     public static void init(){
  24.         configuration  = HBaseConfiguration.create();
  25.         configuration.set("hbase.rootdir","hdfs://localhost:9000/hbase"); //指定HBase数据存储的根目录，这里底层使用hdfs作为存储
  26.         try{
  27.             connection = ConnectionFactory.createConnection(configuration);
  28.             admin = connection.getAdmin();
  29.         }catch (IOException e){
  30.             e.printStackTrace();
  31.         }
  32.     }
  34.     public static void close(){
  35.         try{
  36.             if(admin != null){
  37.                 admin.close();
  38.             }
  39.             if(null != connection){
  40.                 connection.close();
  41.             }
  42.         }catch (IOException e){
  43.             e.printStackTrace();
  44.         }
  45.     }
  46.     /**
  47.      * 创建表
  48.      * @param myTableName 表名
  49.      * @param colFamily 列族数组
  50.      * @throws IOException
  51.      */
  52.     public static void createTable(String myTableName,String[] colFamily) throws IOException {
  53.         TableName tableName = TableName.valueOf(myTableName);
  54.         if(admin.tableExists(tableName)){
  55.             System.out.println("talbe is exists!");
  56.         }else {
  57.             TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);
  58.             for(String str:colFamily){
  59.                 ColumnFamilyDescriptor family = 
  60.                     ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build();
  61.                 tableDescriptor.setColumnFamily(family);
  62.             }
  63.             admin.createTable(tableDescriptor.build());
  64.         } 
  65.     }
  66.     /**
  67.      * 添加数据
  68.      * @param tableName 表名
  69.      * @param rowKey 行键
  70.      * @param colFamily 列族
  71.      * @param col 列限定符（列族中的指定列名）
  72.      * @param val 数据
  73.      * @throws IOException
  74.      */
  75.     public static void insertData(String tableName,String rowKey,String colFamily,String col,String val) throws IOException { 
  76.         Table table = connection.getTable(TableName.valueOf(tableName));
  77.         Put put = new Put(rowKey.getBytes());
  78.         put.addColumn(colFamily.getBytes(),col.getBytes(), val.getBytes());
  79.         table.put(put);
  80.         table.close(); 
  81.     }
  82.     /**
  83.      * 获取某单元格数据
  84.      * @param tableName 表名
  85.      * @param rowKey 行键
  86.      * @param colFamily 列族
  87.      * @param col 列限定符
  88.      * @throws IOException
  89.      */
  90.     public static void getData(String tableName,String rowKey,String colFamily, String col)throws  IOException{ 
  91.         Table table = connection.getTable(TableName.valueOf(tableName));
  92.         Get get = new Get(rowKey.getBytes());
  93.         get.addColumn(colFamily.getBytes(),col.getBytes());
  94.         Result result = table.get(get);
  95.         System.out.println(new String(result.getValue(colFamily.getBytes(),col==null?null:col.getBytes())));
  96.         table.close(); 
  97.     }
  98. }

成功运行后，会在输出中看到 69 的字样
image.png
使用scan命令，查看新建的student表中的数据
image.png