Sha256: c8848e953aa4556aad7d6d8288d2a2f3decbcfce25274da92b01f8e2a5597ecc

Contents?: true

Size: 1.83 KB

Versions: 7

Compression:

Stored size: 1.83 KB

Contents

require 'spec_helper'

describe Mongo::Operation::Read::Query do
  include_context 'operation'

  let(:selector) { {} }
  let(:query_options) { {} }
  let(:spec) do
    { :selector  => selector,
      :options      => query_options,
      :db_name   => db_name,
      :coll_name => coll_name,
      :read => Mongo::ServerSelector.get
    }
  end
  let(:op) { described_class.new(spec) }

  describe '#initialize' do

    context 'query spec' do
      it 'sets the query spec' do
        expect(op.spec).to be(spec)
      end
    end
  end

  describe '#==' do

    context 'when two ops have different specs' do
      let(:other_spec) do
        { :selector  => { :a => 1 },
          :options      => query_options,
          :db_name   => db_name,
          :coll_name => coll_name
        }
      end
      let(:other) { described_class.new(other_spec) }

      it 'returns false' do
        expect(op).not_to eq(other)
      end
    end
  end

  context '#merge' do
    let(:other_op) { described_class.new(spec) }

    it 'is not allowed' do
      expect{ op.merge(other_op) }.to raise_exception
    end
  end

  context '#merge!' do
    let(:other_op) { described_class.new(spec) }

    it 'is not allowed' do
      expect{ op.merge!(other_op) }.to raise_exception
    end
  end

  describe '#execute' do

    context 'message' do

      it 'creates a query wire protocol message with correct specs' do
        expect(Mongo::Protocol::Query).to receive(:new) do |db, coll, sel, options|
          expect(db).to eq(db_name)
          expect(coll).to eq(coll_name)
          expect(sel).to eq(selector)
        end
        op.execute(primary_context)
      end
    end

    context 'connection' do

      it 'dispatches the message on the connection' do
        expect(connection).to receive(:dispatch)
        op.execute(primary_context)
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
mongo-2.0.4 spec/mongo/operation/read/query_spec.rb
mongo-2.0.3 spec/mongo/operation/read/query_spec.rb
mongo-2.0.2 spec/mongo/operation/read/query_spec.rb
mongo-2.0.1 spec/mongo/operation/read/query_spec.rb
mongo-2.0.0 spec/mongo/operation/read/query_spec.rb
mongo-2.0.0.rc spec/mongo/operation/read/query_spec.rb
mongo-2.0.0.beta spec/mongo/operation/read/query_spec.rb