Module: ActiveRecord::ConnectionAdapters::SQLite3::DatabaseStatements

Included in:
ActiveRecord::ConnectionAdapters::SQLite3Adapter
Defined in:
lib/active_record/connection_adapters/sqlite3/database_statements.rb

Instance Method Summary collapse

Instance Method Details

#begin_db_transaction ⇒ Object

:nodoc:



88
89
90
 
# File '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:

Raises:



79
80
81
82
83
84
85
86
 
# File '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/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/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/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/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/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/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/active_record/connection_adapters/sqlite3/database_statements.rb', line 107

def high_precision_current_timestamp
  HIGH_PRECISION_CURRENT_TIMESTAMP
end

#write_query?(sql) ⇒ Boolean

:nodoc:

Returns:

  • (Boolean) 


12
13
14
15
16
 
# File '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