文档

通过HBase Java API连接并使用宽表引擎

更新时间:

Lindorm宽表引擎支持通过HBase Java API读写数据。本文介绍如何通过HBase Java API访问Lindorm宽表引擎。

前提条件

  • 已安装Java环境,要求安装JDK 1.8及以上版本。

  • 已将客户端IP地址添加至Lindorm白名单。添加方法请参见设置白名单

  • 已完成HBase Java SDK的安装。具体操作请参见安装HBase Java SDK

操作步骤

  1. 新建一个配置对象,并设置Lindorm宽表的连接地址、用户名和密码。

    // 新建一个Configuration
    Configuration conf = HBaseConfiguration.create();
    // 宽表引擎使用HBase Java API访问的连接地址
    conf.set("hbase.zookeeper.quorum", "host:port");
    // xml_template.comment.hbaseue.username_password.default
    conf.set("hbase.client.username", "用户名");
    conf.set("hbase.client.password", "密码");

    参数

    示例值

    获取方法

    host:port

    ld-bp17j28j2y7pm****-proxy-lindorm-pub.lindorm.rds.aliyuncs.com:30020

    宽表引擎使用HBase Java API访问的连接地址。

    重要
    • 如果应用部署在ECS实例,建议您通过专有网络连接访问Lindorm实例,可获得更高的安全性和更低的网络延迟。如何获取专有网络连接地址,请参见查看连接地址

    • 如果应用部署在本地,在通过公网连接Lindorm实例前,需在控制台开通公网地址。开通方式:在控制台选择数据库连接 > 宽表引擎,在宽表引擎页签单击开通公网地址

    用户名

    testuser

    如果您忘记用户名密码,可以通过Lindorm宽表引擎的集群管理系统修改密码,具体操作请参见修改用户密码

    密码

    password

  2. 使用步骤1的配置对象,建立连接。

    Connection connection = ConnectionFactory.createConnection(conf);
    说明

    在程序生命周期内只需创建一次,该连接线程安全,可以共享给所有线程使用。在程序结束后,需要将Connection对象关闭,否则会造成连接泄露。也可以采用try finally方式防止泄露。

  3. 连接建立后,可以使用HBase Java API访问Lindorm宽表。下面提供一些简单的Java示例。

    • DDL操作

      try (Admin admin = connection.getAdmin()){
          // 建表
          HTableDescriptor htd = new HTableDescriptor(TableName.valueOf("tablename"));
          htd.addFamily(new HColumnDescriptor(Bytes.toBytes("family")));
          // 创建一个只有一个分区的表
          // 在生产上建表时建议根据数据特点预先分区
          admin.createTable(htd);
      
          // disable表
          admin.disableTable(TableName.valueOf("tablename"));
      
          // truncate表,清空表中数据,清空数据前需要先disable表
          admin.truncateTable(TableName.valueOf("tablename"), true);
      
          // 删除表,删除表之前需要先disable表
          admin.deleteTable(TableName.valueOf("tablename"));
      }
    • DML操作

      //Table为非线程安全对象,每个线程在对Table操作时,都必须从Connection中获取相应的Table对象
      try (Table table = connection.getTable(TableName.valueOf("tablename"))) {
          // 插入数据
          Put put = new Put(Bytes.toBytes("row"));
          put.addColumn(Bytes.toBytes("family"), Bytes.toBytes("qualifier"), Bytes.toBytes("value"));
          table.put(put);
      
          // 单行读取
          Get get = new Get(Bytes.toBytes("row"));
          Result res = table.get(get);
      
          // 删除一行数据
          Delete delete = new Delete(Bytes.toBytes("row"));
          table.delete(delete);
      
          // scan范围数据
          Scan scan = new Scan(Bytes.toBytes("startRow"), Bytes.toBytes("endRow"));
          ResultScanner scanner = table.getScanner(scan);
          for (Result result : scanner) {
              // 处理查询结果result
              System.out.println(result.toString());
          }
          scanner.close();
      }