AMHOL/repo_test.rb

## repo_test.rb
require 'bundler/inline'

gemfile(true) do
  source 'https://rubygems.org'
  gem 'rom', github: 'rom-rb/rom'
  gem 'rom-sql', github: 'rom-rb/rom-sql'
  gem 'rom-repository', github: 'rom-rb/rom-repository'
  gem 'sqlite3'
end

config = ROM::Configuration.new(:sql, 'sqlite::memory')

gateway = config.gateways[:default]
migrations = []

migrations << gateway.migration do
  change do
    create_table :users do
      primary_key :id
      column :name, String, null: false
    end
  end
end

migrations << gateway.migration do
  change do
    create_table :tasks do
      primary_key :id
      foreign_key :user_id, :users, null: false, on_delete: :cascade
      column :title, String
    end
  end
end

migrations << gateway.migration do
  change do
    create_table :tags do
      primary_key :id
      foreign_key :task_id, :tasks, null: false, on_delete: :cascade
      column :name, String
    end
  end
end

migrations.each do |migration|
  migration.apply(gateway.connection, :up)
end

class Users < ROM::Relation[:sql]
  def by_id(id)
    where(id: id)
  end
end

class Tasks < ROM::Relation[:sql]
  def by_id(id)
    where(id: id)
  end
end

class Tags < ROM::Relation[:sql]
  def by_id(id)
    where(id: id)
  end
end

config.register_relation(Users)
config.register_relation(Tasks)
config.register_relation(Tags)

rom = ROM.container(config)

class UserRepo < ROM::Repository[:users]
  relations :tasks, :tags
  commands update: :by_id, delete: :by_id

  def create(graph)
    command(
      :create,
      aggregate(many: tasks.combine_children(many: tags))
    ).call(graph)
  end

  def [](id)
    users.by_id(id).one
  end
end

repo = UserRepo.new(rom)

user = repo.create(
  name: 'Jane',
  tasks: [{ title: 'Task', tags: [{ name: 'red' }]}]
)
	require 'bundler/inline'

	gemfile(true) do
	source 'https://rubygems.org'
	gem 'rom', github: 'rom-rb/rom'
	gem 'rom-sql', github: 'rom-rb/rom-sql'
	gem 'rom-repository', github: 'rom-rb/rom-repository'
	gem 'sqlite3'
	end

	config = ROM::Configuration.new(:sql, 'sqlite::memory')

	gateway = config.gateways[:default]
	migrations = []

	migrations << gateway.migration do
	change do
	create_table :users do
	primary_key :id
	column :name, String, null: false
	end
	end
	end

	migrations << gateway.migration do
	change do
	create_table :tasks do
	primary_key :id
	foreign_key :user_id, :users, null: false, on_delete: :cascade
	column :title, String
	end
	end
	end

	migrations << gateway.migration do
	change do
	create_table :tags do
	primary_key :id
	foreign_key :task_id, :tasks, null: false, on_delete: :cascade
	column :name, String
	end
	end
	end

	migrations.each do \|migration\|
	migration.apply(gateway.connection, :up)
	end

	class Users < ROM::Relation[:sql]
	def by_id(id)
	where(id: id)
	end
	end

	class Tasks < ROM::Relation[:sql]
	def by_id(id)
	where(id: id)
	end
	end

	class Tags < ROM::Relation[:sql]
	def by_id(id)
	where(id: id)
	end
	end

	config.register_relation(Users)
	config.register_relation(Tasks)
	config.register_relation(Tags)

	rom = ROM.container(config)

	class UserRepo < ROM::Repository[:users]
	relations :tasks, :tags
	commands update: :by_id, delete: :by_id

	def create(graph)
	command(
	:create,
	aggregate(many: tasks.combine_children(many: tags))
	).call(graph)
	end

	def [](id)
	users.by_id(id).one
	end
	end

	repo = UserRepo.new(rom)

	user = repo.create(
	name: 'Jane',
	tasks: [{ title: 'Task', tags: [{ name: 'red' }]}]
	)