批量操作
BatchResult batch(BatchRequest request)
功能
批量读写操作,消耗各自对应的读写配额。同一个batch中多个操作修改同一行数据可能导致未定义行为(数据不一致),
应当避免,另外如果一个batch包含同一行的读和写操作,其执行顺序是不确定的,不推荐使用
另外,要注意以下两点:
1.同一个batch里的子操作不保证顺序
2.batch操作不保证原子性,当返回成功即所有子操作都成功,如果返回异常,有可能部分成功部分失败
方法参数
request : BatchRequest : required
BatchRequest 包括一个可以为PutRequest, RemoveRequest, GetRequest, IncrementRequest的列表
1.items : List< BatchRequestItem > : required
BatchRequestItem包括BatchOp和Request
枚举类型BatchOp(PUT, GET, REMOVE, INCREMENT)指定该request的操作类型,
相应的,使用putRequest,getRequest, removeRequest,incrementRequest构造Request参数
方法返回值
batchResult : BatchResult
BatchResult 包括一个带有BatchResultItem的列表,表示batch的每个请求的执行结果
items : List< BatchResultItem >
返回每个子操作的结果
异常错误码
INTERNAL_ERROR(1) : 服务器异常
ACCESS_DENIED(4) : 用户对该表没有读权限
VALIDATION_FAILED(5): batchRequest中的request参数设置错误
THROUGHPUT_EXCEED(8): 当前读写速度已超过该表的读写配额
RESOURCE_NOT_FOUND(9) : 所指定的表不存在
限制
每个子操作必须是同一个表的
put,remove请求不支持带条件
batch操作的子操作数范围为[ 1, 100 ]
示例
以示例表为例,下面给出批量操作的示例代码
$categories = array("work", "travel", "food");
$tableName = 'php-note';
$batch = array();
for ($i = 0; $i < 20; $i++) {
$version = 0; // initial version
$insert = new PutRequest(array(
"tableName" => $tableName,
"record" => Array(
"userId" => DatumUtil::datum("user1"),
"noteId" => DatumUtil::datum($i),
"title" => DatumUtil::datum("Title $i"),
"content" => DatumUtil::datum("note $i"),
"version" => DatumUtil::datum($version),
"mtime" => DatumUtil::datum((new \DateTime())->getTimestamp()),
"category" => DatumUtil::datum($categories[rand(0, sizeof($categories) - 1)]),
)));
$batchItem = new BatchRequestItem(array(
"action" => BatchOp::PUT,
"request" => new Request(array(
"putRequest" => $insert
))
));
$batch[$i] = $batchItem;
}
$batchRequest = new BatchRequest(array(
"items" => $batch
));
$tableClient->batch($batchRequest);