通过 SQL 查询数据

前提条件

• 安装Tablestore Java SDK并初始化客户端。

• 使用 5.13.0 及以上版本的 Tablestore Java SDK。

• 已为待查询的数据表或多元索引创建映射关系。

功能说明

调用 sqlQuery 方法执行 SELECT 语句，查询映射表中的数据。查询结果包含字段结构和满足查询条件的数据行。

SQLQueryResponse sqlQuery(SQLQueryRequest request)

以下示例查询 example_table 映射表中 tenant_id 等于 1 的数据，最多返回 10 行。

String query = "SELECT tenant_id, pk, name, score FROM example_table "
        + "WHERE tenant_id = 1 LIMIT 10";
SQLQueryRequest request = new SQLQueryRequest(query);

SQLQueryResponse response = client.sqlQuery(request);
SQLResultSet resultSet = response.getSQLResultSet();
System.out.println("Schema: " + resultSet.getSQLTableMeta().getSchema());

while (resultSet.hasNext()) {
    SQLRow row = resultSet.next();
    System.out.println(
            row.getLong("tenant_id") + ", "
                    + row.getString("pk") + ", "
                    + row.getString("name") + ", "
                    + row.getLong("score"));
}

参数说明

SQLQueryRequest 包含以下参数。

返回值

SQLQueryResponse 包含以下与查询结果相关的字段。