Class: OccamsRecord::RawQuery

Inherits:
Object
  • Object
show all
Includes:
Enumerable, Batches, EagerLoaders::Builder
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 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) ⇒ 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



66
67
68
69
70
71
72
73
 
# File 'lib/occams-record/raw_query.rb', line 66

def initialize(sql, binds, use: nil, eager_loaders: nil, query_logger: nil)
  @sql = sql
  @binds = binds
  @use = use
  @eager_loaders = eager_loaders || EagerLoaders::Context.new
  @query_logger = query_logger
  @conn = @eager_loaders.model&.connection || ActiveRecord::Base.connection
end

Instance Attribute Details

#binds ⇒ Hash (readonly)

Returns:

  • (Hash) 


51
52
53
 
# File 'lib/occams-record/raw_query.rb', line 51

def binds
  @binds
end

#sql ⇒ String (readonly)

Returns:

  • (String) 


49
50
51
 
# File 'lib/occams-record/raw_query.rb', line 49

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) 


114
115
116
117
118
119
120
 
# File 'lib/occams-record/raw_query.rb', line 114

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:



85
86
87
88
 
# File 'lib/occams-record/raw_query.rb', line 85

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:



95
96
97
98
99
100
101
102
103
 
# File 'lib/occams-record/raw_query.rb', line 95

def run
  _escaped_sql = escaped_sql
  @query_logger << _escaped_sql if @query_logger
  result = @conn.exec_query _escaped_sql
  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)
  rows
end