Class: Sequel::Postgres::Dataset

Inherits:
Object
  • Object
show all
Defined in:
lib/sequel/schema-sharding/extensions/postgres/dataset.rb

Instance Method Summary collapse

Instance Method Details

#adapter_fetch_rows ⇒ Object 



4
 
# File 'lib/sequel/schema-sharding/extensions/postgres/dataset.rb', line 4

alias_method :adapter_fetch_rows, :fetch_rows

#fetch_rows(sql, &block) ⇒ Object 



6
7
8
9
10
11
12
13
 
# File 'lib/sequel/schema-sharding/extensions/postgres/dataset.rb', line 6

def fetch_rows(sql, &block)
  adapter_fetch_rows(sql) do |r|
    if self.respond_to?(:shard_number)
      r[:shard_number] = self.shard_number
    end
    block.call r
  end
end