diff --git a/lib/active_record/connection_adapters/odbc_adapter.rb b/lib/active_record/connection_adapters/odbc_adapter.rb
index 8f4beec1..7d5d2372 100644
--- a/lib/active_record/connection_adapters/odbc_adapter.rb
+++ b/lib/active_record/connection_adapters/odbc_adapter.rb
@@ -80,6 +80,7 @@ def initialize(connection, logger, config, database_metadata)
         configure_time_options(connection)
         super(connection, logger, config)
         @database_metadata = database_metadata
+        @connection = connection
       end
 
       # Returns the human-readable name of the adapter.
diff --git a/lib/odbc_adapter/database_statements.rb b/lib/odbc_adapter/database_statements.rb
index cac31682..14327837 100644
--- a/lib/odbc_adapter/database_statements.rb
+++ b/lib/odbc_adapter/database_statements.rb
@@ -17,6 +17,10 @@ def execute(sql, name = nil, binds = [])
       end
     end
 
+    def internal_exec_query(sql, name = "SQL", binds = [], prepare: false, async: false) # :nodoc:
+      exec_query(sql, name, binds, prepare: prepare)
+    end
+
     # Executes +sql+ statement in the context of this connection using
     # +binds+ as the bind substitutes. +name+ is logged along with
     # the executed +sql+ statement.