Debugging for ODBC::Statement was not dropped

Author: jyothu

lib/active_record/connection_adapters/sqlserver/database_statements.rb

@@ -55,9 +55,12 @@ def raw_execute(sql, name = nil, binds = [], prepare: false, async: false, allow
         end
 
         def internal_exec_sql_query(sql, conn)
+          warn "[EXEC_SQL] run sql=#{sql}"
           handle = raw_connection_run(sql, conn)
+          warn "[EXEC_SQL] got handle=#{handle.object_id}"
           handle_to_names_and_values(handle, ar_result: true)
         ensure
+          warn "[EXEC_SQL] ensure finish handle=#{handle&.object_id}"
           finish_statement_handle(handle)
         end
 
@@ -429,9 +432,12 @@ def identity_columns(table_name)
         # === SQLServer Specific (Selecting) ============================ #
 
         def _raw_select(sql, conn)
+          warn "[RAW_SELECT] run sql=#{sql}"
           handle = raw_connection_run(sql, conn)
+          warn "[RAW_SELECT] got handle=#{handle.object_id}"
           handle_to_names_and_values(handle, fetch: :rows)
         ensure
+          warn "[RAW_SELECT] ensure finish handle=#{handle&.object_id}"
           finish_statement_handle(handle)
         end
 
@@ -464,6 +470,7 @@ def handle_to_names_and_values_dblib(handle, options = {})
         end
 
         def handle_to_names_and_values_odbc(handle, options = {})
+          warn "[HANDLE NAMES AND VALUES] handle=#{handle.object_id}"
           @raw_connection.use_utc = ActiveRecord.default_timezone || :utc
 
           if options[:ar_result]
@@ -478,14 +485,24 @@ def handle_to_names_and_values_odbc(handle, options = {})
               handle.fetch_all || []
             end
           end
+        ensure
+          finish_statement_handle(handle)
         end
 
         def finish_statement_handle(handle)
+          return unless handle
+
           case @config[:mode].to_sym
           when :dblib
-            handle.cancel if handle
+            warn "[FINISH] cancel handle=#{handle.object_id}"
+            handle.cancel
           when :odbc
-            handle.drop if handle && handle.respond_to?(:drop) && !handle.finished?
+            if handle.respond_to?(:drop) && !handle.finished?
+              warn "[FINISH] drop handle=#{handle.object_id}"
+              handle.drop
+            else
+              warn "[FINISH] skip drop handle=#{handle.object_id} (finished?=#{handle.respond_to?(:finished?) ? handle.finished? : 'n/a'})"
+            end
           end
 
           handle
@@ -527,10 +544,12 @@ def execute_dblib_procedure(sql, conn)
         def execute_odbc_procedure(sql, conn)
           results = []
           handle = nil
+          warn "[PROC] run sql=#{sql}"
 
           begin
             internal_raw_execute_odbc(sql, conn) do |h|
               handle = h
+              warn "[PROC] inside block handle=#{handle.object_id}"
 
               loop do
                 rows = handle_to_names_and_values(handle, fetch: :all)
@@ -539,6 +558,7 @@ def execute_odbc_procedure(sql, conn)
                 break unless handle_more_results?(handle)
               end
             end
+            warn "[PROC] finish block handle=#{handle.object_id}"
           ensure
             finish_statement_handle(handle)
           end