Insert All - crashtech/torque-postgresql GitHub Wiki

Small extension to the upsert_all method to support the WHERE filtering which records will be updated. PostgreSQL Docs (condition clause)

How to

When executing your upsert_all operation, just add the extra where: keyword argument with the desired SQL expression.

Tag.upsert_all([{ id: 1, name: 'Tag 10' }, { id: 2, name: 'Tag 20' }], where: 'tags.id >= 2')

So far it does not support the use of scopes or model-based query like Tag.where(enabled: true).

When to use

The best place to use such a feature is when your table is set to use Optimistic Locking. In one operation you can insert multiple records, guarantee that stale objects are not updated, and get the id of those that were updated (then figure out those that were not).

class Tag < ActiveRecord::Base
  self.locking_column = :version
end

entries = [{ id: 1, name: 'Tag 10' }, { id: 2, name: 'Tag 20' }]

result = Tag.upsert_all(entries, where: 'tags.version <= excluded.version')
result.rows.flatten                                            # ["1"] these are the ids of the records successfully updated
result.rows.flatten - entries.map { |entry| entry[:id] }       # ["2"] these are the ids of the records that were not updated