Contents

module ActiveRecord
  module Associations
    class HasManyAssociation
      def delete_records(records, method)
        if method == :destroy
          records.each { |r| r.destroy }
          update_counter(-records.length) unless inverse_updates_counter_cache?
        else
          # CPK
          # keys  = records.map { |r| r[reflection.association_primary_key] }
          # scope = scope.where(reflection.association_primary_key => keys)
          table = Arel::Table.new(reflection.table_name)
          and_conditions = records.map do |record|
            eq_conditions = Array(reflection.association_primary_key).map do |name|
              table[name].eq(record[name])
            end
            Arel::Nodes::And.new(eq_conditions)
          end

          condition = and_conditions.shift
          and_conditions.each do |and_condition|
            condition = condition.or(and_condition)
          end

          scope = scope.where(condition)

          if method == :delete_all
            update_counter(-scope.delete_all)
          else
            # CPK
            # update_counter(-scope.update_all(reflection.foreign_key => nil))
            updates = Array(reflection.foreign_key).inject(Hash.new) do |hash, name|
              hash[name] = nil
              hash
            end
            update_counter(-scope.update_all(updates))
          end
        end
      end

      def foreign_key_present?
        # CPK
        # owner.attribute_present?(reflection.association_primary_key)
        Array(reflection.association_primary_key).all? {|key| owner.attribute_present?(key)}
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
composite_primary_keys-6.0.0	lib/composite_primary_keys/associations/has_many_association.rb