TDSQL Boundless 连接数据库（开发指南 HBase 兼容模式 ）

一、前提条件

·已创建 HBase 兼容模式的实例。

·已创建相关数据表及数据库用户。

·已 获取 jar 包。

·已 获取 hbase shell。

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

JavaGo

// Javapublic class HBaseInsertDemo { public static void main(String[] args) throws Exception { // 配置HBase Configuration conf = HBaseConfiguration.create(); conf.set("hbase.client.tdsql.quorum", "10.10.10.10:6752"); // HBase服务RPC端口 conf.setBoolean("hbase.client.tdsql.enabled", Boolean.TRUE); // 启用HBase兼容模式 conf.set("mysql.native.username", "test"); // 数据库用户名 conf.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("数据插入成功!"); }}

参数说明：

// Goimport ( "context" gohbase "cnb.woa.com/tdsql-hbase/tdsql-gohbase" "cnb.woa.com/tdsql-hbase/tdsql-gohbase/hrpc")func main() { cfg := gohbase.TDSQLConfig{ Endpoints: []string{"10.10.10.10:6752"}, // HBase服务RPC端口 Username: "test", Password: "test123", } client := gohbase.NewClient("", gohbase.WithTDSQLConfig(cfg)) defer client.Close() // 写入 values := map[string]map[string][]byte{"cf": {"a": []byte{0}}} putRequest, _ := hrpc.NewPutStr(context.Background(), "table", "key", values) client.Put(putRequest) // 读取 getRequest, _ := hrpc.NewGetStr(context.Background(), "table", "key") client.Get(getRequest)}

参数说明：