Revert "Merge pull request rails#44531 from matthewd/rm-mark-written"

This reverts commit 199fe99, reversing
changes made to d49f956.

Author: matthewd

activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb

@@ -326,6 +326,13 @@ def transaction(requires_new: nil, isolation: nil, joinable: true, &block)
                :disable_lazy_transactions!, :enable_lazy_transactions!, :dirty_current_transaction,
                to: :transaction_manager
 
+      def mark_transaction_written_if_write(sql) # :nodoc:
+        transaction = current_transaction
+        if transaction.open?
+          transaction.written ||= write_query?(sql)
+        end
+      end
+
       def transaction_open?
         current_transaction.open?
       end

activerecord/lib/active_record/connection_adapters/abstract/transaction.rb

@@ -87,6 +87,7 @@ def dirty!; end
 
     class Transaction # :nodoc:
       attr_reader :connection, :state, :savepoint_name, :isolation_level
+      attr_accessor :written
 
       def initialize(connection, isolation: nil, joinable: true, run_commit_callbacks: false)
         @connection = connection
@@ -419,7 +420,7 @@ def within_new_transaction(isolation: nil, joinable: true)
               # @connection still holds an open or invalid transaction, so we must not
               # put it back in the pool for reuse.
               @connection.throw_away! unless transaction.state.rolledback?
-            elsif Thread.current.status == "aborting" || !completed
+            elsif Thread.current.status == "aborting" || (!completed && transaction.written)
               # The transaction is still open but the block returned earlier.
               #
               # The block could return early because of a timeout or because the thread is aborting,

activerecord/lib/active_record/connection_adapters/abstract_mysql_adapter.rb

@@ -644,6 +644,7 @@ def extended_type_map_key
 
         def raw_execute(sql, name, async: false)
           materialize_transactions
+          mark_transaction_written_if_write(sql)
 
           log(sql, name, async: async) do
             ActiveSupport::Dependencies.interlock.permit_concurrent_loads do

activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb

@@ -168,6 +168,7 @@ def exec_stmt_and_free(sql, name, binds, cache_stmt: false, async: false)
             check_if_write_query(sql)
 
             materialize_transactions
+            mark_transaction_written_if_write(sql)
 
             # make sure we carry over any changes to ActiveRecord.default_timezone that have been
             # made since we established the connection

activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb

@@ -12,6 +12,7 @@ def explain(arel, binds = [])
         # Queries the database and returns the results in an Array-like object
         def query(sql, name = nil) # :nodoc:
           materialize_transactions
+          mark_transaction_written_if_write(sql)
 
           log(sql, name) do
             ActiveSupport::Dependencies.interlock.permit_concurrent_loads do
@@ -40,6 +41,7 @@ def execute(sql, name = nil)
           check_if_write_query(sql)
 
           materialize_transactions
+          mark_transaction_written_if_write(sql)
 
           log(sql, name) do
             ActiveSupport::Dependencies.interlock.permit_concurrent_loads do

activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb

@@ -760,6 +760,7 @@ def execute_and_clear(sql, name, binds, prepare: false, async: false)
 
         def exec_no_cache(sql, name, binds, async: false)
           materialize_transactions
+          mark_transaction_written_if_write(sql)
 
           # make sure we carry over any changes to ActiveRecord.default_timezone that have been
           # made since we established the connection
@@ -775,6 +776,7 @@ def exec_no_cache(sql, name, binds, async: false)
 
         def exec_cache(sql, name, binds, async: false)
           materialize_transactions
+          mark_transaction_written_if_write(sql)
           update_typemap_for_default_timezone
 
           stmt_key = prepare_statement(sql, binds)

activerecord/lib/active_record/connection_adapters/sqlite3/database_statements.rb

@@ -25,6 +25,7 @@ def execute(sql, name = nil) # :nodoc:
           check_if_write_query(sql)
 
           materialize_transactions
+          mark_transaction_written_if_write(sql)
 
           log(sql, name) do
             ActiveSupport::Dependencies.interlock.permit_concurrent_loads do
@@ -38,6 +39,7 @@ def exec_query(sql, name = nil, binds = [], prepare: false, async: false) # :nod
           check_if_write_query(sql)
 
           materialize_transactions
+          mark_transaction_written_if_write(sql)
 
           type_casted_binds = type_casted_binds(binds)
 
@@ -121,6 +123,7 @@ def execute_batch(statements, name = nil)
             check_if_write_query(sql)
 
             materialize_transactions
+            mark_transaction_written_if_write(sql)
 
             log(sql, name) do
               ActiveSupport::Dependencies.interlock.permit_concurrent_loads do