lib/sequel/adapters/shared/mysql.rb in sequel-4.5.0 vs lib/sequel/adapters/shared/mysql.rb in sequel-4.6.0

@@ -48,12 +48,12 @@
         CAST_TYPES[type] || super
       end
 
       # Commit an existing prepared transaction with the given transaction
       # identifier string.
-      def commit_prepared_transaction(transaction_id)
-        run("XA COMMIT #{literal(transaction_id)}")
+      def commit_prepared_transaction(transaction_id, opts=OPTS)
+        run("XA COMMIT #{literal(transaction_id)}", opts)
       end
 
       # MySQL uses the :mysql database type
       def database_type
         :mysql
@@ -110,11 +110,11 @@
         indexes.reject{|k,v| remove_indexes.include?(k)}
       end
 
       # Rollback an existing prepared transaction with the given transaction
       # identifier string.
-      def rollback_prepared_transaction(transaction_id)
-        run("XA ROLLBACK #{literal(transaction_id)}")
+      def rollback_prepared_transaction(transaction_id, opts=OPTS)
+        run("XA ROLLBACK #{literal(transaction_id)}", opts)
       end
 
       # Get version of MySQL server, used for determined capabilities.
       def server_version
         @server_version ||= begin