Skip to content
Snippets Groups Projects

TST: Add Tests for insert and delete

Merged Florian Spreckelsen requested to merge f-insert into dev
All threads resolved!

Files

+ 85
5
@@ -28,10 +28,21 @@
@@ -28,10 +28,21 @@
#include "gtest/gtest-test-part.h" // for TestPartResult, SuiteApiResolver
#include "gtest/gtest-test-part.h" // for TestPartResult, SuiteApiResolver
#include "gtest/gtest_pred_impl.h" // for Test, EXPECT_EQ, AssertionResult
#include "gtest/gtest_pred_impl.h" // for Test, EXPECT_EQ, AssertionResult
#include <memory> // for unique_ptr, allocator, __shar...
#include <memory> // for unique_ptr, allocator, __shar...
 
#include <string> // for string
namespace caosdb::transaction {
namespace caosdb::transaction {
 
using caosdb::entity::Entity;
using caosdb::entity::MessageCode;
using caosdb::entity::MessageCode;
 
class test_transaction : public ::testing::Test {
 
protected:
 
void SetUp() override {}
 
 
void TearDown() override {
 
// TODO(tf): delete all created entities
 
}
 
};
 
TEST(test_transaction, DISABLED_retrieve_manufacturer_by_id) {
TEST(test_transaction, DISABLED_retrieve_manufacturer_by_id) {
const auto &connection =
const auto &connection =
caosdb::connection::ConnectionManager::GetDefaultConnection();
caosdb::connection::ConnectionManager::GetDefaultConnection();
@@ -47,15 +58,14 @@ TEST(test_transaction, DISABLED_retrieve_manufacturer_by_id) {
@@ -47,15 +58,14 @@ TEST(test_transaction, DISABLED_retrieve_manufacturer_by_id) {
transaction->Execute();
transaction->Execute();
const auto &result_set =
const auto &result_set =
dynamic_cast<const caosdb::transaction::UniqueResult &>(
dynamic_cast<const UniqueResult &>(transaction->GetResultSet());
transaction->GetResultSet());
const auto &entity = result_set.GetEntity();
const auto &entity = result_set.GetEntity();
EXPECT_EQ(id, entity.GetId());
EXPECT_EQ(id, entity.GetId());
EXPECT_EQ(name, entity.GetName());
EXPECT_EQ(name, entity.GetName());
EXPECT_EQ(role, entity.GetRole());
EXPECT_EQ(role, entity.GetRole());
EXPECT_EQ(description, entity.GetDescription());
EXPECT_EQ(description, entity.GetDescription());
EXPECT_EQ(version, entity.GetVersion());
EXPECT_EQ(version, entity.GetVersionId());
}
}
TEST(test_transaction, retrieve_non_existing) {
TEST(test_transaction, retrieve_non_existing) {
@@ -73,8 +83,7 @@ TEST(test_transaction, retrieve_non_existing) {
@@ -73,8 +83,7 @@ TEST(test_transaction, retrieve_non_existing) {
ASSERT_EQ(status.GetCode(), StatusCode::GENERIC_TRANSACTION_ERROR);
ASSERT_EQ(status.GetCode(), StatusCode::GENERIC_TRANSACTION_ERROR);
const auto &result_set =
const auto &result_set =
dynamic_cast<const caosdb::transaction::UniqueResult &>(
dynamic_cast<const UniqueResult &>(transaction->GetResultSet());
transaction->GetResultSet());
const auto &entity = result_set.GetEntity();
const auto &entity = result_set.GetEntity();
EXPECT_EQ(id, entity.GetId());
EXPECT_EQ(id, entity.GetId());
@@ -84,4 +93,75 @@ TEST(test_transaction, retrieve_non_existing) {
@@ -84,4 +93,75 @@ TEST(test_transaction, retrieve_non_existing) {
MessageCode::ENTITY_DOES_NOT_EXIST);
MessageCode::ENTITY_DOES_NOT_EXIST);
}
}
 
TEST(test_transaction, insert_delete) {
 
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());
 
// Should have a warning since it has no properties
 
EXPECT_TRUE(new_entity.HasWarnings());
 
EXPECT_EQ(new_entity.GetWarnings().Size(), 1);
 
EXPECT_EQ(new_entity.GetWarnings().At(0).GetCode(),
 
MessageCode::ENTITY_HAS_NO_PROPERTIES);
 
 
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());
 
}
 
 
// TODO(fspreck) Insert an RT and a Record of this type, check
 
// whether this is reflected correctly in the inserted Record, then
 
// delete everything.
 
TEST(test_transaction, insert_delete_with_parent) {
 
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());
 
}
 
 
// TODO(fspreck) Insert a Record with a parent and a Property. Check
 
// for success and delete everything.
 
} // namespace caosdb::transaction
} // namespace caosdb::transaction
Loading