import com.amazonaws.services.dynamodbv2.model.PutItemRequest; //導(dǎo)入方法依賴的package包/類

public List reindex(T instance) throws DataStoreException {

DynamoClassMapping tableInfo = getClassMapping(instance);

log.debug("reindex {}", instance.getClass().getSimpleName());

ScanRequest scanRequest = new ScanRequest();

scanRequest.setTableName(tableInfo.getDynamoTableName());

// TODO: Filter expressions on prefix?

ScanResult scanResponse = dynamoDB.scan(scanRequest);

Map lastEvaluatedKey = scanResponse.getLastEvaluatedKey();

if (lastEvaluatedKey != null) {

throw new UnsupportedOperationException("Multiple page results not implemented");

}

List items = Lists.newArrayList();

List> responseItems = scanResponse.getItems();

for (Map itemData : responseItems) {

if (!tableInfo.matchesType(itemData)) {

continue;

}

T item = tableInfo.mapFromDb(itemData);

Map newItemData = tableInfo.mapToDb(item);

if (DynamoDbHelpers.areEqual(itemData, newItemData)) {

log.debug("No change for item: {}", itemData);

continue;

}

PutItemRequest putRequest = new PutItemRequest();

putRequest.setTableName(tableInfo.getDynamoTableName());

putRequest.setItem(itemData);

dynamoDB.putItem(putRequest);

Map oldKey = extractKey(itemData);

Map newKey = extractKey(newItemData);

if (!DynamoDbHelpers.areEqual(oldKey, newKey)) {

DeleteItemRequest deleteItemRequest = new DeleteItemRequest();

deleteItemRequest.setTableName(tableInfo.getDynamoTableName());

deleteItemRequest.setKey(oldKey);

dynamoDB.deleteItem(deleteItemRequest);

}

}

return items;

}

總結(jié)

以上是生活随笔為你收集整理的java put set_Java PutItemRequest.setItem方法代码示例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。