Contents

RSpec.describe 'PostgreSQL extension', :postgres do
  include_context 'database setup'

  before do
    conn.drop_table?(:pg_people)
    conn.drop_table?(:people)

    conn.create_table :pg_people do
      primary_key :id
      String :name
      column :tags, "text[]"
    end

    conf.relation(:people) do
      schema(:pg_people, infer: true)
    end

    conf.commands(:people) do
      define(:create)
      define(:update)
    end
  end

  let(:people_relation) { relations[:people] }

  describe 'using arrays' do
    let(:people) { commands[:people] }

    it 'inserts array values' do
      people.create.call(name: 'John Doe', tags: ['foo'])
      expect(people_relation.to_a).to eq([id: 1, name: 'John Doe', tags: ['foo']])
    end

    it 'inserts empty arrays' do
      people.create.call(name: 'John Doe', tags: [])
      expect(people_relation.to_a).to eq([id: 1, name: 'John Doe', tags: []])
    end
  end

  describe 'using retrurning' do
    let(:create_person) { commands[:people].create }
    let(:update_person) { commands[:people].update }
    let(:composite_relation) { people_relation >> -> r { r.to_a.map { |x| x.fetch(:name).upcase } } }

    context 'with pipeline' do
      it 'works with create' do
        mapped_people = create_person.new(composite_relation).call(name: 'John Doe', tags: ['foo'])
        expect(mapped_people).to eql(['JOHN DOE'])
      end

      it 'works with update' do
        create_person.call(name: 'John Doe', tags: ['foo'])

        mapped_people = update_person.new(composite_relation).call(name: 'Jane Doe')
        expect(mapped_people).to eql(['JANE DOE'])
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
rom-sql-1.3.5	spec/extensions/postgres/integration_spec.rb
rom-sql-1.3.4	spec/extensions/postgres/integration_spec.rb
rom-sql-2.0.0.beta2	spec/extensions/postgres/integration_spec.rb
rom-sql-2.0.0.beta1	spec/extensions/postgres/integration_spec.rb
rom-sql-1.3.3	spec/extensions/postgres/integration_spec.rb
rom-sql-1.3.2	spec/extensions/postgres/integration_spec.rb
rom-sql-1.3.1	spec/extensions/postgres/integration_spec.rb
rom-sql-1.3.0	spec/extensions/postgres/integration_spec.rb