diff --git a/lib/active_record/connection_adapters/clickhouse/schema_statements.rb b/lib/active_record/connection_adapters/clickhouse/schema_statements.rb index 60799a2c..cd7727fd 100644 --- a/lib/active_record/connection_adapters/clickhouse/schema_statements.rb +++ b/lib/active_record/connection_adapters/clickhouse/schema_statements.rb @@ -47,6 +47,12 @@ def execute(sql, name = nil, format: @response_format, settings: {}) end end + def execute_batch(statements, name = nil, **kwargs) + statements.each do |statement| + execute(statement, name, **kwargs) + end + end + def exec_insert(sql, name = nil, _binds = [], _pk = nil, _sequence_name = nil, returning: nil) new_sql = sql.sub(/ (DEFAULT )?VALUES/, " VALUES") with_response_format(nil) { execute(new_sql, name) }