Repositories » Reading Aggregates
Repositories have a powerful API for composing data into nested structures, which we call aggregates, where the root is constructed from the data provided by the root relation, and additional relations provide data for child nodes.
This document uses
rom-sql which provides support for defining canonical database
associations in relation schemas, which are used to simplify reading aggregates.
First, we want to define our canonical associations. We call them canonical since they are defined by your database schema. It's common to diverge from canonical associations and compose data in different ways, depending on your application needs; however, in the early days of every project, using canonical associations is all you need, so let's start with that!
We're going to define
:users that have many
:tasks. To keep things simpler
let's define relations using block-style setup:
require 'rom' rom = ROM.container(:sql, 'sqlite::memory') do |conf| conf.default.create_table(:users) do primary_key :id column :name, String, null: false column :email, String, null: false end conf.default.create_table(:tasks) do primary_key :id foreign_key :user_id, :users column :title, String, null: false end conf.relation(:users) do schema(infer: true) do associations do has_many :tasks end end end conf.relation(:tasks) do schema(infer: true) do associations do belongs_to :user end end end end
With associations defined in the relation schemas we established common queries that will be automatically used for composing relations into aggregates. Let's see how we can leverage that in repositories.
Let's say we'd like to expose an aggregate where a user is loaded with its tasks.
We need to define a root repository with
:users set up as the root and provide
class UserRepo < ROM::Repository[:users] def user_with_tasks users.combine(:tasks) end end
Now loading an aggregate is as simple as this:
user_repo = UserRepo.new(rom) user_repo.user_with_tasks.one # => #<ROM::Struct[User] id=1 name="jane" email="email@example.com" tasks=[#<ROM::Struct[Task] id=1 user_id=1 title="Jane Task">]>
We can do the other way around, starting with
:tasks relation as the root, which
means we're going to load a task with its user:
class TaskRepo < ROM::Repository[:tasks] def tasks_with_assignee tasks.combine(:user) end end task_repo = TaskRepo.new(rom) task_repo.tasks_with_assignee.one # => #<ROM::Struct[Task] id=1 user_id=1 title="Jane Task" user=#<ROM::Struct[User] id=1 name="jane" email="firstname.lastname@example.org" task_id=1>>
Notice that in this case
User struct is loaded as a child object where
is a parent, thus
task_id assigned, which is a virtual foreign key
that doesn't really exist in our schema.
Loading aggregates with repositories can be achieved in many different ways, for detailed information about invidual methods please refer to the API documentation: