Contents

require 'ddtrace/contrib/active_record/event'

module Datadog
  module Contrib
    module ActiveRecord
      module Events
        # Defines instrumentation for sql.active_record event
        module SQL
          include ActiveRecord::Event

          EVENT_NAME = 'sql.active_record'.freeze
          SPAN_NAME = 'active_record.sql'.freeze

          module_function

          def event_name
            self::EVENT_NAME
          end

          def span_name
            self::SPAN_NAME
          end

          def process(span, event, _id, payload)
            connection_config = Utils.connection_config(payload[:connection_id])
            span.name = "#{connection_config[:adapter_name]}.query"
            span.service = configuration[:service_name]
            span.resource = payload.fetch(:sql)
            span.span_type = Datadog::Ext::SQL::TYPE

            # Find out if the SQL query has been cached in this request. This meta is really
            # helpful to users because some spans may have 0ns of duration because the query
            # is simply cached from memory, so the notification is fired with start == finish.
            cached = payload[:cached] || (payload[:name] == 'CACHE')

            span.set_tag('active_record.db.vendor', connection_config[:adapter_name])
            span.set_tag('active_record.db.name', connection_config[:database_name])
            span.set_tag('active_record.db.cached', cached) if cached
            span.set_tag('out.host', connection_config[:adapter_host])
            span.set_tag('out.port', connection_config[:adapter_port])
          rescue StandardError => e
            Datadog::Tracer.log.debug(e.message)
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ddtrace-0.13.2	lib/ddtrace/contrib/active_record/events/sql.rb
ddtrace-0.13.1	lib/ddtrace/contrib/active_record/events/sql.rb
ddtrace-0.13.0	lib/ddtrace/contrib/active_record/events/sql.rb
ddtrace-0.13.0.beta1	lib/ddtrace/contrib/active_record/events/sql.rb