diff --git a/lib/active_record/connection_adapters/oracle_enhanced/database_statements.rb b/lib/active_record/connection_adapters/oracle_enhanced/database_statements.rb index 33feb53a0..541446338 100644 --- a/lib/active_record/connection_adapters/oracle_enhanced/database_statements.rb +++ b/lib/active_record/connection_adapters/oracle_enhanced/database_statements.rb @@ -9,8 +9,8 @@ module DatabaseStatements # see: abstract/database_statements.rb # Executes a SQL statement - def execute(sql, name = nil) - log(sql, name) { @connection.exec(sql) } + def execute(sql, name = nil, async: false) + log(sql, name, async: async) { @connection.exec(sql) } end def clear_cache! # :nodoc: @@ -18,10 +18,10 @@ def clear_cache! # :nodoc: super end - def exec_query(sql, name = "SQL", binds = [], prepare: false) + def exec_query(sql, name = "SQL", binds = [], prepare: false, async: false) type_casted_binds = type_casted_binds(binds) - log(sql, name, binds, type_casted_binds) do + log(sql, name, binds, type_casted_binds, async: async) do cursor = nil cached = false with_retry do diff --git a/lib/active_record/connection_adapters/oracle_enhanced/dbms_output.rb b/lib/active_record/connection_adapters/oracle_enhanced/dbms_output.rb index 4feff21fd..25aaef4ba 100644 --- a/lib/active_record/connection_adapters/oracle_enhanced/dbms_output.rb +++ b/lib/active_record/connection_adapters/oracle_enhanced/dbms_output.rb @@ -31,7 +31,7 @@ def dbms_output_enabled? end private - def log(sql, name = "SQL", binds = [], type_casted_binds = [], statement_name = nil) + def log(sql, name = "SQL", binds = [], type_casted_binds = [], statement_name = nil, async: false) super ensure log_dbms_output if dbms_output_enabled?