Pass original adapter to percona adapter

departurerb · Jul 23, 2024 · e07b256 · e07b256
1 parent 2555087
commit e07b256
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lib/active_record/connection_adapters/percona_adapter.rb b/lib/active_record/connection_adapters/percona_adapter.rb
@@ -13,7 +13,7 @@ def percona_connection(config)
         config = config.dup if config.frozen?
         config[:username] = 'root'
       end
-      adapter = config[:adapter]
+      adapter = config[:original_adapter]
       connection = if Departure::SUPPORTED_ADAPTERS.include?(adapter)
                      send("#{adapter}_connection", config)
                    else

diff --git a/lib/departure/migration.rb b/lib/departure/migration.rb
@@ -77,7 +77,8 @@ def include_foreigner
     # instead of the current adapter.
     def reconnect_with_percona
       return if connection_config[:adapter] == 'percona'
-      Departure::ConnectionBase.establish_connection(connection_config.merge(adapter: 'percona'))
+      Departure::ConnectionBase.establish_connection(connection_config.merge(adapter: 'percona',
+                                                                             original_adapter: original_adapter))
     end
 
     # Reconnect without percona adapter when Departure is disabled but was