v6.1.0

Author: Praveen Narayanappa

IBM_DB_Adapter/ibm_db/test/active_record/connection_adapters/fake_adapter.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module ActiveRecord
   module ConnectionHandling
     def fake_connection(config)
@@ -9,7 +11,7 @@ module ConnectionAdapters
     class FakeAdapter < AbstractAdapter
       attr_accessor :data_sources, :primary_keys
 
-      @columns = Hash.new { |h,k| h[k] = [] }
+      @columns = Hash.new { |h, k| h[k] = [] }
       class << self
         attr_reader :columns
       end
@@ -30,7 +32,8 @@ def merge_column(table_name, name, sql_type = nil, options = {})
           name.to_s,
           options[:default],
           fetch_type_metadata(sql_type),
-          options[:null])
+          options[:null],
+        )
       end
 
       def columns(table_name)

IBM_DB_Adapter/ibm_db/test/activejob/destroy_association_async_test.rb

@@ -0,0 +1,305 @@
+# frozen_string_literal: true
+
+require "activejob/helper"
+
+require "models/book_destroy_async"
+require "models/essay_destroy_async"
+require "models/tag"
+require "models/tagging"
+require "models/essay"
+require "models/category"
+require "models/post"
+require "models/content"
+require "models/destroy_async_parent"
+require "models/destroy_async_parent_soft_delete"
+require "models/dl_keyed_belongs_to"
+require "models/dl_keyed_belongs_to_soft_delete"
+require "models/dl_keyed_has_one"
+require "models/dl_keyed_join"
+require "models/dl_keyed_has_many"
+require "models/dl_keyed_has_many_through"
+
+class DestroyAssociationAsyncTest < ActiveRecord::TestCase
+  self.use_transactional_tests = false
+
+  include ActiveJob::TestHelper
+
+  test "destroying a record destroys the has_many :through records using a job" do
+    tag = Tag.create!(name: "Der be treasure")
+    tag2 = Tag.create!(name: "Der be rum")
+    book = BookDestroyAsync.create!
+    book.tags << [tag, tag2]
+    book.save!
+
+    book.destroy
+
+    assert_difference -> { Tag.count }, -2 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    Tag.delete_all
+    BookDestroyAsync.delete_all
+  end
+
+  test "destroying a scoped has_many through only deletes within the scope deleted" do
+    tag = Tag.create!(name: "Der be treasure")
+    tag2 = Tag.create!(name: "Der be rum")
+    parent = BookDestroyAsyncWithScopedTags.create!
+    parent.tags << [tag, tag2]
+    parent.save!
+
+    parent.reload # force the association to be reloaded
+
+    parent.destroy
+
+    assert_difference -> { Tag.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+    assert_raises ActiveRecord::RecordNotFound do
+      tag2.reload
+    end
+    assert tag.reload
+  ensure
+    Tag.delete_all
+    Tagging.delete_all
+    BookDestroyAsyncWithScopedTags.delete_all
+  end
+
+  test "enqueues the has_many through to be deleted with custom primary key" do
+    dl_keyed_has_many = DlKeyedHasManyThrough.create!
+    dl_keyed_has_many2 = DlKeyedHasManyThrough.create!
+    parent = DestroyAsyncParent.create!
+    parent.dl_keyed_has_many_through << [dl_keyed_has_many2, dl_keyed_has_many]
+    parent.save!
+    parent.destroy
+
+    assert_difference -> { DlKeyedJoin.count }, -2 do
+     assert_difference -> { DlKeyedHasManyThrough.count }, -2 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+   end
+  ensure
+    DlKeyedHasManyThrough.delete_all
+    DestroyAsyncParent.delete_all
+    DlKeyedJoin.delete_all
+  end
+
+  test "belongs to" do
+    essay = EssayDestroyAsync.create!(name: "Der be treasure")
+    book = BookDestroyAsync.create!(name: "Arr, matey!")
+    essay.book = book
+    essay.save!
+    essay.destroy
+
+    assert_difference -> { BookDestroyAsync.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    EssayDestroyAsync.delete_all
+    BookDestroyAsync.delete_all
+  end
+
+  test "enqueues belongs_to to be deleted with custom primary key" do
+    belongs = DlKeyedBelongsTo.create!
+    parent = DestroyAsyncParent.create!
+    belongs.destroy_async_parent = parent
+    belongs.save!
+    belongs.destroy
+
+    assert_difference -> { DestroyAsyncParent.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    DlKeyedBelongsTo.delete_all
+    DestroyAsyncParent.delete_all
+  end
+
+  test "has_one" do
+    content = Content.create(title: "hello")
+    book = BookDestroyAsync.create!(name: "Arr, matey!")
+    book.content = content
+    book.save!
+    book.destroy
+
+    assert_difference -> { Content.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    Content.delete_all
+    BookDestroyAsync.delete_all
+  end
+
+
+  test "enqueues has_one to be deleted with custom primary key" do
+    child = DlKeyedHasOne.create!
+    parent = DestroyAsyncParent.create!
+    parent.dl_keyed_has_one = child
+    parent.save!
+    parent.destroy
+
+    assert_difference -> { DlKeyedHasOne.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    DlKeyedHasOne.delete_all
+    DestroyAsyncParent.delete_all
+  end
+
+
+  test "has_many" do
+    essay = EssayDestroyAsync.create!(name: "Der be treasure")
+    essay2 = EssayDestroyAsync.create!(name: "Der be rum")
+    book = BookDestroyAsync.create!(name: "Arr, matey!")
+    book.essays << [essay, essay2]
+    book.save!
+    book.destroy
+
+    assert_difference -> { EssayDestroyAsync.count }, -2 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    EssayDestroyAsync.delete_all
+    BookDestroyAsync.delete_all
+  end
+
+  test "has_many with sti parent class destroys all children class records" do
+    book = BookDestroyAsync.create!
+    LongEssayDestroyAsync.create!(book: book)
+    ShortEssayDestroyAsync.create!(book: book)
+    book.destroy
+
+    assert_difference -> { EssayDestroyAsync.count }, -2 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  end
+
+  test "enqueues the has_many to be deleted with custom primary key" do
+    dl_keyed_has_many = DlKeyedHasMany.new
+    parent = DestroyAsyncParent.create!
+    parent.dl_keyed_has_many << [dl_keyed_has_many]
+
+    parent.save!
+    parent.destroy
+
+    assert_difference -> { DlKeyedHasMany.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    DlKeyedHasMany.delete_all
+    DestroyAsyncParent.delete_all
+  end
+
+  test "not enqueue the job if transaction is not committed" do
+    dl_keyed_has_many = DlKeyedHasMany.new
+    parent = DestroyAsyncParent.create!
+    parent.dl_keyed_has_many << [dl_keyed_has_many]
+
+    parent.save!
+    assert_no_enqueued_jobs do
+      DestroyAsyncParent.transaction do
+        parent.destroy
+        raise ActiveRecord::Rollback
+      end
+    end
+  ensure
+    DlKeyedHasMany.delete_all
+    DestroyAsyncParent.delete_all
+  end
+
+  test "has many ensures function for parent" do
+    tag = Tag.create!(name: "Der be treasure")
+    tag2 = Tag.create!(name: "Der be rum")
+    parent = DestroyAsyncParentSoftDelete.create!
+    parent.tags << [tag, tag2]
+    parent.save!
+
+    parent.run_callbacks(:destroy)
+    parent.run_callbacks(:commit)
+
+    assert_no_difference -> { Tag.count } do
+      assert_raises ActiveRecord::DestroyAssociationAsyncError do
+        perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+      end
+    end
+
+    parent.destroy
+    assert_difference -> { Tag.count }, -2 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    Tag.delete_all
+    DestroyAsyncParentSoftDelete.delete_all
+  end
+
+  test "has one ensures function for parent" do
+    child = DlKeyedHasOne.create!
+    parent = DestroyAsyncParentSoftDelete.create!
+    parent.dl_keyed_has_one = child
+    parent.save!
+
+    parent.run_callbacks(:destroy)
+    parent.run_callbacks(:commit)
+
+    assert_no_difference -> { DlKeyedHasOne.count } do
+      assert_raises ActiveRecord::DestroyAssociationAsyncError do
+        perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+      end
+    end
+
+    parent.destroy
+    assert_difference -> { DlKeyedHasOne.count }, -1 do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+  ensure
+    DlKeyedHasOne.delete_all
+    DestroyAsyncParentSoftDelete.delete_all
+  end
+
+  test "enqueues belongs_to to be deleted with ensuring function" do
+    belongs = DlKeyedBelongsToSoftDelete.create!
+    parent = DestroyAsyncParentSoftDelete.create!
+    belongs.destroy_async_parent_soft_delete = parent
+    belongs.save!
+
+    belongs.run_callbacks(:destroy)
+    belongs.run_callbacks(:commit)
+
+    assert_raises ActiveRecord::DestroyAssociationAsyncError do
+      perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    end
+
+    assert_not parent.reload.deleted?
+
+    belongs.destroy
+    perform_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+    assert parent.reload.deleted?
+  ensure
+    DlKeyedBelongsToSoftDelete.delete_all
+    DestroyAsyncParentSoftDelete.delete_all
+  end
+
+  test "Don't enqueue with no relations" do
+    parent = DestroyAsyncParent.create!
+    parent.destroy
+
+    assert_no_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+  ensure
+    DestroyAsyncParent.delete_all
+  end
+
+  test "Rollback prevents jobs from being enqueued" do
+    tag = Tag.create!(name: "Der be treasure")
+    tag2 = Tag.create!(name: "Der be rum")
+    book = BookDestroyAsync.create!
+    book.tags << [tag, tag2]
+    book.save!
+    ActiveRecord::Base.transaction do
+      book.destroy
+      raise ActiveRecord::Rollback
+    end
+    assert_no_enqueued_jobs only: ActiveRecord::DestroyAssociationAsyncJob
+  end
+ensure
+  Tag.delete_all
+  BookDestroyAsync.delete_all
+end

IBM_DB_Adapter/ibm_db/test/activejob/destroy_async_job_not_present_test.rb

@@ -0,0 +1,31 @@
+# frozen_string_literal: true
+
+require "cases/helper"
+
+class UnusedDestroyAsync < ActiveRecord::Base
+  self.destroy_association_async_job = nil
+end
+
+class UnusedBelongsTo < ActiveRecord::Base
+  self.destroy_association_async_job = nil
+end
+
+class ActiveJobNotPresentTest < ActiveRecord::TestCase
+  test "has_one dependent destroy_async requires activejob" do
+    assert_raises ActiveRecord::ActiveJobRequiredError do
+      UnusedDestroyAsync.has_one :unused_belongs_to, dependent: :destroy_async
+    end
+  end
+
+  test "has_many dependent destroy_async requires activejob" do
+    assert_raises ActiveRecord::ActiveJobRequiredError do
+      UnusedDestroyAsync.has_many :essay_destroy_asyncs, dependent: :destroy_async
+    end
+  end
+
+  test "belong_to dependent destroy_async requires activejob" do
+    assert_raises ActiveRecord::ActiveJobRequiredError do
+      UnusedBelongsTo.belongs_to :unused_destroy_asyncs, dependent: :destroy_async
+    end
+  end
+end

IBM_DB_Adapter/ibm_db/test/activejob/helper.rb

@@ -0,0 +1,15 @@
+# frozen_string_literal: true
+
+require "cases/helper"
+
+require "global_id"
+GlobalID.app = "ActiveRecordExampleApp"
+ActiveRecord::Base.include GlobalID::Identification
+
+require "active_job"
+ActiveJob::Base.queue_adapter = :test
+ActiveJob::Base.logger = ActiveSupport::Logger.new(nil)
+
+require_relative "../../../tools/test_common"
+
+ActiveRecord::Base.destroy_association_async_job = ActiveRecord::DestroyAssociationAsyncJob