has one progress

source/orm/query/basic_schema.cpp

@@ -145,6 +145,10 @@ const std::unordered_map<object::collection_composite_key, std::unique_ptr<sql::
   return collection_resolver_producers_;
 }
 
+const std::unordered_map<object::collection_composite_key, std::unique_ptr<sql::object_resolver_producer>, object::collection_composite_key_hash>& basic_schema::joined_object_resolver_producers() const {
+  return joined_object_resolver_producers_;
+}
+
 namespace detail {
 utils::result<void, utils::error> create_tables(const object::repository &repo, const sql::connection &conn) {
   for (const auto &node: repo) {

source/orm/query/session.cpp

@@ -93,6 +93,23 @@ session::session(session_context&& ctx, const basic_schema &scm)
     }
   }
 
+  for (const auto &pair : schema_.joined_object_resolver_producers()) {
+    auto res = pair.second->build_query(dialect_).and_then([this](sql::query_context&& query_ctx) -> result<sql::statement, error> {
+      query_ctx.resolver = resolver_service_;
+      return cache_.acquire(query_ctx);
+    }).and_then([&pair, this](sql::statement&& stmt) -> result<void, error> {
+      resolver_service_->register_collection_resolver(pair.second->produce(std::move(stmt), *resolver_service_));
+
+      return ok<void>();
+    }).or_else([](const auto &err) {
+      return failure(err);
+    });
+
+    if (!res) {
+      throw std::runtime_error(res.err().message());
+    }
+  }
+
   for (const auto &pair : schema_.collection_resolver_producers()) {
     auto res = pair.second->build_query(dialect_).and_then([this](sql::query_context&& query_ctx) -> result<sql::statement, error> {
       query_ctx.resolver = resolver_service_;