tencent cloud

TDSQL Boundless

DocumentaçãoTDSQL BoundlessDeveloper GuideDeveloper Guide (HBase Compatibility Mode)Connecting to the Database

Connecting to the Database

Download
Modo Foco
Tamanho da Fonte
Última atualização: 2026-07-13 09:53:17

Prerequisites

An instance in HBase-compatible mode has been created.
The related data tables and database users have been created.
Have obtained the jar package.
Have obtained hbase shell.

Step 1: Add Client Dependencies

Add the jar package dependency to the pom.xml file of your local Java project.
<dependency>
    <groupId>com.tencent.tdsql</groupId>
    <artifactId>tdsql-hbase-shaded-client</artifactId>
    <version>1.0.10</version>
</dependency>
Note:
Version update: It is recommended to use the latest version of the jar package, as older versions may not support the new server.
Version check: Refer to the published tdsql-hbase-shaded-client version in the central repository and replace the version number with the latest published version number.

Step 2: Configure Client Connection Parameters

Java
Go
// Java
public class HBaseInsertDemo {
    public static void main(String[] args) throws Exception {
        // Configure HBase
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.client.tdsql.quorum", "10.10.10.10:6752");    // RPC port for the HBase service
        conf.setBoolean("hbase.client.tdsql.enabled", Boolean.TRUE); // Enable HBase-compatible mode
        conf.set("mysql.native.username", "test");                   // Database username
        conf.set("mysql.native.password", "test123");                // Database password

        Connection connection = ConnectionFactory.createConnection(conf);

        // Get the Table handle
        TableName tableName = TableName.valueOf("ht1");
        Table table = connection.getTable(tableName);

        // Prepare to insert data
        Put put = new Put(Bytes.toBytes("rk801"));
        put.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("column1"), Bytes.toBytes("v1")); // Column family, column qualifier, value
        table.put(put);

        // Disable resources.
        table.close();
        connection.close();

        System.out.println("Data inserted successfully!");
    }
}
Parameter description:
Parameter
Description
hbase.client.tdsql.quorum
HBase service RPC port.
hbase.client.tdsql.enabled
Must be set to TRUE to enable HBase compatibility mode.
mysql.native.username
As with MySQL, you can set it via SQL statements for creating users, ignoring MySQL privileges.
mysql.native.password
// Go
import (
    "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"}, // RPC port for the HBase service
        Username:  "test",
        Password:  "test123",
    }

    client := gohbase.NewClient("", gohbase.WithTDSQLConfig(cfg))
    defer client.Close()

    // Write
    values := map[string]map[string][]byte{"cf": {"a": []byte{0}}}
    putRequest, _ := hrpc.NewPutStr(context.Background(), "table", "key", values)
    client.Put(putRequest)

    // Read
    getRequest, _ := hrpc.NewGetStr(context.Background(), "table", "key")
    client.Get(getRequest)
}

Parameter description:
Parameter
Description
Endpoints
List of HBase service RPC port addresses, in the format ["host:port"].
Username
Database username
Password
Database password
Anterior: Data ModelPróximo: Database Schema Design

Ajuda e Suporte

Esta página foi útil?

comentários