82 lines
3.5 KiB
Ruby
82 lines
3.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# License: AGPL-3.0-or-later WITH WTO-AP-3.0-or-later
|
|
# Full license explanation at https://github.com/houdiniproject/houdini/blob/master/LICENSE
|
|
require 'rspec'
|
|
require 'rails_helper'
|
|
|
|
describe 'DeleteCustomFieldJoin' do
|
|
it 'copying should be safe and reverable' do
|
|
skip 'this code is only valuable if you are on migration "20170805180556_add_the_tag_joins_backup_table.rb" but before "20170805180557_add_index_for_tag_joins_and_add_constraint.rb"'
|
|
build(:custom_field_join, supporter_id: 100, custom_field_master_id: 200).save(validate: false)
|
|
|
|
last_times_for_supporter_ids = {}
|
|
3.times do |j|
|
|
j += 1
|
|
5.times do |i|
|
|
i += 1
|
|
time = DateTime.now.advance(seconds: -j * i)
|
|
last_times_for_supporter_ids[i] = time if j == 1
|
|
build(:custom_field_join, supporter_id: i, custom_field_master_id: i + 1, updated_at: time).save(validate: false)
|
|
end
|
|
end
|
|
|
|
expect(CustomFieldJoin.count).to eq(16)
|
|
|
|
qx_results = Qx.select("CONCAT(custom_field_joins.supporter_id, '_', custom_field_joins.custom_field_master_id) AS our_concat, COUNT(id) AS our_count")
|
|
.from(:custom_field_joins)
|
|
.group_by('our_concat')
|
|
.having('COUNT(id) > 1')
|
|
.execute
|
|
|
|
expect(qx_results.count).to eq(5)
|
|
|
|
tag_joins_from_qx = CustomFieldJoin.where("CONCAT(supporter_id, '_', custom_field_master_id) IN (?)", qx_results.map { |i| i['our_concat'] })
|
|
|
|
expect(tag_joins_from_qx.count).to eq(15)
|
|
|
|
expect(tag_joins_from_qx.count).to eq(qx_results.sum { |r| r['our_count'] })
|
|
|
|
tag_join_groups = CustomFieldJoin.all.to_a.group_by { |tj| "#{tj.supporter_id}_#{tj.custom_field_master_id}" }.select { |_k, v| v.count > 1 }.to_a
|
|
|
|
expect(qx_results.count).to eq(tag_join_groups.length)
|
|
|
|
expect(tag_join_groups.sum { |_, v| v.count }).to eq(qx_results.sum { |r| r['our_count'] })
|
|
|
|
grouped_tagged_joins = tag_joins_from_qx.group_by { |tj| "#{tj.supporter_id}_#{tj.custom_field_master_id}" }
|
|
|
|
ids_to_delete = DeleteCustomFieldJoins.find_multiple_custom_field_joins
|
|
our_test_cfj = CustomFieldJoin.find(ids_to_delete)
|
|
DeleteCustomFieldJoins.copy_and_delete(ids_to_delete)
|
|
|
|
expect(CustomFieldJoin.count).to eq(6)
|
|
|
|
last_times_for_supporter_ids.each do |k, v|
|
|
results = CustomFieldJoin.where('supporter_id = ? and custom_field_master_id = ?', k, k + 1)
|
|
expect(results.count).to eq(1)
|
|
|
|
expect(results.first.updated_at).to eq(v)
|
|
end
|
|
|
|
expect(CustomFieldJoin.where('supporter_id = ? and custom_field_master_id = ?', 100, 200).count).to eq 1
|
|
|
|
5.times do |i|
|
|
i += 1
|
|
|
|
expect(CustomFieldJoin.where('supporter_id = ? and custom_field_master_id =? ', i, i + 1).count).to eq 1
|
|
end
|
|
|
|
expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).execute[0]['count']).to eq ids_to_delete.count
|
|
|
|
expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).where('id NOT IN ($ids)', ids: ids_to_delete).execute[0]['count']).to eq(0)
|
|
|
|
expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).where('id IN ($ids)', ids: ids_to_delete).execute[0]['count']).to eq(ids_to_delete.count)
|
|
|
|
expect(Qx.select('*').from(:custom_field_joins_backup).where('id IN ($id)', id: ids_to_delete).execute).to match_array(our_test_cfj.map(&:attributes))
|
|
|
|
DeleteCustomFieldJoins.revert
|
|
expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).execute[0]['count']).to eq 0
|
|
expect(CustomFieldJoin.count).to eq(16)
|
|
expect(CustomFieldJoin.find(ids_to_delete)).to match_array(our_test_cfj)
|
|
end
|
|
end
|