使用Eclipse连接hbase1.1 hadoop2.6

红太狼 2022-05-26 08:49 195阅读 0赞

配置项目环境：

1.当第三方应用访问HBase时，需要首先访问ZooKeeper（由$HBASE\_HOME/conf/hbase-site.xml设置），因此需要通过classpath来指定HBase配置文件的位置（即$HBASE\_HOME/conf的位置）

![20160628224042643][]  其它文章介绍将hbase-site.xml拷贝过来就可以了，我是将hadoop下的两个文件也拷贝过来了。

2.将hbase目录lib下的jar包拷贝在工程中，具体拷贝jar包是用maven还是用Build path就不介绍了

3.在/etc/system32/driver/etc/hosts中将hadoop的主机和IP标识写上：

![20160628224455327][]

3.测试通过的代码：

\[html\]  [view plain][]   [copy][view plain]

1.  package use.hbase.api;    
2.      
3.  import java.io.IOException;    
4.      
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.client.Get;    
10. import org.apache.hadoop.hbase.client.HBaseAdmin;    
11. import org.apache.hadoop.hbase.client.HTable;    
12. import org.apache.hadoop.hbase.client.Put;    
13. import org.apache.hadoop.hbase.client.Result;    
14. import org.apache.hadoop.hbase.client.ResultScanner;    
15. import org.apache.hadoop.hbase.client.Scan;    
16. import org.apache.hadoop.hbase.util.Bytes;    
17.     
18. public class HBaseTest \{    
19.     
20.     static Configuration cfg = HBaseConfiguration.create();    
21.     /\*\*   
22.      \* @param args   
23.      \*/    
24.     public static void main(String\[\] args) \{    
25.         // TODO Auto-generated method stub    
26.         String tablename = "hbase\_table";    
27.         String columnFamily = "cf";    
28.         try \{    
29.             HBaseTestCase.create(tablename, columnFamily);    
30.             HBaseTestCase.put(tablename, "row1", columnFamily, "cl1", "hello world!");    
31.             HBaseTestCase.get(tablename, "row1");    
32.             HBaseTestCase.scan(tablename);    
33.             if(true==HBaseTestCase.delete(tablename)) \{    
34.                 System.out.println("Delete table:"+tablename+" success!");    
35.             \}    
36.         \} catch (Exception e) \{    
37.             // TODO Auto-generated catch block    
38.             e.printStackTrace();    
39.         \}    
40.             
41.             
42.     \}    
43.         
44.     /\*\*   
45.      \* create a table :table\_name(columnFamily)    
46.      \* @param tablename   
47.      \* @param columnFamily   
48.      \* @throws Exception   
49.      \*/    
50.     public static void create(String tablename, String columnFamily) throws Exception \{    
51.         HBaseAdmin admin = new HBaseAdmin(cfg);    
52.         if(admin.tableExists(tablename)) \{    
53.             System.out.println("table exists!");    
54.             System.exit(0);    
55.         \}    
56.         else \{    
57.             HTableDescriptor tableDesc = new HTableDescriptor(tablename);    
58.             tableDesc.addFamily(new HColumnDescriptor(columnFamily));    
59.             admin.createTable(tableDesc);    
60.             System.out.println("create table success!");    
61.         \}    
62.     \}    
63.     
64.     /\*\*   
65.      \* put a row data into table    
66.      \* @param tablename   
67.      \* @param row   
68.      \* @param columnFamily   
69.      \* @param column   
70.      \* @param data   
71.      \* @throws Exception   
72.      \*/    
73.     public static void put(String tablename, String row, String columnFamily, String column, String data) throws Exception\{    
74.         HTable table = new HTable(cfg, tablename);    
75.         Put p1 = new Put(Bytes.toBytes(row));    
76.         p1.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(data));    
77.         table.put(p1);    
78.         System.out.println("put '"+row+"', '"+columnFamily+":"+column+"', '"+data+"'");    
79.             
80.     \}    
81.         
82.     /\*\*   
83.      \* get a row data from a table   
84.      \* @param tablename   
85.      \* @param row   
86.      \* @throws Exception   
87.      \*/    
88.     public static void get(String tablename, String row) throws Exception \{    
89.         HTable table = new HTable(cfg, tablename);    
90.         Get get = new Get(Bytes.toBytes(row));    
91.         Result result = table.get(get);    
92.         System.out.println("Get: "+result);    
93.     \}    
94.         
95.     /\*\*   
96.      \* show all data from a table   
97.      \* @param tablename   
98.      \* @throws Exception   
99.      \*/    
100.     public static void scan(String tablename) throws Exception \{    
101.         HTable table = new HTable(cfg, tablename);    
102.         Scan s =new Scan();    
103.         ResultScanner rs = table.getScanner(s);    
104.         for(Result r:rs) \{    
105.             System.out.println("Scan: "+r);    
106.         \}    
107.     \}    
108.     
109.     /\*\*   
110.      \* delete a table's data   
111.      \* @param tablename   
112.      \* @return   
113.      \* @throws IOException   
114.      \*/    
115.     public static boolean delete(String tablename) throws IOException \{    
116.         HBaseAdmin admin = new HBaseAdmin(cfg);    
117.         if(admin.tableExists(tablename)) \{    
118.             try \{    
119.                 admin.disableTable(tablename);    
120.                 admin.deleteTable(tablename);    
121.             \} catch (Exception e) \{    
122.                 // TODO: handle exception    
123.                 e.printStackTrace();    
124.                 return false;    
125.             \}    
126.         \}    
127.         return true;    
128.     \}    
129. \}

在hdfs中可以看到

![20160628224852990][]

[20160628224042643]: /images/20220526/fa2d8d12d83b472dae038db507ae5bec.png
[20160628224455327]: /images/20220526/2c9f45e5a97e4ebab09825a6a9c0a1a1.png
[view plain]: https://blog.csdn.net/nengyu/article/details/51779395#
[20160628224852990]: /images/20220526/b27abc2ec28141ae984c24ac344ca2d8.png