Module: ArJdbc::Abstract::DatabaseStatements

Overview

This provides the basic interface for interacting with the database for JDBC based adapters

Constant Summary collapse

NO_BINDS =
[].freeze

Instance Method Summary collapse

Instance Method Details

#exec_insert(sql, name = nil, binds = NO_BINDS, pk = nil, sequence_name = nil) ⇒ Object



12
13
14
15
16
17
18
19
20
21
22
# File 'lib/arjdbc/abstract/database_statements.rb', line 12

def exec_insert(sql, name = nil, binds = NO_BINDS, pk = nil, sequence_name = nil)
  binds = convert_legacy_binds_to_attributes(binds) if binds.first.is_a?(Array)

  if without_prepared_statement?(binds)
    log(sql, name) { @connection.execute_insert(sql) }
  else
    log(sql, name, binds) do
      @connection.execute_insert(sql, binds)
    end
  end
end

#exec_query(sql, name = nil, binds = NO_BINDS, prepare: false) ⇒ Object

It appears that at this point (AR 5.0) "prepare" should only ever be true if prepared statements are enabled



26
27
28
29
30
31
32
33
34
35
36
37
38
# File 'lib/arjdbc/abstract/database_statements.rb', line 26

def exec_query(sql, name = nil, binds = NO_BINDS, prepare: false)
  binds = convert_legacy_binds_to_attributes(binds) if binds.first.is_a?(Array)

  if without_prepared_statement?(binds)
    log(sql, name) { @connection.execute_query(sql) }
  else
    log(sql, name, binds) do
      # this is different from normal AR that always caches
      cached_statement = fetch_cached_statement(sql) if prepare && @jdbc_statement_cache_enabled
      @connection.execute_prepared_query(sql, binds, cached_statement)
    end
  end
end

#exec_update(sql, name = nil, binds = NO_BINDS) ⇒ Object Also known as: exec_delete



40
41
42
43
44
45
46
47
48
# File 'lib/arjdbc/abstract/database_statements.rb', line 40

def exec_update(sql, name = nil, binds = NO_BINDS)
  binds = convert_legacy_binds_to_attributes(binds) if binds.first.is_a?(Array)

  if without_prepared_statement?(binds)
    log(sql, name) { @connection.execute_update(sql) }
  else
    log(sql, name, binds) { @connection.execute_prepared_update(sql, binds) }
  end
end

#execute(sql, name = nil) ⇒ Object



51
52
53
# File 'lib/arjdbc/abstract/database_statements.rb', line 51

def execute(sql, name = nil)
  log(sql, name) { @connection.execute(sql) }
end

#select_all(arel, name = nil, binds = NO_BINDS, preparable: nil) ⇒ Object



55
56
57
58
# File 'lib/arjdbc/abstract/database_statements.rb', line 55

def select_all(arel, name = nil, binds = NO_BINDS, preparable: nil)
  binds = convert_legacy_binds_to_attributes(binds) if binds.first.is_a?(Array)
  super
end