Module: TG::Geometry::ActiveRecordSource

Defined in:
lib/tg/geometry/active_record_source.rb

Class Method Summary collapse

Class Method Details

.call(scope, id:, geometry:, batch_size: 1_000) ⇒ Object



8
9
10
11
12
13
14
15
16
# File 'lib/tg/geometry/active_record_source.rb', line 8

def call(scope, id:, geometry:, batch_size: 1_000)
  entries = []

  each_record(scope, batch_size: batch_size) do |record|
    entries << [read_field(record, id), read_field(record, geometry)]
  end

  entries
end

.registry_source(scope, id:, geometry:, batch_size: 1_000) ⇒ Object



18
19
20
21
22
23
24
25
26
27
# File 'lib/tg/geometry/active_record_source.rb', line 18

def registry_source(scope, id:, geometry:, batch_size: 1_000)
  proc do
    TG::Geometry::ActiveRecordSource.call(
      scope,
      id: id,
      geometry: geometry,
      batch_size: batch_size
    )
  end
end