diff options
| author | Erwin Pe <erwin.pe@mongodb.com> | 2022-04-01 03:15:48 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-04-01 03:43:36 +0000 |
| commit | 5d448b9565c79235d70d9cf47876ef07d615a0a4 (patch) | |
| tree | 1b2da67769efc09fc5223ea49a1290a786f14fcd /src/mongo/db/fle_crud.cpp | |
| parent | 92d12679edfc7018a8695df2035dc5635aea96ac (diff) | |
| download | mongo-5d448b9565c79235d70d9cf47876ef07d615a0a4.tar.gz | |
SERVER-63468 Add support for ESC compaction
Diffstat (limited to 'src/mongo/db/fle_crud.cpp')
| -rw-r--r-- | src/mongo/db/fle_crud.cpp | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/src/mongo/db/fle_crud.cpp b/src/mongo/db/fle_crud.cpp index 34a1c4eb6ec..2451133e2f4 100644 --- a/src/mongo/db/fle_crud.cpp +++ b/src/mongo/db/fle_crud.cpp @@ -112,6 +112,7 @@ boost::optional<BSONObj> mergeLetAndCVariables(const boost::optional<BSONObj>& l return c; } +} // namespace StatusWith<txn_api::CommitResult> runInTxnWithRetry( OperationContext* opCtx, @@ -189,8 +190,6 @@ boost::intrusive_ptr<ExpressionContext> makeExpCtx(OperationContext* opCtx, return expCtx; } -} // namespace - std::pair<FLEBatchResult, write_ops::InsertCommandReply> processInsert( OperationContext* opCtx, const write_ops::InsertCommandRequest& insertRequest, @@ -1209,6 +1208,16 @@ write_ops::FindAndModifyCommandReply FLEQueryInterfaceImpl::findAndModify( return write_ops::FindAndModifyCommandReply::parse(IDLParserErrorContext("reply"), response); } +std::vector<BSONObj> FLEQueryInterfaceImpl::findDocuments(const NamespaceString& nss, + BSONObj filter) { + FindCommandRequest find(nss); + find.setFilter(filter); + find.setSingleBatch(true); + + // Throws on error + return _txnClient.exhaustiveFind(find).get(); +} + void processFLEFindS(OperationContext* opCtx, FindCommandRequest* findCommand) { fle::processFindCommand(opCtx, findCommand, &getTransactionWithRetriesForMongoS); } |