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

TST: mixed-write transactions

parent 303ac11e
No related branches found
No related tags found
1 merge request!17F mixed write transactions
Pipeline #13889 passed
...@@ -895,7 +895,6 @@ TEST_F(test_transaction, test_multi_write_transactions) { ...@@ -895,7 +895,6 @@ TEST_F(test_transaction, test_multi_write_transactions) {
insert_transaction->InsertEntity(&entity_a); insert_transaction->InsertEntity(&entity_a);
insert_transaction->InsertEntity(&entity_b); insert_transaction->InsertEntity(&entity_b);
insert_transaction->ExecuteAsynchronously(); insert_transaction->ExecuteAsynchronously();
EXPECT_EQ("", insert_transaction->ResponseToString());
insert_transaction->WaitForIt(); insert_transaction->WaitForIt();
ASSERT_TRUE(insert_transaction->GetStatus().IsTerminated()); ASSERT_TRUE(insert_transaction->GetStatus().IsTerminated());
ASSERT_FALSE(insert_transaction->GetStatus().IsError()); ASSERT_FALSE(insert_transaction->GetStatus().IsError());
...@@ -913,7 +912,6 @@ TEST_F(test_transaction, test_multi_write_transactions) { ...@@ -913,7 +912,6 @@ TEST_F(test_transaction, test_multi_write_transactions) {
reference_c.SetName("RTC"); reference_c.SetName("RTC");
Entity entity_a_update(retrieve_transaction->GetResultSet().at(0)); Entity entity_a_update(retrieve_transaction->GetResultSet().at(0));
EXPECT_EQ("", entity_a_update.ToString());
entity_a_update.RemoveProperty(0); entity_a_update.RemoveProperty(0);
entity_a_update.AppendProperty(reference_c); entity_a_update.AppendProperty(reference_c);
...@@ -923,7 +921,6 @@ TEST_F(test_transaction, test_multi_write_transactions) { ...@@ -923,7 +921,6 @@ TEST_F(test_transaction, test_multi_write_transactions) {
ASSERT_EQ(complex_transaction->UpdateEntity(&entity_a_update), ASSERT_EQ(complex_transaction->UpdateEntity(&entity_a_update),
StatusCode::GO_ON); StatusCode::GO_ON);
complex_transaction->ExecuteAsynchronously(); complex_transaction->ExecuteAsynchronously();
EXPECT_EQ("", complex_transaction->ResponseToString());
complex_transaction->WaitForIt(); complex_transaction->WaitForIt();
EXPECT_TRUE(complex_transaction->GetStatus().IsTerminated()); EXPECT_TRUE(complex_transaction->GetStatus().IsTerminated());
...@@ -934,9 +931,10 @@ TEST_F(test_transaction, test_multi_write_transactions) { ...@@ -934,9 +931,10 @@ TEST_F(test_transaction, test_multi_write_transactions) {
ASSERT_EQ(retrieve_transaction->RetrieveById(entity_a_update.GetId()), ASSERT_EQ(retrieve_transaction->RetrieveById(entity_a_update.GetId()),
StatusCode::GO_ON); StatusCode::GO_ON);
retrieve_transaction->ExecuteAsynchronously(); retrieve_transaction->ExecuteAsynchronously();
EXPECT_EQ("", retrieve_transaction->ResponseToString());
retrieve_transaction->WaitForIt(); retrieve_transaction->WaitForIt();
EXPECT_EQ("", retrieve_transaction->GetResultSet().at(0).ToString());
const auto &final_entity = retrieve_transaction->GetResultSet().at(0);
EXPECT_EQ("RTC", final_entity.GetProperties().at(0).GetName());
} }
/* /*
......
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