F update

Tests for caosdb-cpplib!6 (merged)

test/test_transaction.cpp

@@ -27,7 +27,6 @@
 #include "gtest/gtest-message.h"       // for Message
 #include "gtest/gtest-test-part.h"     // for TestPartResult, SuiteApiResolver
 #include "gtest/gtest_pred_impl.h"     // for Test, EXPECT_EQ, AssertionResult
-#include <iostream>                    // for endl, basic_ostream, cout
 #include <memory>                      // for unique_ptr, allocator, __shar...
 #include <string>                      // for string
 #include <vector>                      // for vector
@@ -42,7 +41,18 @@ protected:
   void SetUp() override {}
 
   void TearDown() override {
-    // TODO(tf): delete all created entities
+    const auto &connection =
+      caosdb::connection::ConnectionManager::GetDefaultConnection();
+    auto query_transaction(connection->CreateTransaction());
+    query_transaction->Query("FIND ENTITY WITH id > 99");
+    query_transaction->Execute();
+    if (query_transaction->GetResultSet().Size() > 0) {
+      for (const Entity &entity : query_transaction->GetResultSet()) {
+        auto delete_transaction(connection->CreateTransaction());
+        delete_transaction->DeleteById(entity.GetId());
+        delete_transaction->Execute();
+      }
+    }
   }
 };
 
@@ -203,7 +213,6 @@ TEST(test_transaction, insert_delete_with_parent) {
   const auto &retrieve_result_set =
     dynamic_cast<const UniqueResult &>(retrieve_transaction->GetResultSet());
   const auto &retrieved_rec = retrieve_result_set.GetEntity();
-  std::cout << retrieved_rec.ToString() << std::endl;
 
   EXPECT_EQ(retrieved_rec.GetName(), rec.GetName());
   EXPECT_EQ(retrieved_rec.GetParents().Size(), 1);
@@ -415,7 +424,6 @@ TEST(test_transaction, test_multi_retrieve) {
   EXPECT_EQ(result_set.Size(), 3);
   EXPECT_EQ(result_set.At(1).GetId(), "21");
   EXPECT_EQ(result_set.At(1).GetName(), "unit");
-  std::cout << result_set.At(1).ToString();
   EXPECT_FALSE(result_set.At(1).HasErrors());
 
   EXPECT_EQ(result_set.At(2).GetId(), "22");
@@ -424,4 +432,103 @@ TEST(test_transaction, test_multi_retrieve) {
             MessageCode::ENTITY_DOES_NOT_EXIST);
 }
 
+TEST(test_transaction, insert_update_delete) {
+  const auto &connection =
+    caosdb::connection::ConnectionManager::GetDefaultConnection();
+
+  // INSERT
+  auto insert_transaction(connection->CreateTransaction());
+
+  Entity entity;
+  entity.SetRole("RecordType");
+  entity.SetName("RT1");
+  insert_transaction->InsertEntity(&entity);
+  insert_transaction->ExecuteAsynchronously();
+
+  auto insert_status = insert_transaction->WaitForIt();
+
+  ASSERT_TRUE(insert_status.IsTerminated());
+  ASSERT_FALSE(insert_status.IsError());
+
+  const auto &insert_result_set =
+    dynamic_cast<const UniqueResult &>(insert_transaction->GetResultSet());
+
+  const auto &new_entity = insert_result_set.GetEntity();
+  EXPECT_FALSE(new_entity.GetId().empty());
+  EXPECT_FALSE(new_entity.HasErrors());
+
+  // RETRIEVE
+  auto retrieve_transaction(connection->CreateTransaction());
+  retrieve_transaction->RetrieveById(new_entity.GetId());
+  retrieve_transaction->Execute();
+
+  // UPDATE
+  auto update_transaction(connection->CreateTransaction());
+  auto update_entity(retrieve_transaction->GetResultSet().At(0));
+  update_entity.SetName("RT1-Update");
+
+  update_transaction->UpdateEntity(&update_entity);
+  update_transaction->ExecuteAsynchronously();
+
+  auto update_status = update_transaction->WaitForIt();
+  ASSERT_TRUE(update_status.IsTerminated());
+  ASSERT_FALSE(update_status.IsError());
+
+  EXPECT_EQ(update_transaction->GetResultSet().Size(), 1);
+  const auto &updated_entity = update_transaction->GetResultSet().At(0);
+
+  EXPECT_EQ(updated_entity.GetId(), new_entity.GetId());
+  EXPECT_FALSE(updated_entity.HasErrors());
+
+  // DELETE
+  auto delete_transaction(connection->CreateTransaction());
+
+  delete_transaction->DeleteById(new_entity.GetId());
+  delete_transaction->ExecuteAsynchronously();
+
+  auto delete_status = delete_transaction->WaitForIt();
+
+  ASSERT_TRUE(delete_status.IsTerminated());
+  ASSERT_FALSE(delete_status.IsError());
+
+  const auto &delete_result_set =
+    dynamic_cast<const UniqueResult &>(delete_transaction->GetResultSet());
+
+  const auto &deleted_entity = delete_result_set.GetEntity();
+  EXPECT_EQ(deleted_entity.GetId(), new_entity.GetId());
+  EXPECT_FALSE(deleted_entity.HasErrors());
+}
+
+TEST(test_transaction, test_query) {
+  const auto &connection =
+    caosdb::connection::ConnectionManager::GetDefaultConnection();
+
+  auto insert_transaction(connection->CreateTransaction());
+
+  Entity entity;
+  entity.SetRole("RecordType");
+  entity.SetName("RT1");
+  insert_transaction->InsertEntity(&entity);
+  insert_transaction->ExecuteAsynchronously();
+
+  auto insert_status = insert_transaction->WaitForIt();
+
+  ASSERT_TRUE(insert_status.IsTerminated());
+  ASSERT_FALSE(insert_status.IsError());
+
+  const auto &insert_result_set =
+    dynamic_cast<const UniqueResult &>(insert_transaction->GetResultSet());
+
+  const auto &new_entity = insert_result_set.GetEntity();
+  EXPECT_FALSE(new_entity.GetId().empty());
+  EXPECT_FALSE(new_entity.HasErrors());
+
+  auto query_transaction(connection->CreateTransaction());
+  query_transaction->Query("FIND ENTITY WITH id = " + new_entity.GetId());
+  query_transaction->Execute();
+  EXPECT_EQ(query_transaction->GetResultSet().Size(), 1);
+  EXPECT_EQ(query_transaction->GetResultSet().At(0).GetId(),
+            new_entity.GetId());
+}
+
 } // namespace caosdb::transaction