#primary_keys
[ GitHub ]# File 'activerecord/lib/active_record/insert_all.rb', line 54
def primary_keys Array(connection.schema_cache.primary_keys(model.table_name)) end
123456789_123456789_123456789_123456789_123456789_
Relationships & Source Files | |
Namespace Children | |
Classes:
| |
Inherits: | Object |
Defined in: | activerecord/lib/active_record/insert_all.rb |
TODO: Consider renaming this method, as it only conditionally extends keys, not always.
InsertAll
# File 'activerecord/lib/active_record/insert_all.rb', line 10
def initialize(model, inserts, on_duplicate:, update_only: nil, returning: nil, unique_by: nil, record_timestamps: nil) @model, @connection, @inserts = model, model.connection, inserts.map(&:stringify_keys) @on_duplicate, @update_only, @returning, @unique_by = on_duplicate, update_only, returning, unique_by @record_timestamps = .nil? ? model. : disallow_raw_sql!(on_duplicate) disallow_raw_sql!(returning) if @inserts.empty? @keys = [] else resolve_sti resolve_attribute_aliases @keys = @inserts.first.keys end if model.scope_attributes? @scope_attributes = model.scope_attributes @keys |= @scope_attributes.keys end @keys = @keys.to_set @returning = (connection.supports_insert_returning? ? primary_keys : false) if @returning.nil? @returning = false if @returning == [] @unique_by = find_unique_index_for(@unique_by) configure_on_duplicate_update_logic end
Boolean
(readonly, private)
# File 'activerecord/lib/active_record/insert_all.rb', line 141
def custom_update_sql_provided? @custom_update_sql_provided ||= Arel.arel_node?(on_duplicate) end
# File 'activerecord/lib/active_record/insert_all.rb', line 7
attr_reader :model, :connection, :inserts, :keys
# File 'activerecord/lib/active_record/insert_all.rb', line 7
attr_reader :model, :connection, :inserts, :keys
# File 'activerecord/lib/active_record/insert_all.rb', line 7
attr_reader :model, :connection, :inserts, :keys
# File 'activerecord/lib/active_record/insert_all.rb', line 8
attr_reader :on_duplicate, :update_only, :returning, :unique_by, :update_sql
Boolean
(readonly)
# File 'activerecord/lib/active_record/insert_all.rb', line 81
def @record_timestamps end
# File 'activerecord/lib/active_record/insert_all.rb', line 8
attr_reader :on_duplicate, :update_only, :returning, :unique_by, :update_sql
# File 'activerecord/lib/active_record/insert_all.rb', line 95
attr_reader :scope_attributes
Boolean
(readonly)
# File 'activerecord/lib/active_record/insert_all.rb', line 59
def skip_duplicates? on_duplicate == :skip end
# File 'activerecord/lib/active_record/insert_all.rb', line 8
attr_reader :on_duplicate, :update_only, :returning, :unique_by, :update_sql
Boolean
(readonly)
# File 'activerecord/lib/active_record/insert_all.rb', line 63
def update_duplicates? on_duplicate == :update end
# File 'activerecord/lib/active_record/insert_all.rb', line 8
attr_reader :on_duplicate, :update_only, :returning, :unique_by, :update_sql
# File 'activerecord/lib/active_record/insert_all.rb', line 8
attr_reader :on_duplicate, :update_only, :returning, :unique_by, :update_sql
# File 'activerecord/lib/active_record/insert_all.rb', line 125
def configure_on_duplicate_update_logic if custom_update_sql_provided? && update_only.present? raise ArgumentError, "You can't set :update_only and provide custom update SQL via :on_duplicate at the same time" end if update_only.present? @updatable_columns = Array(update_only) @on_duplicate = :update elsif custom_update_sql_provided? @update_sql = on_duplicate @on_duplicate = :update elsif @on_duplicate == :update && updatable_columns.empty? @on_duplicate = :skip end end
# File 'activerecord/lib/active_record/insert_all.rb', line 209
def disallow_raw_sql!(value) return if !value.is_a?(String) || Arel.arel_node?(value) raise ArgumentError, "Dangerous query method (method whose arguments are used as raw " \ "SQL) called: #{value}. " \ "Known-safe values can be passed " \ "by wrapping them in Arel.sql()." end
# File 'activerecord/lib/active_record/insert_all.rb', line 170
def if returning && !connection.supports_insert_returning? raise ArgumentError, "#{connection.class} does not support :returning" end if skip_duplicates? && !connection.supports_insert_on_duplicate_skip? raise ArgumentError, "#{connection.class} does not support skipping duplicates" end if update_duplicates? && !connection.supports_insert_on_duplicate_update? raise ArgumentError, "#{connection.class} does not support upsert" end if unique_by && !connection.supports_insert_conflict_target? raise ArgumentError, "#{connection.class} does not support :unique_by" end end
# File 'activerecord/lib/active_record/insert_all.rb', line 41
def execute return ActiveRecord::Result.empty if inserts.empty? = +"#{model} " << "Bulk " if inserts.many? << (on_duplicate == :update ? "Upsert" : "Insert") connection.exec_insert_all to_sql, end
# File 'activerecord/lib/active_record/insert_all.rb', line 145
def find_unique_index_for(unique_by) if !connection.supports_insert_conflict_target? return if unique_by.nil? raise ArgumentError, "#{connection.class} does not support :unique_by" end name_or_columns = unique_by || model.primary_key match = Array(name_or_columns).map(&:to_s) sorted_match = match.sort if index = unique_indexes.find { |i| match.include?(i.name) || Array(i.columns).sort == sorted_match } index elsif match == primary_keys unique_by.nil? ? nil : ActiveRecord::ConnectionAdapters::IndexDefinition.new(model.table_name, "#{model.table_name}_primary_key", true, match) else raise ArgumentError, "No unique index found for #{name_or_columns}" end end
Boolean
(private)
TODO: Consider renaming this method, as it only conditionally extends keys, not always
# File 'activerecord/lib/active_record/insert_all.rb', line 67
def map_key_with_value inserts.map do |attributes| attributes = attributes.stringify_keys attributes.merge!(scope_attributes) if scope_attributes attributes.reverse_merge!( ) if verify_attributes(attributes) .map do |key| yield key, attributes[key] end end end
# File 'activerecord/lib/active_record/insert_all.rb', line 54
def primary_keys Array(connection.schema_cache.primary_keys(model.table_name)) end
# File 'activerecord/lib/active_record/insert_all.rb', line 194
def readonly_columns primary_keys + model.readonly_attributes.to_a end
# File 'activerecord/lib/active_record/insert_all.rb', line 121
def resolve_attribute_alias(attribute) model.attribute_alias(attribute) || attribute end
# File 'activerecord/lib/active_record/insert_all.rb', line 110
def resolve_attribute_aliases return unless has_attribute_aliases?(@inserts.first) @inserts = @inserts.map do |insert| insert.transform_keys { |attribute| resolve_attribute_alias(attribute) } end @update_only = Array(@update_only).map { |attribute| resolve_attribute_alias(attribute) } if @update_only @unique_by = Array(@unique_by).map { |attribute| resolve_attribute_alias(attribute) } if @unique_by end
# File 'activerecord/lib/active_record/insert_all.rb', line 218
def model. .index_with(connection. ) end
# File 'activerecord/lib/active_record/insert_all.rb', line 189
def to_sql connection.build_insert_sql(ActiveRecord::InsertAll::Builder.new(self)) end
# File 'activerecord/lib/active_record/insert_all.rb', line 165
def unique_indexes connection.schema_cache.indexes(model.table_name).select(&:unique) end
# File 'activerecord/lib/active_record/insert_all.rb', line 50
def updatable_columns @updatable_columns ||= keys - readonly_columns - unique_by_columns end
# File 'activerecord/lib/active_record/insert_all.rb', line 203
def verify_attributes(attributes) if != attributes.keys.to_set raise ArgumentError, "All objects being inserted must have the same keys" end end