NoSQL Hbase JAVA API

实例一

导入架包：

<dependency><groupId>org.apache.hbase</groupId><artifactId>hbase-client</artifactId><version>1.3.5</version>
</dependency>

首先在java中新建一个HbaseService类

步骤一：添加配置

public static Connection getConnection() throws IOException {Configuration configuration = HBaseConfiguration.create();Connection connection= ConnectionFactory.createConnection(configuration);return connection;
}

步骤二：快速执行方法

public static void main(String[] args) throws IOException{//创建一张表createTable();//向表中插入数据insertTable();//查询表中对应的数据searchTable();//查询所有searchAll();
}

步骤三：查询所有

private static void searchAll() throws IOException{//scan 'emps',FILTER=>ValueFilter(=,'substring:c')Table emps = getConnection().getTable(TableName.valueOf("emps"));Scan scan=new Scan();FilterList lst = new FilterList();ValueFilter vf = new ValueFilter(CompareFilter.CompareOp.EQUAL,new SubstringComparator("c"));lst.addFilter(vf);scan.setFilter(lst);ResultScanner scanner = emps.getScanner(new Scan());//ResultSet=>ResultIterator<Result> rs = scanner.iterator();while (rs.hasNext()){Result row = rs.next();//可以取出多个数值System.out.println(row.getValue("base".getBytes(),"name".getBytes()));}
}

步骤四:查询表中对应的数据

private static void searchTable() throws IOException{//get 'emps','001','base:name'Table emps = getConnection().getTable(TableName.valueOf("emps"));Get get = new Get("001".getBytes());Result result = emps.get(get);result.getValue("base".getBytes(),"name".getBytes());String str =Bytes.toString(result.getValue("base".getBytes(),"name".getBytes()));System.out.println(str);
}

步骤五：向表中插入数据

private static void insertTable() throws IOException{//put 'emps','001','base:name','value'Table emps=getConnection().getTable(TableName.valueOf("emps"));//添加001Put put = new Put("001".getBytes());put.addColumn("base".getBytes(),"name".getBytes(),"cm".getBytes());emps.put(put);
}

步骤六：创建一张表格

private static void createTable() throws IOException{Admin admin=getConnection().getAdmin();//给个表名HTableDescriptor table=new HTableDescriptor(TableName.valueOf("emps"));//创建一个列族HColumnDescriptor base=new HColumnDescriptor("base");//表上加列族table.addFamily(base);admin.createTable(table);
}

步骤七：我们打包前可以修改包名：

进入pom.xml:在<build>下一行添加<filalName>包名<filalName>

步骤八：进入Linux执行下面命令：

[root@head42 ~]# java -cp hb.jar:/opt/hbase-1.3.5/lib/* com.njbdqn.services.HbaseService

实例二

步骤一：导入架包：

<dependency><groupId>org.apache.hbase</groupId><artifactId>hbase-client</artifactId><version>1.3.5</version>
</dependency>

步骤二：编写java代码

public class hbase {public static void main(String[] args) throws IOException {createTable();listTables();//找配置文件Configuration conf = HBaseConfiguration.create();conf.set("hbase.zookeeper.quorum","localhost");//设置端口号conf.set("hbase.zookeeper.property.clientPort","2181");Connection connection= ConnectionFactory.createConnection(conf);Admin admin=connection.getAdmin();//拿到表的名字类型数组,进行for循环for (TableName name:admin.listTableNames()) {System.out.println(name.toString());}connection.close();}

步骤三：以下是开始打包命令：

步骤四：运行并形成一个包：

步骤五：进入Linux执行：[root@head42 ~]# java -cp hbase-java.jar cn.kgc.hbase

（hbase-java.jar：为导入的架包 cn.kgc.hbase：类名地址）

执行成功如下：

这样就可以了哈！