module CompositePrimaryKeys
  module ActiveRecord
    module Calculations
      def aggregate_column(column_name)
        # CPK
        if column_name.kind_of?(Array)
          column_name.map do |column|
            Arel::Attribute.new(@klass.unscoped.table, column)
          end
        elsif @klass.column_names.include?(column_name.to_s)
          Arel::Attribute.new(@klass.unscoped.table, column_name)
        else
          Arel.sql(column_name == :all ? "*" : column_name.to_s)
        end
      end

      def execute_simple_calculation(operation, column_name, distinct)
        # Postgresql doesn't like ORDER BY when there are no GROUP BY
        relation = reorder(nil)

        # CPK
        #if operation == "count" && (relation.limit_value || relation.offset_value)
        if operation == "count"
          # Shortcut when limit is zero.
          return 0 if relation.limit_value == 0

          query_builder = build_count_subquery(relation, column_name, distinct)
        else
          column = aggregate_column(column_name)

          select_value = operation_over_aggregate_column(column, operation, distinct)

          relation.select_values = [select_value]

          query_builder = relation.arel
        end

        type_cast_calculated_value(@klass.connection.select_value(query_builder.to_sql), column_for(column_name), operation)
      end

      def build_count_subquery(relation, column_name, distinct)
        # CPK
        # column_alias = Arel.sql('count_column')
        subquery_alias = Arel.sql('subquery_for_count')

        # CPK
        # aliased_column = aggregate_column(column_name == :all ? 1 : column_name).as(column_alias)
        # relation.select_values = [aliased_column]
        relation.select_values = if column_name.kind_of?(Array)
            column_name.map do |column|
              Arel::Attribute.new(@klass.unscoped.table, column)
            end
          elsif @klass.column_names.include?(column_name.to_s)
            [Arel::Attribute.new(@klass.unscoped.table, column_name)]
          else
            [Arel.sql(column_name == :all ? "#{@klass.quoted_table_name}.*" : column_name.to_s)]
          end


        relation.distinct(true)
        subquery = relation.arel.as(subquery_alias)

        sm = Arel::SelectManager.new relation.engine
        # CPK
        # select_value = operation_over_aggregate_column(column_alias, 'count', distinct)
        select_value = operation_over_aggregate_column(Arel.sql("*"), 'count', false)
        sm.project(select_value).from(subquery)
      end
    end
  end
end