Contents

module ActiveRecord::Turntable
  class Mixer
    class Fader
      class CalculateShardsSumResult < Fader
        def execute
          @shards_query_hash.map do |shard, query|
            args = @args.dup
            args[1] = args[1].dup if args[1].present?
            shard.connection.send(@called_method, query, *@args, &@block)
          end.inject(&:+)
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
activerecord-turntable-1.1.2	lib/active_record/turntable/mixer/fader/calculate_shards_sum_result.rb
activerecord-turntable-1.1.1	lib/active_record/turntable/mixer/fader/calculate_shards_sum_result.rb
activerecord-turntable-1.1.0	lib/active_record/turntable/mixer/fader/calculate_shards_sum_result.rb
activerecord-turntable-1.0.1	lib/active_record/turntable/mixer/fader/calculate_shards_sum_result.rb
activerecord-turntable-1.0.0	lib/active_record/turntable/mixer/fader/calculate_shards_sum_result.rb