Class: OccamsRecord::RawQuery

Inherits:
Object
  • Object
show all
Includes:
Enumerable, Batches, EagerLoaders::Builder, Measureable
Defined in:
lib/occams-record/raw_query.rb

Overview

Represents a raw SQL query to be run and eager associations to be loaded. Use OccamsRecord.sql to create your queries instead of instantiating objects directly.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Measureable

#measure

Methods included from EagerLoaders::Builder

#eager_load, #eager_load_many, #eager_load_one, #nest

Methods included from Batches

#find_each, #find_in_batches

Constructor Details

#initialize(sql, binds, use: nil, eager_loaders: nil, query_logger: nil, measurements: nil) ⇒ RawQuery

Initialize a new query.

Parameters:

  • sql (String) —

    The SELECT statement to run. Binds should use Ruby’s named string substitution.

  • binds (Hash) —

    Bind values (Symbol keys)

  • use (Array<Module>) (defaults to: nil) —

    optional Module to include in the result class (single or array)

  • eager_loaders (OccamsRecord::EagerLoaders::Context) (defaults to: nil)
  • query_logger (Array) (defaults to: nil) —

    (optional) an array into which all queries will be inserted for logging/debug purposes

  • measurements (Array) (defaults to: nil) 


79
80
81
82
83
84
85
 
# File 'lib/occams-record/raw_query.rb', line 79

def initialize(sql, binds, use: nil, eager_loaders: nil, query_logger: nil, measurements: nil)
  @sql = sql
  @binds = binds
  @use = use
  @eager_loaders = eager_loaders || EagerLoaders::Context.new
  @query_logger, @measurements = query_logger, measurements
end

Instance Attribute Details

#binds ⇒ Hash (readonly)

Returns:

  • (Hash) 


62
63
64
 
# File 'lib/occams-record/raw_query.rb', line 62

def binds
  @binds
end

#sql ⇒ String (readonly)

Returns:

  • (String) 


60
61
62
 
# File 'lib/occams-record/raw_query.rb', line 60

def sql
  @sql
end

Instance Method Details

#each {|OccansR::Results::Row| ... } ⇒ Enumerable

If you pass a block, each result row will be yielded to it. If you don’t, an Enumerable will be returned.

Yields:

  • (OccansR::Results::Row)

Returns:

  • (Enumerable) 


134
135
136
137
138
139
140
 
# File 'lib/occams-record/raw_query.rb', line 134

def each
  if block_given?
    to_a.each { |row| yield row }
  else
    to_a.each
  end
end

#model(klass) ⇒ OccamsRecord::RawQuery

Specify the model to be used to load eager associations. Normally this would be the main table you’re SELECTing from.

NOTE Some database adapters, notably SQLite’s, require that the model always be specified, even if you aren’t doing eager loading.

Parameters:

  • klass (ActiveRecord::Base)

Returns:



97
98
99
100
 
# File 'lib/occams-record/raw_query.rb', line 97

def model(klass)
  @eager_loaders.model = klass
  self
end

#run ⇒ Array<OccamsRecord::Results::Row> Also known as: to_a

Run the query and return the results.

Returns:



107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
# File 'lib/occams-record/raw_query.rb', line 107

def run
  _escaped_sql = escaped_sql
  @query_logger << _escaped_sql if @query_logger
  result = if measure?
             record_start_time!
             measure!(table_name, _escaped_sql) {
               conn.exec_query _escaped_sql
             }
           else
             conn.exec_query _escaped_sql
           end
  row_class = OccamsRecord::Results.klass(result.columns, result.column_types, @eager_loaders.names, model: @eager_loaders.model, modules: @use)
  rows = result.rows.map { |row| row_class.new row }
  @eager_loaders.run!(rows, query_logger: @query_logger, measurements: @measurements)
  yield_measurements!
  rows
end