Contents

# frozen_string_literal: true

require 'takwimu/notifications/base'

module Takwimu
  module Notifications
    class ActiveRecord < Base

      SELECT_DELETE = / FROM `(w+)`/
      INSERT = /^INSERT INTO `(w+)`/
      UPDATE = /^UPDATE `(w+)`/

      def self.event_name
        "sql.active_record"
      end

      def self.callback(name, start, finish, unique_id, payload)
        statsd_client = Takwimu.config.statsd
        hostname = Takwimu.config.hostname

        case payload[:sql]
          when /^SELECT/
            payload[:sql] =~ SELECT_DELETE
            statsd_client.increment("#{hostname}.sql.select")
            statsd_client.timing("#{hostname}.sql.#{$1}.select.query_time", (finish - start) * 1000, 1)
          when /^DELETE/
            payload[:sql] =~ SELECT_DELETE
            statsd_client.increment("#{hostname}.sql.delete")
            statsd_client.timing("#{hostname}.sql.#{$1}.delete.query_time", (finish - start) * 1000, 1)
          when /^INSERT/
            payload[:sql] =~ INSERT
            statsd_client.increment("#{hostname}.sql.insert")
            statsd_client.timing("#{hostname}.sql.#{$1}.insert.query_time", (finish - start) * 1000, 1)
          when /^UPDATE/
            payload[:sql] =~ UPDATE
            statsd_client.increment("#{hostname}.sql.update"  )
            statsd_client.timing("#{hostname}.sql.#{$1}.update.query_time", (finish - start) * 1000, 1)
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
takwimu-0.1.1	lib/takwimu/notifications/active_record.rb
takwimu-0.1.0	lib/takwimu/notifications/active_record.rb