Contents

require "active_record/log_subscriber"

module ActiveRecord::Turntable
  module ActiveRecordExt
    module LogSubscriber
      # @note prepend to add shard name logging
      def sql(event)
        payload = event.payload
        if payload[:turntable_shard_name]
          payload[:name] = "#{payload[:name]} [Shard: #{payload[:turntable_shard_name]}]"
        end
        super
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
activerecord-turntable-3.0.0.alpha3	lib/active_record/turntable/active_record_ext/log_subscriber.rb
activerecord-turntable-3.0.0.alpha2	lib/active_record/turntable/active_record_ext/log_subscriber.rb
activerecord-turntable-3.0.0.alpha1	lib/active_record/turntable/active_record_ext/log_subscriber.rb