Java 版 Hello World

本代码示例是通过 Java 版 Bigtable 客户端库，使用 Java 编写的“hello world”应用， 该示例说明如何完成以下任务：

  • 设置身份验证
  • 连接到 Bigtable 实例。
  • 新建一个表。
  • 将数据写入表中。
  • 重新读取这些数据。
  • 删除表。

运行示例

本代码使用 Java 版Google Cloud 客户端库中的 Bigtable 客户端库与 Bigtable 通信。

在开始之前，请按照参考 文档中所述的设置步骤操作。

将 Cloud 客户端库与 Bigtable 搭配使用

示例应用会连接到 Bigtable 并演示一些基本操作。

连接到 Bigtable

如需开始连接，您需要一个用来与数据 API 客户端库通信的数据客户端，以及一个用来与管理员 API 客户端库通信的表管理员客户端。

首先，实例化一个 BigtableDataSettings 对象，其中包含 hello world 应用要使用的项目 ID 和实例 ID。然后将设置传递给 BigtableDataClient.create() 方法以便创建数据客户端。

对管理员客户端执行类似操作，即首先通过创建 BigtableTableAdminSettings 对象建立设置，然后使用该设置创建 BigtableTableAdminClient 对象。

最佳做法是务必在使用 Bigtable 时创建一次客户端，并在整个应用中重复使用该客户端。

// Creates the settings to configure a bigtable data client.
BigtableDataSettings settings =
    BigtableDataSettings.newBuilder().setProjectId(projectId).setInstanceId(instanceId).build();

// Creates a bigtable data client.
dataClient = BigtableDataClient.create(settings);

// Creates a bigtable table admin client.
adminClient = BigtableTableAdminClientV2.create();

创建表

如需创建表，请构建一个 CreateTableRequest 对象 并将其传递给管理员客户端的 createTable() 方法。

// Checks if table exists, creates table if does not exist.
boolean exists = false;
try {
  adminClient.getTable(
      GetTableRequest.newBuilder()
          .setName("projects/" + projectId + "/instances/" + instanceId + "/tables/" + tableId)
          .setView(Table.View.NAME_ONLY)
          .build());
  exists = true;
} catch (NotFoundException e) {
  // ignore
}
if (!exists) {
  System.out.println("Creating table: " + tableId);
  String parent = "projects/" + projectId + "/instances/" + instanceId;
  CreateTableRequest request =
      CreateTableRequest.newBuilder()
          .setParent(parent)
          .setTableId(tableId)
          .setTable(
              Table.newBuilder()
                  .putColumnFamilies(COLUMN_FAMILY, ColumnFamily.getDefaultInstance())
                  .build())
          .build();
  adminClient.createTable(request);
  System.out.printf("Table %s created successfully%n", tableId);
}

将行写入表

创建一个包含三个问候语的 greetings[] 字符串数组，用作写入表的数据源。循环遍历该数组。在循环的每个 迭代中，创建一个 RowMutation 对象，然后使用 setCell() 方法向 变更中添加条目。

try {
  System.out.println("\nWriting some greetings to the table");
  String[] names = {"World", "Bigtable", "Java"};
  for (int i = 0; i < names.length; i++) {
    String greeting = "Hello " + names[i] + "!";
    RowMutation rowMutation =
        RowMutation.create(TableId.of(tableId), ROW_KEY_PREFIX + i)
            .setCell(COLUMN_FAMILY, COLUMN_QUALIFIER_NAME, names[i])
            .setCell(COLUMN_FAMILY, COLUMN_QUALIFIER_GREETING, greeting);
    dataClient.mutateRow(rowMutation);
    System.out.println(greeting);
  }
} catch (NotFoundException e) {
  System.err.println("Failed to write to non-existent table: " + e.getMessage());
}

按行键读取行

使用数据客户端的 readRow() 方法读取 您写入的第一行。

try {
  System.out.println("\nReading a single row by row key");
  Row row = dataClient.readRow(TableId.of(tableId), ROW_KEY_PREFIX + 0);
  System.out.println("Row: " + row.getKey().toStringUtf8());
  for (RowCell cell : row.getCells()) {
    System.out.printf(
        "Family: %s    Qualifier: %s    Value: %s%n",
        cell.getFamily(), cell.getQualifier().toStringUtf8(), cell.getValue().toStringUtf8());
  }
  return row;
} catch (NotFoundException e) {
  System.err.println("Failed to read from a non-existent table: " + e.getMessage());
  return null;
}
try {
  System.out