使用Java API连接和操作HBase数据库

r囧r小猫 2023-09-25 11:45 64阅读 0赞

2 public class HbaseTest \{

7 static Configuration config=null;

8 private Connection connection=null;

9 private Table table=null;

11 @Before

12 public void init() throws Exception \{

13 config=HBaseConfiguration.create();// 配置

14 config.set("hbase.zookeeper.quorum", "192.168.33.61");// zookeeper地址

15 config.set("hbase.zookeeper.property.clientPort", "2181");// zookeeper端口

16 connection=ConnectionFactory.createConnection(config);

17 table=connection.getTable(TableName.valueOf("dept"));

18 \}

25 @Test

26 public void createTable() throws Exception \{

27 // 创建表管理类

28 HBaseAdmin admin=new HBaseAdmin(config); // hbase表管理

29 // 创建表描述类

30 TableName tableName=TableName.valueOf("dept"); // 表名称

31 HTableDescriptor desc=new HTableDescriptor(tableName);

32 // 创建列族的描述类

33 HColumnDescriptor family=new HColumnDescriptor("info"); // 列族

34 // 将列族添加到表中

35 desc.addFamily(family);

36 HColumnDescriptor family2=new HColumnDescriptor("subdept"); // 列族

37 // 将列族添加到表中

38 desc.addFamily(family2);

39 // 创建表

40 admin.createTable(desc); // 创建表

41 System.out.println("创建表成功！");

42 \}

50 @SuppressWarnings(\{ "deprecation", "resource" \})

51 @Test

52 public void insertData() throws Exception \{

53 table.setAutoFlushTo(false);

54 table.setWriteBufferSize(534534534);

55 ArrayList arrayList=new ArrayList ();

57 Put put=new Put(Bytes.toBytes("0\_1"));

58 put.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("网络部"));

59 put.add(Bytes.toBytes("subdept"), Bytes.toBytes("subdept1"), Bytes.toBytes("1\_1"));

60 put.add(Bytes.toBytes("subdept"), Bytes.toBytes("subdept2"), Bytes.toBytes("1\_2"));

61 arrayList.add(put);

63 Put put1=new Put(Bytes.toBytes("1\_1"));

64 put1.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("开发部"));

65 put1.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("0\_1"));

67 Put put2=new Put(Bytes.toBytes("1\_2"));

68 put2.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("测试部"));

69 put2.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("0\_1"));

71 for (int i=1; i <=100; i++) \{

73 put1.add(Bytes.toBytes("subdept"), Bytes.toBytes("subdept"+i), Bytes.toBytes("2\_"+i));

74 put2.add(Bytes.toBytes("subdept"), Bytes.toBytes("subdept"+i), Bytes.toBytes("3\_"+i));

75 \}

76 arrayList.add(put1);

77 arrayList.add(put2);

78 //插入数据

79 table.put(arrayList);

80 //提交

81 table.flushCommits();

82 System.out.println("数据插入成功！");

83 \}

89 @Test

90 public void insertOtherData() throws Exception \{

91 table.setAutoFlushTo(false);

92 table.setWriteBufferSize(534534534);

93 ArrayList arrayList=new ArrayList ();

94 for (int i=1; i <=100; i++) \{

95 Put put\_development=new Put(Bytes.toBytes("2\_"+i));

96 put\_development.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("开发"+i+"组"));

97 put\_development.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("1\_1"));

98 arrayList.add(put\_development);

100 Put put\_test=new Put(Bytes.toBytes("3\_"+i));

101 put\_test.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("测试"+i+"组"));

102 put\_test.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("1\_2"));

103 arrayList.add(put\_test);

104 \}

105

106 //插入数据

107 table.put(arrayList);

108 //提交

109 table.flushCommits();

110 System.out.println("插入其他数据成功！");

111 \}

112

113

117 @Test

118 public void scanDataStep1() throws Exception \{

119

120 // 创建全表扫描的scan

121 Scan scan=new Scan();

122 System.out.println("查询到的所有一级部门如下：");

123 // 打印结果集

124 ResultScanner scanner=table.getScanner(scan);

125 for (Result result : scanner) \{

126 if (result.getValue(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"))==null) \{

127 for (KeyValue kv : result.raw()) \{

128 System.out.print(new String(kv.getRow()) + " ");

129 System.out.print(new String(kv.getFamily()) + ":");

130 System.out.print(new String(kv.getQualifier()) + "=");

131 System.out.print(new String(kv.getValue()));

132 System.out.print(" timestamp=" + kv.getTimestamp() + "

");

133 \}

134 \}

135 \}

136 \}

137

138

142 @Test

143 public void scanDataStep2() throws Exception \{

144 Get g=new Get("1\_1".getBytes());

145 g.addFamily("subdept".getBytes());

146 // 打印结果集

147 Result result=table.get(g);

148 for (KeyValue kv : result.raw()) \{

149 Get g1=new Get(kv.getValue());

150 Result result1=table.get(g1);

151 for (KeyValue kv1 : result1.raw()) \{

152 System.out.print(new String(kv1.getRow()) + " ");

153 System.out.print(new String(kv1.getFamily()) + ":");

154 System.out.print(new String(kv1.getQualifier()) + "=");

155 System.out.print(new String(kv1.getValue()));

156 System.out.print(" timestamp=" + kv1.getTimestamp() + "

");

157 \}

158 \}

159 \}

160

161

167 @Test

168 public void scanDataStep3() throws Exception \{

169 //新增一个部门

170 Put put=new Put(Bytes.toBytes("4\_1"));

171 put.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("我增加的部门"));

172 put.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("0\_1"));

173 //插入数据

174 table.put(put);

175 //提交

176 table.flushCommits();

177

178 //更新网络部

179 Put put1=new Put(Bytes.toBytes("0\_1"));

180 put1.add(Bytes.toBytes("subdept"), Bytes.toBytes("subdept3"), Bytes.toBytes("4\_1"));

181 //插入数据

182 table.put(put1);

183 //提交

184 table.flushCommits();

185 \}

186

187

191 @Test

192 public void scanDataStep4() throws Exception \{

193

196 table.setAutoFlushTo(false);

197 table.setWriteBufferSize(534534534);

198 ArrayList arrayList=new ArrayList ();

199 Put put1=new Put(Bytes.toBytes("5\_1"));

200 put1.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("新增子部门1"));

201 put1.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("4\_1"));

202 Put put2=new Put(Bytes.toBytes("5\_2"));

203 put2.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("新增子部门2"));

204 put2.add(Bytes.toBytes("info"), Bytes.toBytes("f\_pid"), Bytes.toBytes("4\_1"));

205

206 arrayList.add(put1);

207 arrayList.add(put2);

208 //插入数据

209 table.put(arrayList);

210 //提交

211 table.flushCommits();

212

213

217 Put put=new Put(Bytes.toBytes("4\_1"));

218 put.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("开发部"));

219 //插入数据

220 table.put(put);

221 //提交

222 table.flushCommits();

223 \}

224

225 @After

226 public void close() throws Exception \{

227 table.close();

228 connection.close();

229 \}

230

231 \}

使用Java API连接和操作HBase数据库

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关使用Java API连接和操作HBase数据库

相关 hbase数据库scan操作_hbase数据库操作

相关 HBase Java API操作数据库

相关 Hbase 新api连接java实现

相关 java api操作hbase

相关 java操作hbase数据库

相关 java连接Hbase数据库

相关使用java操作Hbase数据库

相关 HBase API 和基本操作

相关使用Phoenix5 Java api操作HBase