行操作

1private static void myPutRow(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望写入数据的表的表名
3    PutRowRequest putRequest = new PutRowRequest(TABLE_NAME, "rowkey1");
4    // 设置写入内容
5    for (int i = 0; i < 10; i++) {
6        putRequest.addCell("col" + i, "val" + i);
7    }
8    try {
9        // 写入一行数据
10        tableStorageClient.putRow(putRequest);
11    } catch (BceClientException e) {
12        return;
13    }
14}   

1private static void myBatchPutRow(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望写入数据的表的表名
3    BatchPutRowRequest batchPutRowRequest = new BatchPutRowRequest(TABLE_NAME);
4    // 设置写入内容
5    for (int i = 0; i < 10; i++) {
6        PutRow putRow = new PutRow("rowkey" + i);
7        for (int j = 0; j < 10; j++) {
8            putRow.addCell("col" + j, "val" + j);
9        }
10        batchPutRowRequest.addPutRow(putRow);
11    }
12    try {
13        // 批量写入多行数据
14        tableStorageClient.batchPutRow(batchPutRowRequest);
15    } catch (BceClientException e) {
16        return;
17    }
18}

1private static void myDeleteRow(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望删除数据的表的表名
3    DeleteRowRequest deleteRowRequest = new DeleteRowRequest(TABLE_NAME, “rowkey1”);
4    // 指定期望删除的列
5    for (int i = 0; i < 10; i++) {
6        deleteRowRequest.addCell("col" + i);
7    }
8    try {
9        // 删除指定行的数据
10        tableStorageClient.deleteRow(deleteRowRequest);
11    } catch (BceClientException e) {
12        return;
13    }
14}

1private static void myBatchDeleteRow(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望删除数据的表的表名
3    BatchDeleteRowRequest batchDeleteRowRequest = new batchDeleteRowRequest(TABLE_NAME);
4    // 指定期望删除的行和列
5    for (int i = 0; i < 10; i++) {
6        DeleteRow deleteRow = new DeleteRow("rowkey" + i);
7        for (int j = 0; j < 10; j++) {
8            deleteRow.addCell("col" + j);
9        }
10        batchDeleteRowRequest.addDeleteRow(deleteRow);
11    }
12    try {
13        // 批量删除多行数据
14        tableStorageClient.batchDeleteRow(request);
15    } catch (BceClientException e) {
16        return;
17    }
18}

1private static void myGetRow(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望读取数据的表的表名
3    GetRowRequest getRowRequest = new GetRowRequest(TABLE_NAME, rowkey);
4    // 指定随机读取的列和版本数
5    for (int i = 0; i < 10; i++) {
6        getRowRequest.addCell("col" + i);
7    }
8    getRowRequest.setMaxVersions(1);
9    try {
10        // 读取指定行的数据
11        GetRowResponse response = tableStorageClient.getRow(getRowRequest);
12        // 打印随机读结果
13        System.out.println("==================================");
14        System.out.println("GetRowResponse result:");
15        TableStorageResult result = response.getResult();
16        System.out.println("  rowkey=" + result.getRowkey() + ",");
17        for (TableStorageCell cell : result.getCells()) {
18        System.out.println("    column=" + cell.getColumn() + ", value=" + cell.getValue() + ",");
19    }
20        System.out.println("==================================");
21    } catch (BceClientException e) {
22        return;
23    }
24}

1private static void myBatchGetRow(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望读取数据的表的表名
3    BatchGetRowRequest batchGetRowRequest = new BatchGetRowRequest(TABLE_NAME);
4    // 指定随机读的行和列
5    for (int i = 0; i < 10; i++) {
6        GetRow getRow = new GetRow("rowkey" + i);
7        for (int j = 0; j < 10; j++) {
8            getRow.addCell("col" + j);
9        }
10        batchGetRowRequest.addGetRow(getRow);
11    }
12    batchGetRowRequest.setMaxVersions(1);
13    try {
14        // 批量读取多行数据
15        BatchGetRowResponse response = tableStorageClient.batchGetRow(batchGetRowRequest);
16        // 打印随机读结果
17        System.out.println("==================================");
18        System.out.println("BatchGetRowResponse result:");
19        for (TableStorageResult result : response.getResults()) {
20            System.out.println("  result:");
21            System.out.println("    rowkey=" + result.getRowkey() + ",");
22            for (TableStorageCell cell : result.getCells()) {
23                System.out.println("      column=" + cell.getColumn() + ", value=" + cell.getValue() + ",");
24            }
25        }
26        System.out.println("==================================");
27    } catch (BceClientException e) {
28        return;
29    }
30}

1private static void myScan(TableStorageClient client) {
2    // 指定表，其中TABLE_NAME为期望区间读数据的表的表名
3    ScanRequest scanRequest = new ScanRequest(TABLE_NAME);
4    // 指定区间读范围
5    scanRequest.setStartRowkey(rowkey, true);
6    scanRequest.setStopRowkey(rowkey, true);
7    scanRequest.setMaxVersions(1);
8    scanRequest.setLimit(1);
9    // 指定需要读的列
10    for (int i = 0; i < 10; i++) {
11        scanRequest.addCell("col" + i);
12    }
13    try {
14        // 读取指定区间的数据
15        ScanResponse response = tableStorageClient.scan(scanRequest);
16        // 打印区间读结果
17        System.out.println("==================================");
18        System.out.println("ScanResponse result:");
19        for (TableStorageResult result : response.getResults()) {
20            System.out.println("  result:");
21            System.out.println("    rowkey=" + result.getRowkey() + ",");
22            for (TableStorageCell cell : result.getCells()) {
23            System.out.println("      column=" + cell.getColumn() + ", value=" + cell.getValue() + ",");
24            }
25        }
26        System.out.println("==================================");
27    } catch (BceClientException e) {
28        return;
29    }
30}