Skip to content
Snippets Groups Projects
Verified Commit 636ca477 authored by Timm Fitschen's avatar Timm Fitschen
Browse files

WIP: inser delete

parent 81d01222
No related branches found
No related tags found
1 merge request!4ENH: Allow insertion and deletion of single entities
Pipeline #10919 passed
Pipeline: caosdb-cppinttest

#10920

    ...@@ -65,7 +65,7 @@ private: ...@@ -65,7 +65,7 @@ private:
    class Transaction { class Transaction {
    private: private:
    mutable std::unique_ptr<ResultSet> result_set; mutable std::unique_ptr<ResultSet> result_set;
    TransactionStatus status = TransactionStatus::INITIAL(); mutable TransactionStatus status = TransactionStatus::INITIAL();
    std::shared_ptr<EntityTransactionService::Stub> service_stub; std::shared_ptr<EntityTransactionService::Stub> service_stub;
    MultiTransactionRequest *request; MultiTransactionRequest *request;
    mutable MultiTransactionResponse *response; mutable MultiTransactionResponse *response;
    ......
    ...@@ -206,24 +206,24 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus { ...@@ -206,24 +206,24 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus {
    case WrappedResponseCase::kRetrieveResponse: { case WrappedResponseCase::kRetrieveResponse: {
    auto *entity = responses->mutable_retrieve_response()->release_entity(); auto *entity = responses->mutable_retrieve_response()->release_entity();
    if (!entity->errors().empty()) { if (!entity->errors().empty()) {
    this->status = this->status = TransactionStatus::TRANSACTION_ERROR(
    TransactionStatus::TRANSACTION_ERROR("The request returned with errors."); "The request returned with errors.");
    } }
    this->result_set = std::make_unique<UniqueResult>(entity); this->result_set = std::make_unique<UniqueResult>(entity);
    } break; } break;
    case WrappedResponseCase::kInsertResponse: { case WrappedResponseCase::kInsertResponse: {
    auto *insertedIdResponse = responses->mutable_insert_response(); auto *insertedIdResponse = responses->mutable_insert_response();
    if (!insertedIdResponse->entity_errors().empty()) { if (!insertedIdResponse->entity_errors().empty()) {
    this->status = this->status = TransactionStatus::TRANSACTION_ERROR(
    TransactionStatus::TRANSACTION_ERROR("The request returned with errors."); "The request returned with errors.");
    } }
    this->result_set = std::make_unique<UniqueResult>(insertedIdResponse); this->result_set = std::make_unique<UniqueResult>(insertedIdResponse);
    } break; } break;
    case WrappedResponseCase::kDeleteResponse: { case WrappedResponseCase::kDeleteResponse: {
    auto *deletedIdResponse = responses->mutable_delete_response(); auto *deletedIdResponse = responses->mutable_delete_response();
    if (!deletedIdResponse->entity_errors().empty()) { if (!deletedIdResponse->entity_errors().empty()) {
    this->status = this->status = TransactionStatus::TRANSACTION_ERROR(
    TransactionStatus::TRANSACTION_ERROR("The request returned with errors."); "The request returned with errors.");
    } }
    this->result_set = std::make_unique<UniqueResult>(deletedIdResponse); this->result_set = std::make_unique<UniqueResult>(deletedIdResponse);
    } break; } break;
    ......
    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