1
0
Fork 0

Fixed remove

This commit is contained in:
Simon Grätzer 2017-04-28 16:50:40 +02:00
parent db26fe0061
commit 506e56aa72
1 changed files with 4 additions and 3 deletions

View File

@ -316,14 +316,15 @@ void RocksDBTransactionState::prepareOperation(
}
case TRI_VOC_DOCUMENT_OPERATION_REMOVE: {
if (singleOp) {
RocksDBLogValue logValue = RocksDBLogValue::SinglePut(_vocbase->id(),
collectionId);
TRI_ASSERT(!key.empty());
RocksDBLogValue logValue = RocksDBLogValue::SingleRemove(_vocbase->id(),
collectionId,
key);
_rocksTransaction->PutLogData(logValue.slice());
} else {
RocksDBLogValue logValue =
RocksDBLogValue::DocumentOpsPrologue(collectionId);
_rocksTransaction->PutLogData(logValue.slice());
}
} break;
case TRI_VOC_DOCUMENT_OPERATION_UNKNOWN: