Skip to content
Snippets Groups Projects
Commit 6f470c60 authored by florian's avatar florian
Browse files

ENH: Add switch for type of retrieve response

parent d5818c16
No related branches found
No related tags found
1 merge request!7ENH: Support FIND and COUNT queries
Pipeline #11562 canceled
...@@ -405,7 +405,7 @@ private: ...@@ -405,7 +405,7 @@ private:
MultiTransactionRequest *request; MultiTransactionRequest *request;
mutable MultiTransactionResponse *response; mutable MultiTransactionResponse *response;
std::string error_message; std::string error_message;
int query_count; mutable long query_count;
}; };
template <class InputIterator> template <class InputIterator>
......
...@@ -96,6 +96,8 @@ using caosdb::entity::v1alpha1::MultiTransactionRequest; ...@@ -96,6 +96,8 @@ using caosdb::entity::v1alpha1::MultiTransactionRequest;
using caosdb::entity::v1alpha1::MultiTransactionResponse; using caosdb::entity::v1alpha1::MultiTransactionResponse;
using WrappedResponseCase = using WrappedResponseCase =
caosdb::entity::v1alpha1::TransactionResponse::WrappedResponseCase; caosdb::entity::v1alpha1::TransactionResponse::WrappedResponseCase;
using QueryResponseCase =
caosdb::entity::v1alpha1::RetrieveResponse::QueryResponseCase;
using caosdb::utility::get_arena; using caosdb::utility::get_arena;
using grpc::ClientAsyncResponseReader; using grpc::ClientAsyncResponseReader;
using ProtoEntity = caosdb::entity::v1alpha1::Entity; using ProtoEntity = caosdb::entity::v1alpha1::Entity;
...@@ -303,12 +305,26 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus { ...@@ -303,12 +305,26 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus {
auto *responses = this->response->mutable_responses(0); auto *responses = this->response->mutable_responses(0);
switch (responses->wrapped_response_case()) { switch (responses->wrapped_response_case()) {
case WrappedResponseCase::kRetrieveResponse: { case WrappedResponseCase::kRetrieveResponse: {
auto *entity = responses->mutable_retrieve_response()->release_entity(); auto *retrieve_response = responses->mutable_retrieve_response();
if (!entity->errors().empty()) { switch (retrieve_response->query_response_case()) {
this->status = TransactionStatus::TRANSACTION_ERROR( case QueryResponseCase::kEntity: {
"The request returned with errors."); auto *entity = retrieve_response->release_entity();
if (!entity->errors().empty()) {
this->status = TransactionStatus::TRANSACTION_ERROR(
"The request returned with errors.");
}
this->result_set = std::make_unique<UniqueResult>(entity);
} break;
case QueryResponseCase::kSelectResult: {
// TODO(tf) Select queries
} break;
case QueryResponseCase::kCountResult: {
this->query_count = retrieve_response->count_result();
} break;
default:
// TODO(tf) Error
break;
} }
this->result_set = std::make_unique<UniqueResult>(entity);
} break; } break;
case WrappedResponseCase::kUpdateResponse: { case WrappedResponseCase::kUpdateResponse: {
auto *updatedIdResponse = responses->mutable_update_response(); auto *updatedIdResponse = responses->mutable_update_response();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment