Specify no format in :exec_insert and :exec_insert_all instead of inf…

…erring within FormatManager

lib/active_record/connection_adapters/clickhouse/schema_statements.rb

@@ -18,7 +18,7 @@ def with_settings(**settings)
 
         # Request a specific format for the duration of the provided block.
         # Pass `nil` to explicitly send the SQL statement without a `FORMAT` clause.
-        # @param [String] format
+        # @param [String, nil] format
         #
         # @example Specify CSVWithNamesAndTypes format
         #   with_response_format('CSVWithNamesAndTypes') do
@@ -49,7 +49,7 @@ def execute(sql, name = nil, format: @response_format, settings: {})
 
         def exec_insert(sql, name, _binds, _pk = nil, _sequence_name = nil, returning: nil)
           new_sql = sql.sub(/ (DEFAULT )?VALUES/, " VALUES")
-          execute(new_sql, name)
+          with_response_format(nil) { execute(new_sql, name) }
           true
         end
 
@@ -70,7 +70,7 @@ def internal_exec_query(sql, name = nil, binds = [], prepare: false, async: fals
         end
 
         def exec_insert_all(sql, name)
-          execute(sql, name)
+          with_response_format(nil) { execute(sql, name) }
           true
         end
 

lib/active_record/connection_adapters/clickhouse/statement/format_manager.rb

@@ -7,7 +7,7 @@ class Statement
         class FormatManager
 
           def initialize(sql, format:)
-            @sql = sql
+            @sql = sql.strip
             @format = format
           end
 
@@ -18,29 +18,25 @@ def apply
           end
 
           def skip_format?
-            for_insert? || system_command? || schema_command? || format_specified? || delete?
+            system_command? || schema_command? || format_specified? || delete?
           end
 
           private
 
-          def for_insert?
-            /^insert into/i.match?(@sql)
-          end
-
           def system_command?
-            /^system|^optimize/i.match?(@sql)
+            /\Asystem|\Aoptimize/i.match?(@sql)
           end
 
           def schema_command?
-            /^create|^alter|^drop|^rename/i.match?(@sql)
+            /\Acreate|\Aalter|\Adrop|\Arename/i.match?(@sql)
           end
 
           def format_specified?
             /format [a-z]+\z/i.match?(@sql)
           end
 
           def delete?
-            /^delete from/i.match?(@sql)
+            /\Adelete from/i.match?(@sql)
           end
 
         end