Class: Graphiti::Adapters::ActiveRecord
Defined Under Namespace
Modules: Inference
Classes: BelongsToSideload, HasManySideload, HasOneSideload, ManyToManySideload, Sanitizer
Instance Attribute Summary
Attributes inherited from Abstract
#resource
Class Method Summary
collapse
Instance Method Summary
collapse
-
#associate(parent, child, association_name, association_type) ⇒ Object
-
#associate_all(parent, children, association_name, association_type) ⇒ Object
-
#average(scope, attr) ⇒ Float
The average of the scope.
-
#base_scope(model) ⇒ Object
-
#close ⇒ Object
-
#count(scope, attr) ⇒ Numeric
-
#create(model_class, create_params) ⇒ Object
-
#destroy(model_instance) ⇒ Object
-
#disassociate(parent, child, association_name, association_type) ⇒ Object
When a has_and_belongs_to_many relationship, we don’t have a foreign key that can be null’d.
-
#filter_datetime_eq(scope, attribute, value, is_not: false) ⇒ Object
Ensure fractional seconds don’t matter.
-
#filter_datetime_lte(scope, attribute, value) ⇒ Object
-
#filter_datetime_not_eq(scope, attribute, value) ⇒ Object
-
#filter_eq(scope, attribute, value) ⇒ Object
(also: #filter_integer_eq, #filter_float_eq, #filter_big_decimal_eq, #filter_date_eq, #filter_boolean_eq, #filter_uuid_eq, #filter_enum_eq)
-
#filter_gt(scope, attribute, value) ⇒ Object
(also: #filter_integer_gt, #filter_float_gt, #filter_big_decimal_gt, #filter_datetime_gt, #filter_date_gt)
-
#filter_gte(scope, attribute, value) ⇒ Object
(also: #filter_integer_gte, #filter_float_gte, #filter_big_decimal_gte, #filter_datetime_gte, #filter_date_gte)
-
#filter_lt(scope, attribute, value) ⇒ Object
(also: #filter_integer_lt, #filter_float_lt, #filter_big_decimal_lt, #filter_datetime_lt, #filter_date_lt)
-
#filter_lte(scope, attribute, value) ⇒ Object
(also: #filter_integer_lte, #filter_float_lte, #filter_big_decimal_lte, #filter_date_lte)
-
#filter_not_eq(scope, attribute, value) ⇒ Object
(also: #filter_integer_not_eq, #filter_float_not_eq, #filter_big_decimal_not_eq, #filter_date_not_eq, #filter_boolean_not_eq, #filter_uuid_not_eq, #filter_enum_not_eq)
-
#filter_string_eq(scope, attribute, value, is_not: false) ⇒ Object
-
#filter_string_eql(scope, attribute, value, is_not: false) ⇒ Object
-
#filter_string_match(scope, attribute, value, is_not: false) ⇒ Object
-
#filter_string_not_eq(scope, attribute, value) ⇒ Object
-
#filter_string_not_eql(scope, attribute, value) ⇒ Object
-
#filter_string_not_match(scope, attribute, value) ⇒ Object
-
#filter_string_not_prefix(scope, attribute, value) ⇒ Object
-
#filter_string_not_suffix(scope, attribute, value) ⇒ Object
-
#filter_string_prefix(scope, attribute, value, is_not: false) ⇒ Object
-
#filter_string_suffix(scope, attribute, value, is_not: false) ⇒ Object
-
#maximum(scope, attr) ⇒ Numeric
The maximum value of the scope.
-
#minimum(scope, attr) ⇒ Numeric
The maximum value of the scope.
-
#order(scope, attribute, direction) ⇒ Object
-
#paginate(scope, current_page, per_page, offset) ⇒ Object
-
#resolve(scope) ⇒ Object
-
#save(model_instance) ⇒ Object
-
#sum(scope, attr) ⇒ Numeric
-
#transaction(model_class) ⇒ Object
Run this write request within an ActiveRecord transaction.
-
#update(model_class, update_params) ⇒ Object
Methods inherited from Abstract
#assign_attributes, #belongs_to_many_filter, #build, default_operators, #initialize, numerical_operators, #persistence_attributes
#process_belongs_to, #process_has_many, #update_foreign_key, #update_foreign_key_for_parents, #update_foreign_type
Instance Method Details
#associate(parent, child, association_name, association_type) ⇒ Object
260
261
262
263
264
265
266
267
268
|
# File 'lib/graphiti/adapters/active_record.rb', line 260
def associate(parent, child, association_name, association_type)
if activerecord_associate?(parent, child, association_name)
association = parent.association(association_name)
association.loaded!
association.instance_variable_set(:@target, child)
else
super
end
end
|
#associate_all(parent, children, association_name, association_type) ⇒ Object
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
|
# File 'lib/graphiti/adapters/active_record.rb', line 238
def associate_all(parent, children, association_name, association_type)
if activerecord_associate?(parent, children[0], association_name)
association = parent.association(association_name)
association.loaded!
children.each do |child|
if association_type == :many_to_many &&
[:create, :update].include?(Graphiti.context[:namespace]) &&
!parent.send(association_name).exists?(child.id) &&
child.errors.blank?
parent.send(association_name) << child
else
target = association.instance_variable_get(:@target)
target |= [child]
association.instance_variable_set(:@target, target)
end
end
else
super
end
end
|
#average(scope, attr) ⇒ Float
Returns the average of the scope.
204
205
206
|
# File 'lib/graphiti/adapters/active_record.rb', line 204
def average(scope, attr)
scope.average(attr).to_f
end
|
#base_scope(model) ⇒ Object
177
178
179
|
# File 'lib/graphiti/adapters/active_record.rb', line 177
def base_scope(model)
model.all
end
|
304
305
306
|
# File 'lib/graphiti/adapters/active_record.rb', line 304
def close
::ActiveRecord::Base.clear_active_connections!
end
|
#count(scope, attr) ⇒ Numeric
Returns the count of the scope.
195
196
197
198
199
200
201
|
# File 'lib/graphiti/adapters/active_record.rb', line 195
def count(scope, attr)
if attr.to_sym == :total
scope.distinct.count(:all)
else
scope.distinct.count(attr)
end
end
|
#create(model_class, create_params) ⇒ Object
281
282
283
284
285
|
# File 'lib/graphiti/adapters/active_record.rb', line 281
def create(model_class, create_params)
instance = model_class.new(create_params)
instance.save
instance
end
|
#destroy(model_instance) ⇒ Object
299
300
301
302
|
# File 'lib/graphiti/adapters/active_record.rb', line 299
def destroy(model_instance)
model_instance.destroy
model_instance
end
|
#disassociate(parent, child, association_name, association_type) ⇒ Object
When a has_and_belongs_to_many relationship, we don’t have a foreign key that can be null’d. Instead, go through the ActiveRecord API.
273
274
275
276
277
278
|
# File 'lib/graphiti/adapters/active_record.rb', line 273
def disassociate(parent, child, association_name, association_type)
if association_type == :many_to_many
parent.send(association_name).delete(child)
end
end
|
#filter_datetime_eq(scope, attribute, value, is_not: false) ⇒ Object
Ensure fractional seconds don’t matter
161
162
163
164
165
|
# File 'lib/graphiti/adapters/active_record.rb', line 161
def filter_datetime_eq(scope, attribute, value, is_not: false)
ranges = value.map { |v| (v..v + 1.second - 0.00000001) unless v.nil? }
clause = {attribute => ranges}
is_not ? scope.where.not(clause) : scope.where(clause)
end
|
#filter_datetime_lte(scope, attribute, value) ⇒ Object
171
172
173
174
175
|
# File 'lib/graphiti/adapters/active_record.rb', line 171
def filter_datetime_lte(scope, attribute, value)
value = value.map { |v| v + 1.second - 0.00000001 }
column = scope.klass.arel_table[attribute]
scope.where(column.lteq_any(value))
end
|
#filter_datetime_not_eq(scope, attribute, value) ⇒ Object
167
168
169
|
# File 'lib/graphiti/adapters/active_record.rb', line 167
def filter_datetime_not_eq(scope, attribute, value)
filter_datetime_eq(scope, attribute, value, is_not: true)
end
|
#filter_eq(scope, attribute, value) ⇒ Object
Also known as:
filter_integer_eq, filter_float_eq, filter_big_decimal_eq, filter_date_eq, filter_boolean_eq, filter_uuid_eq, filter_enum_eq
19
20
21
|
# File 'lib/graphiti/adapters/active_record.rb', line 19
def filter_eq(scope, attribute, value)
scope.where(attribute => value)
end
|
#filter_gt(scope, attribute, value) ⇒ Object
Also known as:
filter_integer_gt, filter_float_gt, filter_big_decimal_gt, filter_datetime_gt, filter_date_gt
121
122
123
124
|
# File 'lib/graphiti/adapters/active_record.rb', line 121
def filter_gt(scope, attribute, value)
column = column_for(scope, attribute)
scope.where(column.gt_any(value))
end
|
#filter_gte(scope, attribute, value) ⇒ Object
Also known as:
filter_integer_gte, filter_float_gte, filter_big_decimal_gte, filter_datetime_gte, filter_date_gte
131
132
133
134
|
# File 'lib/graphiti/adapters/active_record.rb', line 131
def filter_gte(scope, attribute, value)
column = column_for(scope, attribute)
scope.where(column.gteq_any(value))
end
|
#filter_lt(scope, attribute, value) ⇒ Object
Also known as:
filter_integer_lt, filter_float_lt, filter_big_decimal_lt, filter_datetime_lt, filter_date_lt
141
142
143
144
|
# File 'lib/graphiti/adapters/active_record.rb', line 141
def filter_lt(scope, attribute, value)
column = column_for(scope, attribute)
scope.where(column.lt_any(value))
end
|
#filter_lte(scope, attribute, value) ⇒ Object
Also known as:
filter_integer_lte, filter_float_lte, filter_big_decimal_lte, filter_date_lte
151
152
153
154
|
# File 'lib/graphiti/adapters/active_record.rb', line 151
def filter_lte(scope, attribute, value)
column = column_for(scope, attribute)
scope.where(column.lteq_any(value))
end
|
#filter_not_eq(scope, attribute, value) ⇒ Object
Also known as:
filter_integer_not_eq, filter_float_not_eq, filter_big_decimal_not_eq, filter_date_not_eq, filter_boolean_not_eq, filter_uuid_not_eq, filter_enum_not_eq
30
31
32
|
# File 'lib/graphiti/adapters/active_record.rb', line 30
def filter_not_eq(scope, attribute, value)
scope.where.not(attribute => value)
end
|
#filter_string_eq(scope, attribute, value, is_not: false) ⇒ Object
41
42
43
44
45
|
# File 'lib/graphiti/adapters/active_record.rb', line 41
def filter_string_eq(scope, attribute, value, is_not: false)
column = column_for(scope, attribute)
clause = column.lower.eq_any(value.map(&:downcase))
is_not ? scope.where.not(clause) : scope.where(clause)
end
|
#filter_string_eql(scope, attribute, value, is_not: false) ⇒ Object
47
48
49
50
|
# File 'lib/graphiti/adapters/active_record.rb', line 47
def filter_string_eql(scope, attribute, value, is_not: false)
clause = {attribute => value}
is_not ? scope.where.not(clause) : scope.where(clause)
end
|
#filter_string_match(scope, attribute, value, is_not: false) ⇒ Object
64
65
66
67
68
69
|
# File 'lib/graphiti/adapters/active_record.rb', line 64
def filter_string_match(scope, attribute, value, is_not: false)
clause = sanitized_like_for(scope, attribute, value) { |v|
"%#{v}%"
}
is_not ? scope.where.not(clause) : scope.where(clause)
end
|
#filter_string_not_eq(scope, attribute, value) ⇒ Object
52
53
54
|
# File 'lib/graphiti/adapters/active_record.rb', line 52
def filter_string_not_eq(scope, attribute, value)
filter_string_eq(scope, attribute, value, is_not: true)
end
|
#filter_string_not_eql(scope, attribute, value) ⇒ Object
56
57
58
|
# File 'lib/graphiti/adapters/active_record.rb', line 56
def filter_string_not_eql(scope, attribute, value)
filter_string_eql(scope, attribute, value, is_not: true)
end
|
#filter_string_not_match(scope, attribute, value) ⇒ Object
117
118
119
|
# File 'lib/graphiti/adapters/active_record.rb', line 117
def filter_string_not_match(scope, attribute, value)
filter_string_match(scope, attribute, value, is_not: true)
end
|
#filter_string_not_prefix(scope, attribute, value) ⇒ Object
109
110
111
|
# File 'lib/graphiti/adapters/active_record.rb', line 109
def filter_string_not_prefix(scope, attribute, value)
filter_string_prefix(scope, attribute, value, is_not: true)
end
|
#filter_string_not_suffix(scope, attribute, value) ⇒ Object
113
114
115
|
# File 'lib/graphiti/adapters/active_record.rb', line 113
def filter_string_not_suffix(scope, attribute, value)
filter_string_suffix(scope, attribute, value, is_not: true)
end
|
#filter_string_prefix(scope, attribute, value, is_not: false) ⇒ Object
71
72
73
74
75
76
|
# File 'lib/graphiti/adapters/active_record.rb', line 71
def filter_string_prefix(scope, attribute, value, is_not: false)
clause = sanitized_like_for(scope, attribute, value) { |v|
"#{v}%"
}
is_not ? scope.where.not(clause) : scope.where(clause)
end
|
#filter_string_suffix(scope, attribute, value, is_not: false) ⇒ Object
78
79
80
81
82
83
|
# File 'lib/graphiti/adapters/active_record.rb', line 78
def filter_string_suffix(scope, attribute, value, is_not: false)
clause = sanitized_like_for(scope, attribute, value) { |v|
"%#{v}"
}
is_not ? scope.where.not(clause) : scope.where(clause)
end
|
#maximum(scope, attr) ⇒ Numeric
Returns the maximum value of the scope.
214
215
216
|
# File 'lib/graphiti/adapters/active_record.rb', line 214
def maximum(scope, attr)
scope.maximum(attr)
end
|
#minimum(scope, attr) ⇒ Numeric
Returns the maximum value of the scope.
219
220
221
|
# File 'lib/graphiti/adapters/active_record.rb', line 219
def minimum(scope, attr)
scope.minimum(attr)
end
|
#order(scope, attribute, direction) ⇒ Object
182
183
184
|
# File 'lib/graphiti/adapters/active_record.rb', line 182
def order(scope, attribute, direction)
scope.order(attribute => direction)
end
|
#paginate(scope, current_page, per_page, offset) ⇒ Object
187
188
189
190
191
192
|
# File 'lib/graphiti/adapters/active_record.rb', line 187
def paginate(scope, current_page, per_page, offset)
scope = scope.page(current_page) if current_page
scope = scope.per(per_page) if per_page
scope = scope.padding(offset) if offset
scope
end
|
#resolve(scope) ⇒ Object
Resolve the scope. This is where you’d actually fire SQL, actually make an HTTP call, etc.
224
225
226
|
# File 'lib/graphiti/adapters/active_record.rb', line 224
def resolve(scope)
scope.to_a
end
|
#save(model_instance) ⇒ Object
294
295
296
297
|
# File 'lib/graphiti/adapters/active_record.rb', line 294
def save(model_instance)
model_instance.save
model_instance
end
|
#sum(scope, attr) ⇒ Numeric
Returns the sum of the scope.
209
210
211
|
# File 'lib/graphiti/adapters/active_record.rb', line 209
def sum(scope, attr)
scope.sum(attr)
end
|
#transaction(model_class) ⇒ Object
Run this write request within an ActiveRecord transaction
232
233
234
235
236
|
# File 'lib/graphiti/adapters/active_record.rb', line 232
def transaction(model_class)
model_class.transaction do
yield
end
end
|
#update(model_class, update_params) ⇒ Object
288
289
290
291
292
|
# File 'lib/graphiti/adapters/active_record.rb', line 288
def update(model_class, update_params)
instance = model_class.find(update_params.only(:id))
instance.update_attributes(update_params.except(:id))
instance
end
|