Sha256: 23eaec83a65700b776e661deb4ca24a0ddc225ccd30dd0acb7a582101dcb3ba8
Contents?: true
Size: 1.92 KB
Versions: 42
Compression:
Stored size: 1.92 KB
Contents
module Instana
module Instrumentation
module MysqlAdapter
IGNORED_PAYLOADS = %w(SCHEMA EXPLAIN CACHE).freeze
EXPLAINED_SQLS = /\A\s*(with|select|update|delete|insert)\b/i
# This module supports instrumenting ActiveRecord with the mysql2 adapter.
#
def self.included(klass)
if ActiveRecord::VERSION::STRING >= '3.2'
Instana::Util.method_alias(klass, :exec_query)
@@sanitize_regexp = Regexp.new('(\'[\s\S][^\']*\'|\d*\.\d+|\d+|NULL)', Regexp::IGNORECASE)
end
end
# Collect up this DB connection info for reporting.
#
# @param sql [String]
# @return [Hash] Hash of collected KVs
#
def collect(sql)
payload = { :activerecord => {} }
payload[:activerecord][:sql] = sql.gsub(@@sanitize_regexp, '?')
payload[:activerecord][:adapter] = @config[:adapter]
payload[:activerecord][:host] = @config[:host]
payload[:activerecord][:db] = @config[:database]
payload[:activerecord][:username] = @config[:username]
payload
end
# In the spirit of ::ActiveRecord::ExplainSubscriber.ignore_payload? There are
# only certain calls that we're interested in tracing. e.g. No use to instrument
# framework caches.
#
# @param payload [String]
# @return [Boolean]
#
def ignore_payload?(name, sql)
IGNORED_PAYLOADS.include?(name) || sql !~ EXPLAINED_SQLS
end
def exec_query_with_instana(sql, name = 'SQL', binds = [], *args)
if !::Instana.tracer.tracing? || ignore_payload?(name, sql) ||
::Instana.tracer.current_span[:n] == :activerecord
return exec_query_without_instana(sql, name, binds, *args)
end
kv_payload = collect(sql)
::Instana.tracer.trace(:activerecord, kv_payload) do
exec_query_without_instana(sql, name, binds, *args)
end
end
end
end
end
Version data entries
42 entries across 42 versions & 1 rubygems