使用Java操作Hbase

快来打我* 2024-03-26 19:18 87阅读 0赞

**目录**

修改hosts文件

导入jar包

配置hbase信息，连接hbase数据库

创建表

删除表

获取namespace

获取tables

添加数据

查询表中的数据

查询表中所有数据

关闭流

--------------------

### 修改hosts文件 ###

位置：C:\\Windows\\System32\\drivers\\etc\\hosts

![63d6297487b844ab9d8d906e4d45fb72.png][]

win+R：ping一下IP地址和虚拟机名看一下能不能ping通

![623bd126c68342ca8d6ea5ec6bb944a7.png][]

### 导入jar包 ###

创建maven项目，在pom.xml 里面添加jar包

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

### 配置hbase信息，连接hbase数据库 ###

//定义一个config，用于获取配置对象
        static Configuration config = null;
        //获取连接
        private Connection conn = null;
        Admin admin = null;
    
        public void init() throws IOException {
            //配置hbase信息，连接hbase数据库
            config = HBaseConfiguration.create();
            config.set(HConstants.HBASE_DIR, "hdfs://192.168.152.192:9000/hbase");
            config.set(HConstants.ZOOKEEPER_QUORUM, "192.168.152.192");
            config.set(HConstants.CLIENT_PORT_STR, "2181");
            //hbase连接工厂
            conn = ConnectionFactory.createConnection(config);
            //拿到admin
            admin = conn.getAdmin();
        }

创建命名空间

public void createNameSpace() {
            NamespaceDescriptor test = NamespaceDescriptor.create("test").build();
    
            try {
                //执行创建对象
                admin.createNamespace(test);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

### 创建表 ###

public void createTable() throws IOException {
            //创建表的描述类
            TableName tableName = TableName.valueOf("test:student");
            //获取表格描述器
            HTableDescriptor desc = new HTableDescriptor(tableName);
    
            //创建列族的描述类，添加列族
            HColumnDescriptor family1 = new HColumnDescriptor("info1");
            HColumnDescriptor family2 = new HColumnDescriptor("info2");
            desc.addFamily(family1);
            desc.addFamily(family2);
    
            admin.createTable(desc);
        }

### 删除表 ###

public void deleteTable() throws IOException { 
            //禁用
            admin.disableTable(TableName.valueOf("test:student"));
            //删除
            admin.deleteTable(TableName.valueOf("test:student"));
    }

### 获取namespace ###

public void getAllNamespace() throws IOException {
            String[] namespaces = admin.listNamespaces();
             String s = Arrays.toString(namespaces);
             System.out.println(s);
        }

![3059be4c9a5b49f181224d97afbb0ae9.png][]

### 获取tables ###

public void getAllNamespace() throws IOException {
            List<TableDescriptor> tableDescriptors =
     admin.listTableDescriptorsByNamespace("test".getBytes());
            System.out.println(tableDescriptors);
        }

![40f7f51731c344d7a0608789e87989cc.png][]

### 添加数据 ###

public void insertData() throws IOException {
            //获取表的信息
            Table table = conn.getTable(TableName.valueOf("test:student"));
            //设置行键
            Put put = new Put(Bytes.toBytes("student1"));
            //设置列的标识以及列值
            put.addColumn("info1".getBytes(), "name".getBytes(), "zs".getBytes());
            put.addColumn("info2".getBytes(), "school".getBytes(), "xwxx".getBytes());
            //执行添加
            table.put(put);
    
            //使用集合添加数据
            Put put2 = new Put(Bytes.toBytes("student2"));
            put2.addColumn("info1".getBytes(), "name".getBytes(), "zss".getBytes());
            put2.addColumn("info2".getBytes(), "school".getBytes(), "xwxx".getBytes());
            Put put3 = new Put(Bytes.toBytes("student3"));
            put3.addColumn("info1".getBytes(), "name".getBytes(), "zsr".getBytes());
            put3.addColumn("info2".getBytes(), "school".getBytes(), "xwxx".getBytes());
            List<Put> list = new ArrayList<>();
            list.add(put2);
            list.add(put3);
            table.put(list);
        }

### 查询表中的数据 ###

public void queryData() throws IOException {
            Table table = conn.getTable(TableName.valueOf("test:student"));
            Get get = new Get(Bytes.toBytes("student1"));
            Result result = table.get(get);
            byte[] value = result.getValue(Bytes.toBytes("info1"), Bytes.toBytes("name"));
            System.out.println("姓名:" + Bytes.toString(value));
            value = result.getValue(Bytes.toBytes("info2"), Bytes.toBytes("school"));
            System.out.println("学校:" + Bytes.toString(value));
    
        }

![ce95efaa4ce541b898ae066d2ba6b1d7.png][]

### 查询表中所有数据 ###

![f406c19121a340eea6ded4fb957d404a.png][]

### 关闭流 ###

public void close() throws IOException {
            if (admin != null) {
                admin.close();
            }
            if (conn != null) {
                conn.close();
            }
        }

[63d6297487b844ab9d8d906e4d45fb72.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/6fc149fc8e3a44629b03fa04db88ff57.png
[623bd126c68342ca8d6ea5ec6bb944a7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/d997046f72674f0ba8f77a67fa8b88bd.png
[3059be4c9a5b49f181224d97afbb0ae9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/fe7f5102c9754c4994d9b0faf2e32664.png
[40f7f51731c344d7a0608789e87989cc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/42419eb7f219419987a94de409c75b9b.png
[ce95efaa4ce541b898ae066d2ba6b1d7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/f2a7610dc92b4985822a1e3d013711f2.png
[f406c19121a340eea6ded4fb957d404a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/db8fe54c57fb46b3a3854843d94832cf.png