Module: ActiveRecord::ConnectionAdapters::Trilogy::DatabaseStatements

Included in:
ActiveRecord::ConnectionAdapters::TrilogyAdapter
Defined in:
lib/active_record/connection_adapters/trilogy/database_statements.rb

Instance Method Summary collapse

Instance Method Details

#build_explain_clause(options = []) ⇒ Object 



83
84
85
86
87
88
89
90
91
92
93
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 83

def build_explain_clause(options = [])
  return "EXPLAIN" if options.empty?

  explain_clause = "EXPLAIN #{options.join(" ").upcase}"

  if analyze_without_explain? && explain_clause.include?("ANALYZE")
    explain_clause.sub("EXPLAIN ", "")
  else
    explain_clause
  end
end

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

:nodoc:



68
69
70
71
72
73
74
75
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 68

def exec_delete(sql, name = nil, binds = []) # :nodoc:
  sql = transform_query(sql)
  check_if_write_query(sql)
  mark_transaction_written_if_write(sql)

  result = raw_execute(to_sql(sql, binds), name)
  result.affected_rows
end

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

:nodoc:



60
61
62
63
64
65
66
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 60

def exec_insert(sql, name, binds, pk = nil, sequence_name = nil, returning: nil) # :nodoc:
  sql = transform_query(sql)
  check_if_write_query(sql)
  mark_transaction_written_if_write(sql)

  raw_execute(to_sql(sql, binds), name)
end

#exec_query(sql, name = "SQL", binds = [], prepare: false, **kwargs) ⇒ Object 



47
48
49
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 47

def exec_query(sql, name = "SQL", binds = [], prepare: false, **kwargs)
  internal_exec_query(sql, name, binds, prepare: prepare, **kwargs)
end

#execute(sql, name = nil, **kwargs) ⇒ Object 



15
16
17
18
19
20
21
22
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 15

def execute(sql, name = nil, **kwargs)
  sql = transform_query(sql)
  check_if_write_query(sql)
  mark_transaction_written_if_write(sql)

  result = raw_execute(sql, name, **kwargs)
  ActiveRecord::Result.new(result.fields, result.to_a)
end

#explain(arel, binds = [], options = []) ⇒ Object 



38
39
40
41
42
43
44
45
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 38

def explain(arel, binds = [], options = [])
  sql     = build_explain_clause(options) + " " + to_sql(arel, binds)
  start   = Process.clock_gettime(Process::CLOCK_MONOTONIC)
  result  = internal_exec_query(sql, "EXPLAIN", binds)
  elapsed = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start

  MySQL::ExplainPrettyPrinter.new.pp(result, elapsed)
end

#high_precision_current_timestamp ⇒ Object 



79
80
81
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 79

def high_precision_current_timestamp
  HIGH_PRECISION_CURRENT_TIMESTAMP
end

#internal_exec_query(sql, name = "SQL", binds = [], prepare: false, async: false) ⇒ Object

:nodoc:



51
52
53
54
55
56
57
58
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 51

def internal_exec_query(sql, name = "SQL", binds = [], prepare: false, async: false) # :nodoc:
  sql = transform_query(sql)
  check_if_write_query(sql)
  mark_transaction_written_if_write(sql)

  result = raw_execute(sql, name, async: async)
  ActiveRecord::Result.new(result.fields, result.to_a)
end

#select_all ⇒ Object

:nodoc:



24
25
26
27
28
29
30
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 24

def select_all(*, **) # :nodoc:
  result = super
  with_trilogy_connection do |conn|
    conn.next_result while conn.more_results_exist?
  end
  result
end

#write_query?(sql) ⇒ Boolean

:nodoc:

Returns:

  • (Boolean) 


32
33
34
35
36
 
# File 'lib/active_record/connection_adapters/trilogy/database_statements.rb', line 32

def write_query?(sql) # :nodoc:
  !READ_QUERY.match?(sql)
rescue ArgumentError # Invalid encoding
  !READ_QUERY.match?(sql.b)
end