123456789_123456789_123456789_123456789_123456789_

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

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Included In:
::ActiveRecord::ConnectionAdapters::TrilogyAdapter
Defined in: activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb

Instance Attribute Summary

Instance Method Summary

Instance Attribute Details

#multi_statements_enabled? ⇒ Boolean (readonly, private)

[ GitHub ] 

  


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



def multi_statements_enabled?
  !!@config[:multi_statement]
end


  







Instance Method Details



  

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

  

    This method is for internal use only.
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 25



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)  
  

  

    This method is for internal use only.
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 16



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)

  sql, _binds = sql_for_insert(sql, pk, binds, returning)
  raw_execute(sql, name)
end


  








  

    #exec_update(sql, name = nil, binds = [])  
  

  

    This method is for internal use only.
  



  

    

Alias for #exec_delete.


  



  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 34



alias :exec_update :exec_delete # :nodoc:


  








  

    #execute_batch(statements, name = nil)   (private)
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 70



def execute_batch(statements, name = nil)
  statements = statements.map { |sql| transform_query(sql) }
  combine_multi_statements(statements).each do |statement|
    with_raw_connection do |conn|
      raw_execute(statement, name)
    end
  end
end


  








  

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

  

    This method is for internal use only.
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 7



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

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


  








  

    #last_inserted_id(result)   (private)
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 53



def last_inserted_id(result)
  if supports_insert_returning?
    super
  else
    result.last_insert_id
  end
end


  








  

    #raw_execute(sql, name, async: false, allow_retry: false, materialize_transactions: true)   (private)
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 37



def raw_execute(sql, name, async: false, allow_retry: false, materialize_transactions: true)
  log(sql, name, async: async) do |notification_payload|
    with_raw_connection(allow_retry: allow_retry, materialize_transactions: materialize_transactions) do |conn|
      sync_timezone_changes(conn)
      result = conn.query(sql)
      while conn.more_results_exist?
        conn.next_result
      end
      verified!
      handle_warnings(sql)
      notification_payload[:row_count] = result.count
      result
    end
  end
end


  








  

    #sync_timezone_changes(conn)   (private)
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 61



def sync_timezone_changes(conn)
  # Sync any changes since connection last established.
  if default_timezone == :local
    conn.query_flags |= ::Trilogy::QUERY_FLAGS_LOCAL_TIMEZONE
  else
    conn.query_flags &= ~::Trilogy::QUERY_FLAGS_LOCAL_TIMEZONE
  end
end


  








  

    #with_multi_statements   (private)
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 83



def with_multi_statements
  if multi_statements_enabled?
    return yield
  end

  with_raw_connection do |conn|
    conn.set_server_option(::Trilogy::SET_SERVER_MULTI_STATEMENTS_ON)

    yield
  ensure
    conn.set_server_option(::Trilogy::SET_SERVER_MULTI_STATEMENTS_OFF) if active?
  end
end