Sha256: c7f9c71f373c6fc365064d98065e3b69c467a85b28fd09aa49273d37f01740fa
Contents?: true
Size: 900 Bytes
Versions: 44
Compression:
Stored size: 900 Bytes
Contents
require "pact_broker/db/data_migrations/helpers"
module PactBroker
module DB
module DataMigrations
class SetConsumerVersionOrderForPactPublications
extend Helpers
def self.call connection
if required_columns_exist?(connection)
connection.from(:pact_publications)
.where(consumer_version_order: nil)
.update(
consumer_version_order: connection.from(:versions)
.select(:order)
.where(Sequel[:versions][:id] => Sequel[:pact_publications][:consumer_version_id])
)
end
end
def self.required_columns_exist?(connection)
columns_exist?(connection, :pact_publications, [:consumer_version_id, :consumer_version_order]) &&
columns_exist?(connection, :versions, [:id, :order])
end
end
end
end
end
Version data entries
44 entries across 44 versions & 1 rubygems