module Actn::DB::PG

Public Instance Methods

db_config() click to toggle source

:singleton method parses database url

# File lib/actn/db/pg.rb, line 65
def db_config
  @@config ||= begin
    db = URI.parse(ENV['DATABASE_URL'] || 'postgres://localhost')
    config = {
      dbname: db.path[1..-1],
      host: db.host,
      port: db.port,
      size: ENV['DB_POOL_SIZE'] || 5,          
      async_autoreconnect: ENV['DB_ASYNC_AUTO_RECONNECT'] || true,
      connect_timeout: ENV['DB_CONN_TIMEOUT'] || 60,
      query_timeout: ENV['DB_QUERY_TIMEOUT'] || 30,
      on_autoreconnect: proc { |pg| pg.exec "SELECT plv8_startup();" rescue nil },
      on_connect: proc { |pg| pg.exec "SELECT plv8_startup();" rescue nil }
    }
    config[:user] = db.user if db.user
    config[:password] = db.password if db.password
    config
  end
end
exec_func(func_name, *params) click to toggle source
# File lib/actn/db/pg.rb, line 25
def exec_func func_name, *params
  sql = "SELECT __#{func_name}(#{ (params.length-1).times.inject("$1"){ |m,i| "#{m},$#{ i + 2 }"} })"
  exec_prepared sql.parameterize.underscore, sql, params
end
exec_params(sql, params = []) click to toggle source
# File lib/actn/db/pg.rb, line 45
def exec_params sql, params = []
  result = pg.exec_params(sql, params)
  json = result.values.flatten.first
  result.clear
  json
end
exec_prepared(statement, sql, params = []) click to toggle source
# File lib/actn/db/pg.rb, line 30
def exec_prepared statement, sql, params = []
  
  pg.prepare statement, sql rescue ::PG::DuplicatePstatement
  
  begin          
    result = pg.exec_prepared(statement, params)
    json = result.values.flatten.first
    result.clear
    json
  rescue ::PG::InvalidSqlStatementName
    exec_params sql, params
  end
  
end
pg() click to toggle source

:singleton method holds db connection

# File lib/actn/db/pg.rb, line 56
def pg 
  @@connection_pool ||= ::PG::EM::ConnectionPool.new(db_config)
end