Sha256: 0c62849d121ee5f33dd9ed367be886f35740a08d980ab80f8f55587c3d172d24
Contents?: true
Size: 1.71 KB
Versions: 29
Compression:
Stored size: 1.71 KB
Contents
module Neo4j
module ActiveNode
module Query
module QueryProxyEagerLoading
def each(node = true, rel = nil, &block)
return super if with_associations_spec.size.zero?
query_from_association_spec.pluck(identity, with_associations_return_clause).map do |record, eager_data|
eager_data.each_with_index do |eager_records, index|
record.association_proxy(with_associations_spec[index]).cache_result(eager_records)
end
block.call(record)
end
end
def with_associations_spec
@with_associations_spec ||= []
end
def with_associations_return_clause
'[' + with_associations_spec.map { |n| "collect(#{n})" }.join(',') + ']'
end
def with_associations(*spec)
invalid_association_names = spec.reject do |association_name|
model.associations[association_name]
end
if invalid_association_names.size > 0
fail "Invalid associations: #{invalid_association_names.join(', ')}"
end
new_link.tap do |new_query_proxy|
new_spec = new_query_proxy.with_associations_spec + spec
new_query_proxy.with_associations_spec.replace(new_spec)
end
end
private
def query_from_association_spec
with_associations_spec.inject(query_as(identity).return(identity)) do |query, association_name|
association = model.associations[association_name]
query.optional_match("#{identity}#{association.arrow_cypher}#{association_name}")
.where(association.target_where_clause)
.break
end
end
end
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems