module Sequel::Plugins::PgArrayAssociations::DatasetMethods
Private Instance Methods
many_to_pg_array_association_filter_expression(op, ref, obj)
click to toggle source
Support filtering by many_to_pg_array associations using a subquery.
# File lib/sequel/plugins/pg_array_associations.rb 520 def many_to_pg_array_association_filter_expression(op, ref, obj) 521 pk = ref.qualify(model.table_name, ref.primary_key) 522 key = ref[:key] 523 # :nocov: 524 expr = case obj 525 # :nocov: 526 when Sequel::Model 527 if (assoc_pks = obj.get_column_value(key)) && !assoc_pks.empty? 528 Sequel[pk=>assoc_pks.to_a] 529 end 530 when Array 531 if (assoc_pks = obj.map{|o| o.get_column_value(key)}.flatten.compact.uniq) && !assoc_pks.empty? 532 Sequel[pk=>assoc_pks] 533 end 534 when Sequel::Dataset 535 obj.select(ref.qualify(obj.model.table_name, ref[:key_column]).as(:key)).from_self.where{{pk=>any(:key)}}.select(1).exists 536 end 537 expr = Sequel::SQL::Constants::FALSE unless expr 538 expr = add_association_filter_conditions(ref, obj, expr) 539 association_filter_handle_inversion(op, expr, [pk]) 540 end
pg_array_to_many_association_filter_expression(op, ref, obj)
click to toggle source
Support filtering by pg_array_to_many associations using a subquery.
# File lib/sequel/plugins/pg_array_associations.rb 543 def pg_array_to_many_association_filter_expression(op, ref, obj) 544 key = ref.qualify(model.table_name, ref[:key_column]) 545 # :nocov: 546 expr = case obj 547 # :nocov: 548 when Sequel::Model 549 if pkv = obj.get_column_value(ref.primary_key_method) 550 Sequel.pg_array_op(key).contains(Sequel.pg_array([pkv], ref.array_type)) 551 end 552 when Array 553 if (pkvs = obj.map{|o| o.get_column_value(ref.primary_key_method)}.compact) && !pkvs.empty? 554 Sequel.pg_array(key).overlaps(Sequel.pg_array(pkvs, ref.array_type)) 555 end 556 when Sequel::Dataset 557 Sequel.function(:coalesce, Sequel.pg_array_op(key).overlaps(obj.select{array_agg(ref.qualify(obj.model.table_name, ref.primary_key))}), Sequel::SQL::Constants::FALSE) 558 end 559 expr = Sequel::SQL::Constants::FALSE unless expr 560 expr = add_association_filter_conditions(ref, obj, expr) 561 association_filter_handle_inversion(op, expr, [key]) 562 end