更新时间:2023-11-21 GMT+08:00
通过Java连接实例
本小节主要介绍使用Java语言连接GeminiDB HBase的基本操作。
前提条件
- 已成功创建GeminiDB HBase实例,且实例状态正常。创建GeminiDB HBase实例的方法请参见购买实例。
- 已创建弹性云服务器,创建弹性云服务器的方法,请参见《弹性云服务器快速入门》中“创建弹性云服务器”章节。
- 弹性云服务器上已经安装JDK环境。
操作步骤
- 获取GeminiDB HBase实例的开放的内网IP地址、端口。
内网IP地址和端口的获取方法请参见查看IP地址和端口。
- 登录弹性云服务器,具体操作请参见《弹性云服务器快速入门》中“登录弹性云服务器”。
- 请添加以下Maven依赖到你的项目中。
<dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-client</artifactId> <version>2.5.3</version> </dependency>
- 编辑连接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(); } } }
- 运行示例代码,确认结果是否正常。
父主题: 连接实例