在集群中Java 通过调用API操作HBase_JAVA_编程开发_程序员俱乐部

1. package com.wan.hbase;
2. import java.io.IOException;
3. import org.apache.Hadoop.conf.Configuration;
4. import org.apache.hadoop.hbase.Cell;
5. import org.apache.hadoop.hbase.CellUtil;
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.MasterNotRunningException;
10. import org.apache.hadoop.hbase.TableName;
11. import org.apache.hadoop.hbase.ZooKeeperConnectionException;
12. import org.apache.hadoop.hbase.client.Delete;
13. import org.apache.hadoop.hbase.client.Get;
14. import org.apache.hadoop.hbase.client.HBaseAdmin;
15. import org.apache.hadoop.hbase.client.HTable;
16. import org.apache.hadoop.hbase.client.Put;
17. import org.apache.hadoop.hbase.client.Result;
18. import org.apache.hadoop.hbase.client.ResultScanner;
19. import org.apache.hadoop.hbase.client.Scan;
20. import org.apache.hadoop.hbase.util.Bytes;
22. public class SimpleHBase {
23. public static void main(String[] args) {
24. ??Configuration configuration=HBaseConfiguration.create();
25. ??String tableName="student";
26. ??createTable(configuration, tableName);
27. //??addData(configuration, tableName);
28. //??getData(configuration, tableName);
29. //??getAllData(configuration, tableName);
30. //??deleteDate(configuration, tableName);
31. //??dropTable(configuration, tableName);
32. ??
33. }
36. public static void createTable(Configuration configuration,String tableName){
37. ??HBaseAdmin admin;
38. ??try {
39. ???admin = new HBaseAdmin(configuration);
40. ???if(admin.tableExists(tableName)){
41. ????admin.disableTable(tableName);
42. ????admin.deleteTable(tableName);
43. ????System.out.println(tableName+"is exist ,delete ......");
44. ???}
45. ???
46. ???
47. ???HTableDescriptor tableDescriptor=new HTableDescriptor(TableName.valueOf(tableName));
48. ???tableDescriptor.addFamily(new HColumnDescriptor("info"));
49. ???tableDescriptor.addFamily(new HColumnDescriptor("address"));
50. ???admin.createTable(tableDescriptor);
51. ???System.out.println("end create table");
52. ??} catch (MasterNotRunningException e) {
53. ???// TODO Auto-generated catch block
54. ???e.printStackTrace();
55. ??} catch (ZooKeeperConnectionException e) {
56. ???// TODO Auto-generated catch block
57. ???e.printStackTrace();
58. ??} catch (IOException e) {
59. ???// TODO Auto-generated catch block
60. ???e.printStackTrace();
61. ??}
62. ??
63. }
66. public static void dropTable(Configuration configuration,String tableName){
67. ??HBaseAdmin admin;
68. ??try {
69. ???admin = new HBaseAdmin(configuration);
70. ???if(admin.tableExists(tableName)){
71. ????admin.disableTable(tableName);
72. ????admin.deleteTable(tableName);
73. ????System.out.println(tableName+"delete success!");
74. ???}else{
75. ????System.out.println(tableName+"Table does not exist!");
76. ???}
77. ??} catch (MasterNotRunningException e) {
78. ???// TODO Auto-generated catch block
79. ???e.printStackTrace();
80. ??} catch (ZooKeeperConnectionException e) {
81. ???// TODO Auto-generated catch block
82. ???e.printStackTrace();
83. ??} catch (IOException e) {
84. ???// TODO Auto-generated catch block
85. ???e.printStackTrace();
86. ??}
87. }
90. public static void addData(Configuration configuration,String tableName){
91. ??HBaseAdmin admin;
92. ??try {
93. ???admin = new HBaseAdmin(configuration);
94. ???if(admin.tableExists(tableName)){
95. ????HTable table=new HTable(configuration, tableName);
96. ????Put put=new Put(Bytes.toBytes("zhangsan"));
97. ????put.add(Bytes.toBytes("info"), Bytes.toBytes("age"), Bytes.toBytes("28"));
98. ????table.put(put);
99. ????System.out.println("add success!");
100. ???}else{
101. ????System.out.println(tableName+"Table does not exist!");
102. ???}
103. ??} catch (MasterNotRunningException e) {
104. ???// TODO Auto-generated catch block
105. ???e.printStackTrace();
106. ??} catch (ZooKeeperConnectionException e) {
107. ???// TODO Auto-generated catch block
108. ???e.printStackTrace();
109. ??} catch (IOException e) {
110. ???// TODO Auto-generated catch block
111. ???e.printStackTrace();
112. ??}
113. }
116. public static void deleteDate(Configuration configuration,String tableName){
117. ??HBaseAdmin admin;
118. ??try {
119. ???admin=new HBaseAdmin(configuration);
120. ???if(admin.tableExists(tableName)){
121. ????HTable table=new HTable(configuration, tableName);
122. ????Delete delete=new Delete(Bytes.toBytes("zhangsan"));
123. ????table.delete(delete);
124. ????System.out.println("delete success!");
125. ???}else{
126. ????System.out.println("Table does not exist!");
127. ???}
128. ??} catch (MasterNotRunningException e) {
129. ???// TODO Auto-generated catch block
130. ???e.printStackTrace();
131. ??} catch (ZooKeeperConnectionException e) {
132. ???// TODO Auto-generated catch block
133. ???e.printStackTrace();
134. ??} catch (IOException e) {
135. ???// TODO Auto-generated catch block
136. ???e.printStackTrace();
137. ??}
138. }
141. public static void getData(Configuration configuration,String tableName){
142. ??HTable table;
143. ??try {
144. ???table = new HTable(configuration, tableName);
145. ???Get get=new Get(Bytes.toBytes("zhangsan"));
146. ???Result result=table.get(get);
148. ???for(Cell cell:result.rawCells()){???
149. ????System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
150. ????System.out.println("Timetamp:"+cell.getTimestamp()+" ");
151. ????System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
152. ????System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
153. ????System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");
154. ???}
155. ??} catch (IOException e) {
156. ???// TODO Auto-generated catch block
157. ???e.printStackTrace();
158. ??}
159. }
162. public static void getAllData(Configuration configuration,String tableName){
163. ??HTable table;
164. ??try {
165. ???table=new HTable(configuration, tableName);
166. ???Scan scan=new Scan();
167. ???ResultScanner results=table.getScanner(scan);
168. ???for(Result result:results){
169. ????for(Cell cell:result.rawCells()){???
170. ?????System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
171. ?????System.out.println("Timetamp:"+cell.getTimestamp()+" ");
172. ?????System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
173. ?????System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
174. ?????System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");
175. ????}
176. ???}
177. ??} catch (IOException e) {
178. ???// TODO Auto-generated catch block
179. ???e.printStackTrace();
180. ??}
181. ????
182. }
183. }

?

?

?

?

?

http://blog.sina.com.cn/s/blog_68674da70102vaaw.html