pg_web_stats.rb

require 'pg'
require 'coderay'
require 'yaml'

class PgWebStats
  attr_accessor :config, :connection

  def initialize(config_path = 'config.yml')
    hash = config_path.is_a?(Hash) ? config_path : YAML.load_file(config_path)
    self.config = Hash[hash.map{ |k, v| [k.to_s, v] }]
    self.connection = PG.connect(
      dbname: config['database'],
      host: config['host'],
      user: config['user'] || config['username'],
      password: config['password'],
      port: config['port']
    )
  end

  def get_stats(params = { order: "total_time desc" })
    query = build_stats_query(params)

    results = []
    connection.exec(query) do |result|
      result.each do |row|
        results << Row.new(row, users, databases)
      end
    end

    results
  end

  def users
    @users ||= select_by_oid("select oid, rolname from pg_authid order by rolname;", 'rolname')
  end

  def databases
    @databases ||= select_by_oid("select oid, datname from pg_database order by datname;", 'datname')
  end

  private

  def select_by_oid(select_query, row_name)
    @selection = {}
    connection.exec(select_query) do |result|
      result.each do |row|
        @selection[row['oid']] = row[row_name]
      end
    end

    @selection
  end

  def build_stats_query(params)
    order_by = params[:order]

    query = "SELECT * FROM pg_stat_statements"

    where_conditions = []

    userid = params[:userid]
    if userid && !userid.empty?
      where_conditions << "userid='#{userid.gsub("'", "''")}'"
    end

    dbid = params[:dbid]
    if dbid && !dbid.empty?
      where_conditions << "dbid='#{dbid.gsub("'", "''")}'"
    end

    q = params[:q]
    if q && !q.empty?
      where_conditions << "query LIKE '#{q.gsub("'", "''")}%'"
    end

    query += " WHERE #{where_conditions.join(" AND ")}" if where_conditions.size > 0

    query += " ORDER BY #{order_by}"

    query
  end
end

class PgWebStats::Row
  attr_accessor :data, :users, :databases

  def initialize(data, users, databases)
    self.data = data
    self.users = users
    self.databases = databases
  end

  def respond_to?(method_sym, include_private = false)
    if data[method_sym.to_s]
      true
    else
      super
    end
  end

  def method_missing(method_sym, *arguments, &block)
    if result = data[method_sym.to_s]
      result
    else
      super
    end
  end

  def user
    users[userid]
  end

  def db
    databases[dbid]
  end

  def query
    CodeRay.scan(data["query"].gsub(/\s+/, ' ').strip, "sql").div(:css => :class)
  end

  def waste?
    clean_query = self.query.dup.downcase.strip
    keywords = ['show', 'set', 'rollback', 'savepoint', 'release', 'begin', 'create_extension']
    keywords.any? { |k| clean_query.start_with?(k) }
  end
end