database_log_subscriber.rb

class DatabaseLogSubscriber < ActiveSupport::LogSubscriber
  IGNORE_PAYLOAD_NAMES = ["SCHEMA", "EXPLAIN"]
  def sql(event)
    return unless logger.debug?
    payload = event.payload
    return if IGNORE_PAYLOAD_NAMES.include?(payload[:name])

    conn_id = payload[:connection_id]
    conn = ObjectSpace._id2ref(conn_id)
    from_connection = conn.active? ? conn.current_database : "No active connection"

    name  = "#{payload[:name]} (#{event.duration.round(1)}ms)  #{from_connection}"
    name  = "CACHE #{name}" if payload[:cached]
    name = color(name, RED)
    debug "  #{name}"
  end
end

DatabaseLogSubscriber.attach_to :active_record