JAVA API操作JAVA

1.Configuration在使用Java API时,Client端需要知道HBase的配置环境,如存储地址,zookeeper等信息。这些信息通过Configuration对象来封装,可通过如下代码构建该对象
       Configuration config=HBaseConfiguration.create();
在调用HBaseConfiguration.create()方法时,HBase首先会在classpath下查找hbase-site.xml文件,将里面的信息解析出来封装到Configuration对象中,如果hbase-site.xml文件不存在,则使用默认的hbase-core.xml文件。
除了将hbase-site.xml放到classpath下,开发人员还可通过config.set(name, value)方法来手工构建Configuration对象。
Configuration.set(String name, String value) 2.HBaseAdminHBaseAdmin用于创建数据库表格,并管理表格的元数据信息,通过如下方法构建
       HBaseAdmin admin=new HBaseAdmin(config);
常用方法:

       addColumn(tableName,column):为表格添加栏位
       deleteColumn(tableName,column):删除指定栏位
        balanceSwitch(boolean):是否启用负载均衡
        createTable(HTableDescriptor desc):创建表格
        deleteTable(tableName):删除表格
        tableExists(tableName):判断表格是否存在 
[java] 
 
  • HBaseAdmin admin=new HBaseAdmin(config);  
  • If(!admin.tableExists(“test”)){  
  •     HTableDescriptor tableDesc=new HTableDescriptor(“test”);  
  •     HColumnDescriptor cf=new HColumnDescriptor(“cf”);  
  •     tableDesc.addFamily(cf);  
  •     admin.createTable(tableDesc);  
  • }  


HBaseAdmin admin=new HBaseAdmin(config);If(!admin.tableExists(“test”)){        HTableDescriptor tableDesc=new HTableDescriptor(“test”);        HColumnDescriptor cf=new HColumnDescriptor(“cf”);        tableDesc.addFamily(cf);        admin.createTable(tableDesc);}
3.HTable在HBase中,HTable封装表格对象,对表格的增删改查操作主要通过它来完成,构造方法如下:
       HTable table=new HTable(config,tableName);
在构建多个HTable对象时,HBase推荐所有的HTable使用同一个Configuration。这样,HTable之间便可共享HConnection对象、zookeeper信息以及Region地址的缓存信息。
示例1:Get操作
[java] 
  • Get get=new Get(rowKey);  
  • Result res=table.get(get);  


Get get=new Get(rowKey);Result res=table.get(get);示例2:Put操作[java] 
  • Put put=new Put(rowKey);  
  • put.add(columnFamily,column,value);  
  • table.put(put);  


Put put=new Put(rowKey);put.add(columnFamily,column,value);table.put(put);注:在HBase中,实体的新增和更新都是通过Put操作来实现示例3:Delete操作
[java] 
  • Delete delete=new Delete();  
  • table.delete(delete);  


Delete delete=new Delete();table.delete(delete);示例4:Scan操作[java]
  • Scan scan=new Scan( );  
  • scan.addColumn(columnFamily,column);//指定查询要返回的column  
  • SingleColumnValueFilter filter=new SingleColumnValueFilter(  
  •         columnFamily,column,//指定要过滤的column  
  •         CompareOp.EQUAL,value//指定过滤条件  
  • );  
  • //更多的过滤器信息请查看org.apache.hadoop.hbase.filter包  
  • scan.setFilter(filter);//为查询指定过滤器  
  • ResultScanner scanner=table.getScanner(scan);//执行扫描查找  
  • Iterator<Result> res=scanner.iterator( );//返回查询遍历器  

0 个评论

要回复文章请先登录注册