Incorporate rails/rails#48109

lib/active_record/connection_adapters/trilogy_adapter.rb

@@ -5,7 +5,6 @@
 
 require "active_record/tasks/trilogy_database_tasks"
 require "active_record/connection_adapters/trilogy/database_statements"
-require "trilogy_adapter/lost_connection_exception_translator"
 
 module ActiveRecord
   # ActiveRecord <= 6.1 support
@@ -56,12 +55,21 @@ def resolve(config) # :nodoc:
         @resolver.resolve(config)
       end
     end
+
+    module ::ActiveRecord
+      class QueryAborted < ::ActiveRecord::StatementInvalid
+      end
+      class AdapterTimeout < ::ActiveRecord::QueryAborted
+      end
+    end
   end
 
   module ConnectionAdapters
     class TrilogyAdapter < ::ActiveRecord::ConnectionAdapters::AbstractMysqlAdapter
       ER_BAD_DB_ERROR = 1049
+      ER_DBACCESS_DENIED_ERROR = 1044
       ER_ACCESS_DENIED_ERROR = 1045
+      ER_SERVER_SHUTDOWN = 1053
 
       ADAPTER_NAME = "Trilogy"
 
@@ -340,16 +348,6 @@ def default_timezone
           end
         end
 
-        def translate_exception(exception, message:, sql:, binds:)
-          if exception.is_a?(::Trilogy::TimeoutError) && !exception.error_code
-            return ActiveRecord::AdapterTimeout.new(message, sql: sql, binds: binds)
-          end
-          error_code = exception.error_code if exception.respond_to?(:error_code)
-
-          ::TrilogyAdapter::LostConnectionExceptionTranslator.
-            new(exception, message, error_code).translate || super
-        end
-
         def default_prepared_statements
           false
         end

lib/activerecord-trilogy-adapter.rb

@@ -1,5 +1,4 @@
 # frozen_string_literal: true
 
 require "active_record"
-require "trilogy_adapter/errors"
 require "trilogy_adapter/railtie"

test/lib/active_record/connection_adapters/trilogy_adapter_test.rb

@@ -46,7 +46,7 @@ class ActiveRecord::ConnectionAdapters::TrilogyAdapterTest < TestCase
 
   test ".new_client on access denied error" do
     configuration = @configuration.merge(username: "unknown")
-    assert_raises ActiveRecord::DatabaseConnectionError do
+    assert_raises Trilogy::QueryError do
       @adapter.class.new_client(configuration)
     end
   end
@@ -457,7 +457,7 @@ class Post < ActiveRecord::Base; end
     server_shutdown_error.instance_variable_set(:@error_code, 1053)
     mock_connection.expect(:query, nil) { raise server_shutdown_error }
 
-    assert_raises(TrilogyAdapter::Errors::ServerShutdown) do
+    assert_raises(ActiveRecord::StatementInvalid) do
       adapter.execute "SELECT * FROM posts;"
     end
 
@@ -772,13 +772,13 @@ class Post < ActiveRecord::Base; end
     assert_equal 123, @adapter.send(:error_number, exception)
   end
 
-  test "read timeout raises ActiveRecord::AdapterTimeout" do
+  test "read timeout raises ActiveRecord::StatementInvalid" do
     ActiveRecord::Base.establish_connection(@configuration.merge("read_timeout" => 1))
 
-    error = assert_raises(ActiveRecord::AdapterTimeout) do
+    error = assert_raises(ActiveRecord::StatementInvalid) do
       ActiveRecord::Base.connection.execute("SELECT SLEEP(2)")
     end
-    assert_kind_of ActiveRecord::QueryAborted, error
+    assert_kind_of ActiveRecord::StatementInvalid, error
 
     assert_equal Trilogy::TimeoutError, error.cause.class
   end