module NewRelic::Agent::Instrumentation::ActiveRecord
Constants
- EXPLAINER
Public Class Methods
Source
# File lib/new_relic/agent/instrumentation/active_record.rb, line 30 def self.included(instrumented_class) instrumented_class.class_eval do unless instrumented_class.method_defined?(:log_without_newrelic_instrumentation) alias_method(:log_without_newrelic_instrumentation, :log) alias_method(:log, :log_with_newrelic_instrumentation) protected(:log) end end end
Source
# File lib/new_relic/agent/instrumentation/active_record.rb, line 15 def self.insert_instrumentation if defined?(::ActiveRecord::VERSION::MAJOR) && ::ActiveRecord::VERSION::MAJOR.to_i >= 3 if ::NewRelic::Agent.config[:prepend_active_record_instrumentation] ::ActiveRecord::Base.prepend(::NewRelic::Agent::Instrumentation::ActiveRecordPrepend::BaseExtensions) ::ActiveRecord::Relation.prepend(::NewRelic::Agent::Instrumentation::ActiveRecordPrepend::RelationExtensions) else ::NewRelic::Agent::Instrumentation::ActiveRecordHelper.instrument_additional_methods end end ::ActiveRecord::ConnectionAdapters::AbstractAdapter.module_eval do include ::NewRelic::Agent::Instrumentation::ActiveRecord end end
Public Instance Methods
Source
# File lib/new_relic/agent/instrumentation/active_record.rb, line 41 def log_with_newrelic_instrumentation(*args, &block) state = NewRelic::Agent::Tracer.state if !state.is_execution_traced? return log_without_newrelic_instrumentation(*args, &block) end sql, name, _ = args product, operation, collection = ActiveRecordHelper.product_operation_collection_for( NewRelic::Helper.correctly_encoded(name), NewRelic::Helper.correctly_encoded(sql), @config && @config[:adapter] ) host = nil port_path_or_id = nil database = nil if ActiveRecordHelper::InstanceIdentification.supported_adapter?(@config) host = ActiveRecordHelper::InstanceIdentification.host(@config) port_path_or_id = ActiveRecordHelper::InstanceIdentification.port_path_or_id(@config) database = @config && @config[:database] end segment = NewRelic::Agent::Tracer.start_datastore_segment( product: product, operation: operation, collection: collection, host: host, port_path_or_id: port_path_or_id, database_name: database ) segment._notice_sql(sql, @config, EXPLAINER) begin NewRelic::Agent::Tracer.capture_segment_error(segment) do log_without_newrelic_instrumentation(*args, &block) end ensure ::NewRelic::Agent::Transaction::Segment.finish(segment) end end