class Persisto::Pg

Attributes

database[R]

Public Class Methods

connect(*args) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 6
def self.connect *args
        new Sequel.connect(*args)
end
new(database) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 12
def initialize database
        @database = database
end

Public Instance Methods

delete(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 28
def delete qo
        single_value(qo)
end
insert(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 20
def insert qo
        single_value(qo)
end
select(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 16
def select qo
        all(qo)
end
transaction(&block) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 32
def transaction &block
        database.transaction &block
end
update(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 24
def update qo
        single_value(qo)
end

Private Instance Methods

all(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 38
def all qo
        fetch(qo).all
end
fetch(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 46
def fetch qo
        database.fetch(qo.query)
end
single_value(qo) click to toggle source
# File lib/persisto/adaptors/pg.rb, line 42
def single_value qo
        fetch(qo).single_value
end