Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Added a reset function to OperationCursor. ALso added a switch to getMore to define that all documents are referenced as Externals instead of inplace

This commit is contained in:
Michael Hackstein 2016-03-01 16:37:21 +01:00
parent 03dbc4a745
commit 922a96fee0
2 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
arangod/Utils/OperationCursor.cpp
View File

@ -25,6 +25,11 @@
using namespace arangodb;
void OperationCursor::reset() {
_indexIterator->reset();
}
//////////////////////////////////////////////////////////////////////////////
/// @brief Get next default batchSize many elements.
/// Check hasMore()==true before using this
@ -38,10 +43,12 @@ int OperationCursor::getMore() {
//////////////////////////////////////////////////////////////////////////////
/// @brief Get next batchSize many elements.
/// Check hasMore()==true before using this
/// If useExternals is set to true all elements in the vpack are
/// externals. Otherwise they are inlined.
/// NOTE: This will throw on OUT_OF_MEMORY
//////////////////////////////////////////////////////////////////////////////
int OperationCursor::getMore(uint64_t batchSize) {
int OperationCursor::getMore(uint64_t batchSize, bool useExternals) {
// This may throw out of memory
if (!hasMore()) {
TRI_ASSERT(false);
@ -56,7 +63,11 @@ int OperationCursor::getMore(uint64_t batchSize) {
while (batchSize > 0 && _limit > 0 && (mptr = _indexIterator->next()) != nullptr) {
--batchSize;
--_limit;
_builder.add(VPackSlice(mptr->vpack()));
if (useExternals) {
_builder.add(VPackValue(mptr->vpack(), VPackValueType::External));
} else {
_builder.add(VPackSlice(mptr->vpack()));
}
}
if (batchSize > 0 || _limit == 0) {
// Iterator empty, there is no more

8
arangod/Utils/OperationCursor.h
View File

@ -94,13 +94,19 @@ struct OperationCursor : public OperationResult {
return _hasMore;
}
//////////////////////////////////////////////////////////////////////////////
/// @brief Reset the cursor
//////////////////////////////////////////////////////////////////////////////
void reset();
//////////////////////////////////////////////////////////////////////////////
/// @brief Get next batchSize many elements.
/// Check hasMore()==true before using this
/// NOTE: This will throw on OUT_OF_MEMORY
//////////////////////////////////////////////////////////////////////////////
int getMore(uint64_t);
int getMore(uint64_t, bool useExternals = false);
//////////////////////////////////////////////////////////////////////////////
/// @brief Get next default batchSize many elements.