Only the Chinese version of this page is provided currently. The English version will be provided soon.

连接数据库

Last updated: 2026-02-04 16:56:49

前提条件

已创建 HBase 兼容模式的实例。
已创建相关数据表及数据库用户。

步骤一:添加客户端依赖

添加 jar 包依赖到本地 Java 工程的pom.xml文件中。
<dependency>
<groupId>com.tencent.tdsql</groupId>
<artifactId>tdsql-hbase-shaded-client</artifactId>
<version>1.0.9</version>
</dependency>
注意:
版本更新:建议使用最新版本 jar 包,旧版本的 jar 包可能不支持新的服务端。
版本检查:参考 中央仓库 已发布的 tdsql-hbase-shaded-client 版本,将版本号替换为已发布的最新版本号。

步骤二:设置客户端连接参数

public class HBaseInsertDemo {
public static void main(String[] args) throws Exception {
// 配置HBase
Configuration conf = HBaseConfiguration.create();
config.set("hbase.client.tdsql.quorum", "10.10.10.10:6752"); // HBase服务RPC端口
config.setBoolean("hbase.tdsql.hash.partition", Boolean.TRUE); // 启用HBase兼容模式
config.set("mysql.native.username", "test"); // 数据库用户名
config.set("mysql.native.password", "test123"); // 数据库密码

Connection connection = ConnectionFactory.createConnection(conf);

// 拿到Table句柄
TableName tableName = TableName.valueOf("ht1");
Table table = connection.getTable(tableName);

// 准备插入数据
Put put = new Put(Bytes.toBytes("rk801"));
put.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("column1"), Bytes.toBytes("v1")); // 列族,列标识符,值
table.put(put);

// 关闭资源
table.close();
connection.close();

System.out.println("数据插入成功!");
}
}
参数说明:
参数
说明
hbase.client.tdsql.quorum
HBase 服务 RPC 端口。
hbase.tdsql.hash.partition
必须设置为TRUE,启用 HBase 兼容模式。
mysql.native.username
和 MySQL 一样,通过创建用户的 SQL 语句设置,忽略 MySQL 的权限。
mysql.native.password