diff --git a/Gemfile.lock b/Gemfile.lock index 373044a..3346c15 100644 --- a/Gemfile.lock +++ b/Gemfile.lock @@ -11,7 +11,7 @@ GIT PATH remote: . specs: - umbrellio-utils (1.13.0) + umbrellio-utils (1.13.1) memery (~> 1) GEM diff --git a/lib/umbrellio_utils/click_house/backends/native.rb b/lib/umbrellio_utils/click_house/backends/native.rb index 65b369d..347b36f 100644 --- a/lib/umbrellio_utils/click_house/backends/native.rb +++ b/lib/umbrellio_utils/click_house/backends/native.rb @@ -23,24 +23,24 @@ class Native < Base UNKNOWN_TABLE = 60 UNKNOWN_DATABASE = 81 - def execute(sql, host: nil, **_opts) # rubocop:disable Lint/UnusedMethodArgument + def execute(sql, host: nil, **opts) # rubocop:disable Lint/UnusedMethodArgument sql_string = sql.is_a?(String) ? sql : sql.sql - log_errors(sql_string) { pool.execute(sql_string) } + log_errors(sql_string) { pool.execute(sql_string, settings: opts) } end - def query(dataset, host: nil, **_opts) # rubocop:disable Lint/UnusedMethodArgument + def query(dataset, host: nil, **opts) # rubocop:disable Lint/UnusedMethodArgument sql = sql_for(dataset) - log_errors(sql) { pool.query(sql) } + log_errors(sql) { pool.query(sql, settings: opts) } end - def query_value(dataset, host: nil, **_opts) # rubocop:disable Lint/UnusedMethodArgument + def query_value(dataset, host: nil, **opts) # rubocop:disable Lint/UnusedMethodArgument sql = sql_for(dataset) - log_errors(sql) { pool.query_value(sql) } + log_errors(sql) { pool.query_value(sql, settings: opts) } end - def query_each(dataset, host: nil, **_opts, &) # rubocop:disable Lint/UnusedMethodArgument + def query_each(dataset, host: nil, **opts, &) # rubocop:disable Lint/UnusedMethodArgument sql = sql_for(dataset) - log_errors(sql) { pool.query_each(sql, &) } + log_errors(sql) { pool.query_each(sql, settings: opts, &) } end def insert(table_name, db_name: self.db_name, rows: []) diff --git a/lib/umbrellio_utils/version.rb b/lib/umbrellio_utils/version.rb index 040173a..715b608 100644 --- a/lib/umbrellio_utils/version.rb +++ b/lib/umbrellio_utils/version.rb @@ -1,5 +1,5 @@ # frozen_string_literal: true module UmbrellioUtils - VERSION = "1.13.0" + VERSION = "1.13.1" end