Module: ActiveRecord::ConnectionAdapters::SQLite3::DatabaseStatements
- Included in:
- ActiveRecord::ConnectionAdapters::SQLite3Adapter
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb
Instance Method Summary collapse
-
#begin_db_transaction ⇒ Object
:nodoc:.
-
#begin_isolated_db_transaction(isolation) ⇒ Object
:nodoc:.
-
#commit_db_transaction ⇒ Object
:nodoc:.
-
#exec_delete(sql, name = "SQL", binds = []) ⇒ Object
(also: #exec_update)
:nodoc:.
-
#exec_query(sql, name = nil, binds = [], prepare: false, async: false) ⇒ Object
:nodoc:.
-
#exec_rollback_db_transaction ⇒ Object
:nodoc:.
-
#execute(sql, name = nil) ⇒ Object
:nodoc:.
- #explain(arel, binds = []) ⇒ Object
- #high_precision_current_timestamp ⇒ Object
-
#write_query?(sql) ⇒ Boolean
:nodoc:.
Instance Method Details
#begin_db_transaction ⇒ Object
:nodoc:
88 89 90 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 88 def begin_db_transaction # :nodoc: log("begin transaction", "TRANSACTION") { @connection.transaction } end |
#begin_isolated_db_transaction(isolation) ⇒ Object
:nodoc:
79 80 81 82 83 84 85 86 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 79 def begin_isolated_db_transaction(isolation) # :nodoc: raise TransactionIsolationError, "SQLite3 only supports the `read_uncommitted` transaction isolation level" if isolation != :read_uncommitted raise StandardError, "You need to enable the shared-cache mode in SQLite mode before attempting to change the transaction isolation level" unless shared_cache? ActiveSupport::IsolatedExecutionState[:active_record_read_uncommitted] = @connection.get_first_value("PRAGMA read_uncommitted") @connection.read_uncommitted = true begin_db_transaction end |
#commit_db_transaction ⇒ Object
:nodoc:
92 93 94 95 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 92 def commit_db_transaction # :nodoc: log("commit transaction", "TRANSACTION") { @connection.commit } reset_read_uncommitted end |
#exec_delete(sql, name = "SQL", binds = []) ⇒ Object Also known as: exec_update
:nodoc:
73 74 75 76 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 73 def exec_delete(sql, name = "SQL", binds = []) # :nodoc: exec_query(sql, name, binds) @connection.changes end |
#exec_query(sql, name = nil, binds = [], prepare: false, async: false) ⇒ Object
:nodoc:
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 37 def exec_query(sql, name = nil, binds = [], prepare: false, async: false) # :nodoc: sql = transform_query(sql) check_if_write_query(sql) materialize_transactions mark_transaction_written_if_write(sql) type_casted_binds = type_casted_binds(binds) log(sql, name, binds, type_casted_binds, async: async) do ActiveSupport::Dependencies.interlock.permit_concurrent_loads do # Don't cache statements if they are not prepared unless prepare stmt = @connection.prepare(sql) begin cols = stmt.columns unless without_prepared_statement?(binds) stmt.bind_params(type_casted_binds) end records = stmt.to_a ensure stmt.close end else stmt = @statements[sql] ||= @connection.prepare(sql) cols = stmt.columns stmt.reset! stmt.bind_params(type_casted_binds) records = stmt.to_a end build_result(columns: cols, rows: records) end end end |
#exec_rollback_db_transaction ⇒ Object
:nodoc:
97 98 99 100 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 97 def exec_rollback_db_transaction # :nodoc: log("rollback transaction", "TRANSACTION") { @connection.rollback } reset_read_uncommitted end |
#execute(sql, name = nil) ⇒ Object
:nodoc:
23 24 25 26 27 28 29 30 31 32 33 34 35 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 23 def execute(sql, name = nil) # :nodoc: sql = transform_query(sql) check_if_write_query(sql) materialize_transactions mark_transaction_written_if_write(sql) log(sql, name) do ActiveSupport::Dependencies.interlock.permit_concurrent_loads do @connection.execute(sql) end end end |
#explain(arel, binds = []) ⇒ Object
18 19 20 21 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 18 def explain(arel, binds = []) sql = "EXPLAIN QUERY PLAN #{to_sql(arel, binds)}" SQLite3::ExplainPrettyPrinter.new.pp(exec_query(sql, "EXPLAIN", [])) end |
#high_precision_current_timestamp ⇒ Object
107 108 109 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 107 def HIGH_PRECISION_CURRENT_TIMESTAMP end |
#write_query?(sql) ⇒ Boolean
:nodoc:
12 13 14 15 16 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activerecord-7.0.4/lib/active_record/connection_adapters/sqlite3/database_statements.rb', line 12 def write_query?(sql) # :nodoc: !READ_QUERY.match?(sql) rescue ArgumentError # Invalid encoding !READ_QUERY.match?(sql.b) end |