前提條件

• 已初始化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等工具同步其他數據源的數據到表格存儲數據表中。更多信息，請參見數據集成服務。