sascha
/
query
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

reactivated relation_completer

This commit is contained in:
Sascha Kühl 2025-12-12 08:49:40 +01:00
parent 79c46bbd38
commit 758ea96ea4
3 changed files with 76 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
include/matador/object/foreign_node_completer.hpp
View File

@ -194,30 +194,31 @@ void foreign_node_completer<NodeType>::on_has_many(const char * /*id*/,
template<typename NodeType> template<typename NodeType>
template<class CollectionType> template<class CollectionType>
void foreign_node_completer<NodeType>::on_has_many_to_many(const char *id, CollectionType & /*collection*/, void foreign_node_completer<NodeType>::on_has_many_to_many(const char * /*id*/,
const char *join_column, CollectionType & /*collection*/,
const char *inverse_join_column, const char * /*join_column*/,
const char * /*inverse_join_column*/,
const utils::foreign_attributes & /*attr*/) { const utils::foreign_attributes & /*attr*/) {
if (!repo_.expecting_relation_node(id)) { // if (!repo_.expecting_relation_node(id)) {
repo_.expect_relation_node(id, typeid(typename CollectionType::value_type::value_type)); // repo_.expect_relation_node(id, typeid(typename CollectionType::value_type::value_type));
} else { // } else {
attach_relation_node<typename CollectionType::value_type::value_type>(id, join_column, inverse_join_column); // attach_relation_node<typename CollectionType::value_type::value_type>(id, join_column, inverse_join_column);
repo_.remove_expected_relation_node(id); // repo_.remove_expected_relation_node(id);
} // }
} }
template<typename NodeType> template<typename NodeType>
template<class CollectionType> template<class CollectionType>
void foreign_node_completer<NodeType>::on_has_many_to_many(const char *id, void foreign_node_completer<NodeType>::on_has_many_to_many(const char * /*id*/,
CollectionType & /*collection*/, CollectionType & /*collection*/,
const utils::foreign_attributes & /*attr*/) { const utils::foreign_attributes & /*attr*/) {
if (!repo_.expecting_relation_node(id)) { // if (!repo_.expecting_relation_node(id)) {
repo_.expect_relation_node(id, typeid(typename CollectionType::value_type::value_type)); // repo_.expect_relation_node(id, typeid(typename CollectionType::value_type::value_type));
} else { // } else {
const auto join_columns = join_columns_collector_.collect<typename CollectionType::value_type::value_type>(); // const auto join_columns = join_columns_collector_.collect<typename CollectionType::value_type::value_type>();
attach_relation_node<typename CollectionType::value_type::value_type>(id, join_columns.join_column, join_columns.inverse_join_column); // attach_relation_node<typename CollectionType::value_type::value_type>(id, join_columns.join_column, join_columns.inverse_join_column);
repo_.remove_expected_relation_node(id); // repo_.remove_expected_relation_node(id);
} // }
} }
template<typename NodeType> template<typename NodeType>

97
include/matador/object/relation_completer.hpp
View File

@ -2,6 +2,7 @@
#define RELATION_COMPLETER_HPP #define RELATION_COMPLETER_HPP
#include "matador/object/internal/shadow_repository.hpp" #include "matador/object/internal/shadow_repository.hpp"
#include "matador/object/foreign_node_completer.hpp"
#include "matador/object/many_to_many_relation.hpp" #include "matador/object/many_to_many_relation.hpp"
#include "matador/object/join_columns_collector.hpp" #include "matador/object/join_columns_collector.hpp"
#include "matador/object/object_ptr.hpp" #include "matador/object/object_ptr.hpp"
@ -143,6 +144,9 @@ private:
nodes_.pop(); nodes_.pop();
} }
template<typename NodeType>
void attach_relation_node(const std::string &name, const std::string &join_column, const std::string &inverse_join_column);
static void register_relation_endpoints(const endpoint_ptr &endpoint, static void register_relation_endpoints(const endpoint_ptr &endpoint,
const endpoint_ptr &other_endpoint); const endpoint_ptr &other_endpoint);
static void link_relation_endpoints(const endpoint_ptr &endpoint, static void link_relation_endpoints(const endpoint_ptr &endpoint,
@ -244,47 +248,12 @@ void relation_completer<Type>::on_has_many_to_many(const char *id,
const char *join_column, const char *join_column,
const char *inverse_join_column, const char *inverse_join_column,
const utils::foreign_attributes &/*attr*/) { const utils::foreign_attributes &/*attr*/) {
using relation_value_type = many_to_many_relation<typename CollectionType::value_type::value_type, Type>; if (!schema_.expecting_relation_node(id)) {
using value_type = typename CollectionType::value_type::value_type; schema_.expect_relation_node(id, typeid(typename CollectionType::value_type::value_type));
} else {
// Check if the object_ptr type is already inserted in the schema (by id) attach_relation_node<typename CollectionType::value_type::value_type>(id, join_column, inverse_join_column);
auto result = schema_.find_node(typeid(value_type)); schema_.remove_expected_relation_node(id);
if (!result) {
// Todo: throw internal error or attach node
return;
} }
const auto foreign_node = result.value();
result = schema_.find_node(id);
if (result) {
return;
}
// Relation not found.
auto creator = [join_column, inverse_join_column] {
return std::make_unique<relation_value_type>(join_column, inverse_join_column);
};
auto node = repository_node::make_node<relation_value_type>(schema_.repo(), id, std::move(creator));
result = schema_.attach_node(node);
if (!result) {
// Todo: throw internal error
return;
}
const auto local_endpoint = std::make_shared<relation_endpoint>(id, relation_type::HasMany, node);
const auto join_endpoint = std::make_shared<relation_endpoint>(join_column, relation_type::BelongsTo, nodes_.top());
const auto inverse_join_endpoint = std::make_shared<relation_endpoint>(inverse_join_column, relation_type::BelongsTo, foreign_node);
const auto foreign_endpoint = std::make_shared<relation_endpoint>(id, relation_type::HasMany, node);
// register relation endpoint in local node
nodes_.top()->info_->register_relation_endpoint(typeid(typename CollectionType::value_type::value_type), local_endpoint);
// register relation endpoint in foreign node
foreign_node->info_->register_relation_endpoint(nodes_.top()->type_index(), foreign_endpoint);
// register endpoints in relation node
node->info_->register_relation_endpoint(nodes_.top()->type_index(), join_endpoint);
node->info_->register_relation_endpoint(typeid(typename CollectionType::value_type::value_type), inverse_join_endpoint);
// link endpoints
link_relation_endpoints(local_endpoint, join_endpoint);
link_relation_endpoints(foreign_endpoint, inverse_join_endpoint);
} }
template<typename Type> template<typename Type>
@ -372,6 +341,54 @@ void relation_completer<Type>::on_belongs_to(const char *id,
} }
} }
template<typename Type>
template<typename NodeType>
void relation_completer<Type>::attach_relation_node(const std::string &name, const std::string &join_column, const std::string &inverse_join_column) {
using relation_value_type = many_to_many_relation<NodeType, Type>;
using value_type = NodeType;
// Check if the object_ptr type is already inserted in the schema (by id)
auto result = schema_.find_node(typeid(value_type));
if (!result) {
// Todo: throw internal error or attach node
return;
}
const auto foreign_node = result.value();
result = schema_.find_node(name);
if (result) {
return;
}
// Relation does not exist. Create it.
auto creator = [join_column, inverse_join_column] {
return std::make_unique<relation_value_type>(join_column, inverse_join_column);
};
auto node = repository_node::make_node<relation_value_type>(schema_.repo(), name, std::move(creator));
result = schema_.attach_node(node);
if (!result) {
// Todo: throw internal error
return;
}
foreign_node_completer<Type>::template complete<relation_value_type>(result.value());
const auto local_endpoint = std::make_shared<relation_endpoint>(name, relation_type::HasMany, node);
const auto join_endpoint = std::make_shared<relation_endpoint>(join_column, relation_type::BelongsTo, nodes_.top());
const auto inverse_join_endpoint = std::make_shared<relation_endpoint>(inverse_join_column, relation_type::BelongsTo, foreign_node);
const auto foreign_endpoint = std::make_shared<relation_endpoint>(name, relation_type::HasMany, node);
// register relation endpoint in local node
nodes_.top()->info_->register_relation_endpoint(typeid(value_type), local_endpoint);
// register relation endpoint in foreign node
foreign_node->info_->register_relation_endpoint(nodes_.top()->type_index(), foreign_endpoint);
// register endpoints in relation node
node->info_->register_relation_endpoint(nodes_.top()->type_index(), join_endpoint);
node->info_->register_relation_endpoint(typeid(value_type), inverse_join_endpoint);
// link endpoints
link_relation_endpoints(local_endpoint, join_endpoint);
link_relation_endpoints(foreign_endpoint, inverse_join_endpoint);
}
template<typename Type> template<typename Type>
void relation_completer<Type>::register_relation_endpoints(const endpoint_ptr &endpoint, void relation_completer<Type>::register_relation_endpoints(const endpoint_ptr &endpoint,
const endpoint_ptr &other_endpoint) { const endpoint_ptr &other_endpoint) {

2
include/matador/object/repository.hpp
View File

@ -46,7 +46,7 @@ public:
return utils::failure(result.err()); return utils::failure(result.err());
} }
foreign_node_completer<Type>::template complete<Type>(node); foreign_node_completer<Type>::template complete<Type>(node);
// relation_completer<Type>::complete(node); relation_completer<Type>::complete(node);
} else if (!has_node(name)) { } else if (!has_node(name)) {
it->second->update_name(name); it->second->update_name(name);
nodes_by_name_[name] = it->second; nodes_by_name_[name] = it->second;