更新时间:2023-11-21 GMT+08:00
分享

通过Java连接实例

本小节主要介绍使用Java语言连接GeminiDB HBase的基本操作。

前提条件

  • 已成功创建GeminiDB HBase实例,且实例状态正常。创建GeminiDB HBase实例的方法请参见购买实例
  • 已创建弹性云服务器,创建弹性云服务器的方法,请参见《弹性云服务器快速入门》中“创建弹性云服务器”章节。
  • 弹性云服务器上已经安装JDK环境。

操作步骤

  1. 获取GeminiDB HBase实例的开放的内网IP地址、端口。

    内网IP地址和端口的获取方法请参见查看IP地址和端口

  2. 登录弹性云服务器,具体操作请参见《弹性云服务器快速入门》中“登录弹性云服务器”。
  3. 请添加以下Maven依赖到你的项目中。

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

  4. 编辑连接GeminiDB HBase实例的代码。

    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.HBaseConfiguration;
    import org.apache.hadoop.hbase.TableName;
    import org.apache.hadoop.hbase.client.*;
    import org.apache.hadoop.hbase.util.Bytes;
    
    import java.io.IOException;
    
    public class HBaseExample {
        public static void main(String[] args) throws IOException {
            // 创建配置对象并设置Hbase连接参数
            Configuration config = HBaseConfiguration.create();
            config.set("hbase.zookeeper.quorum", "your_hbase_instance_quorum");
            config.set("hbase.zookeeper.property.clientPort", "your_hbase_instance_port");
    
            // 建立与Hbase实例的连接
            Connection connection = ConnectionFactory.createConnection(config);
    
            try {
                // 获取表对象
                TableName tableName = TableName.valueOf("your_table_name");
                Table table = connection.getTable(tableName);
    
                // 插入数据
                Put put = new Put(Bytes.toBytes("row_key"));
                put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col"), Bytes.toBytes("value"));
                table.put(put);
    
                // 获取单行数据
                Get get = new Get(Bytes.toBytes("row_key"));
                Result result = table.get(get);
                byte[] value = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("col"));
                System.out.println("Value: " + Bytes.toString(value));
    
            } finally {
                // 关闭连接
                connection.close();
            }
        }
    }

  5. 运行示例代码,确认结果是否正常。
分享:

    相关文档

    相关产品