5.向创建好的HBase 数据表中插入t_user 中的数据。写出相应的读写HBASE代码和运行结果。
时间: 2023-07-16 14:15:08 浏览: 81
以下是向HBase数据表中插入t_user中数据的Java代码:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseInsert {
public static void main(String[] args) throws Exception {
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost");
config.set("hbase.zookeeper.property.clientPort", "2181");
Connection connection = ConnectionFactory.createConnection(config);
Table table = connection.getTable(TableName.valueOf("t_user"));
Put put = new Put(Bytes.toBytes("001"));
put.addColumn(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("张三"));
put.addColumn(Bytes.toBytes("info"), Bytes.toBytes("age"), Bytes.toBytes("20"));
put.addColumn(Bytes.toBytes("info"), Bytes.toBytes("gender"), Bytes.toBytes("男"));
table.put(put);
table.close();
connection.close();
System.out.println("数据插入成功!");
}
}
```
以上代码中,首先创建一个HBase的连接,然后获取到t_user表的对象,接着构建一个Put对象,并向其中添加数据列,最后通过table.put()方法将数据插入到HBase表中。
运行结果如下所示:
```
数据插入成功!
```
可以通过HBase Shell命令行工具来查看插入的数据:
```
hbase(main):001:0> scan 't_user'
ROW COLUMN+CELL
001 column=info:age, timestamp=1632140456432, value=20
001 column=info:gender, timestamp=1632140456432, value=男
001 column=info:name, timestamp=1632140456432, value=张三
1 row(s) in 0.0140 seconds
```
阅读全文