离线批量写入数据

前提条件

• 已初始化OTSClient。具体操作，请参见初始化OTSClient。

• 已创建数据表。具体操作，请参见创建数据表。

参数

示例

以下示例用于批量写入数据。

private static void bulkImport(SyncClient client, String start, String end){
    // 创建bulkImportRequest。
    // 设置数据表名称。
    String tableName = "<TABLE_NAME>"; 
    BulkImportRequest bulkImportRequest = new BulkImportRequest(tableName);

    // 创建rowChanges，设置要写入的数据。
    List<RowChange> rowChanges = new ArrayList<RowChange>();
    for (Integer i = Integer.valueOf(start); i <= Integer.valueOf(end); i++){
        PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
        primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(String.valueOf(i)));
        PrimaryKey primaryKey = primaryKeyBuilder.build();
        RowPutChange rowChange = new RowPutChange(tableName,primaryKey);
        rowChange.addColumn(new Column("DC1", ColumnValue.fromString(i.toString())));
        rowChange.addColumn(new Column("DC2", ColumnValue.fromString(i.toString())));
        rowChange.addColumn(new Column("DC3", ColumnValue.fromString(i.toString())));
        rowChanges.add(rowChange);
    }

    bulkImportRequest.addRowChanges(rowChanges);
    // 获取bulkImportResponse。
    BulkImportResponse bulkImportResponse = client.bulkImport(bulkImportRequest);
  
    List<BulkImportResponse.RowResult> succeedRows = new ArrayList<BulkImportResponse.RowResult>();
    List<BulkImportResponse.RowResult> failedRows = new ArrayList<BulkImportResponse.RowResult>();
    bulkImportResponse.getResult(succeedRows, failedRows);

    for (int i = 0; i < succeedRows.size(); i++){
        System.out.println(succeedRows.get(i).getConsumedCapacity().getCapacityDataSize().jsonize());
    }
    for (int i = 0; i < failedRows.size(); i++){
        System.out.println(failedRows.get(i).getError().getCode());
        System.out.println(failedRows.get(i).getError().getMessage());
    }
}

常见问题

• 使用SDK时出现Validate PK size fail异常

• 使用SDK时出现Validate PK name fail异常

• 主键类型报错

相关文档

• 关于API的更多信息，请参见BulkImport。

• 关于功能接口实现的更多信息，请参见BulkImportRequest.java和BulkImportResponse.java。

• 写入数据后，您可以根据需要读取或者删除表中数据。

  • 如果读取数据，您可以通过离线批量读取数据、基础数据读取等方式实现。更多信息，请参见离线批量读取数据和读取数据。

  • 如果需要删除数据，您可以通过调用DeleteRow或BatchWriteRow接口实现，更多信息，请参见删除数据。

• 您还可以通过如下方式写入数据到数据表。

  • 通过PutRow、UpdateRow和BatchWriteRow接口写入数据。更多信息，请参见写入数据。

  • 通过DataWorks、DataX等工具同步其他数据源的数据到表格存储数据表中。更多信息，请参见数据集成服务。