Sha256: 7e8c38eec4b576d2498381f1d9705e070395c26535082b2d471b8164790dd9c2

Contents?: true

Size: 1.61 KB

Versions: 1

Compression:

Stored size: 1.61 KB

Contents

class Upsert
  # @private
  class ColumnDefinition
    class << self
      # activerecord-3.2.X/lib/active_record/connection_adapters/XXXXXXXXX_adapter.rb#column_definitions
      def all(connection, table_name)
        raise "not impl"
      end
    end

    TIME_DETECTOR = /date|time/i

    attr_reader :name
    attr_reader :sql_type
    attr_reader :default
    attr_reader :quoted_name
    attr_reader :quoted_selector_name
    attr_reader :quoted_setter_name

    def initialize(connection, name, sql_type, default)
      @name = name
      @sql_type = sql_type
      @temporal_query = !!(sql_type =~ TIME_DETECTOR)
      @default = default
      @quoted_name = connection.quote_ident name
      @quoted_selector_name = connection.quote_ident "#{name}_sel"
      @quoted_setter_name = connection.quote_ident "#{name}_set"
    end

    def to_selector_arg
      "#{quoted_selector_name} #{arg_type}"
    end

    def to_setter_arg
      "#{quoted_setter_name} #{arg_type}"
    end

    def to_setter
      "#{quoted_name} = #{to_setter_value}"
    end

    def to_selector
      if temporal?
        "#{quoted_name} = CAST(#{quoted_selector_name} AS #{sql_type})"
      else
        equality(quoted_name, quoted_selector_name)
      end
    end

    def temporal?
      @temporal_query
    end

    def equality(left, right)
      "#{left} = #{right}"
    end

    def arg_type
      if temporal?
        'character varying(255)'
      else
        sql_type
      end
    end

    def to_setter_value
      if temporal?
        "CAST(#{quoted_setter_name} AS #{sql_type})"
      else
        quoted_setter_name
      end
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
upsert-2.0.2 lib/upsert/column_definition.rb