Methods

Instance Public methods

begin_db_transaction()

Begins a transaction.

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 132
        def begin_db_transaction
          execute "BEGIN"
        end
🔎 See on GitHub

begin_isolated_db_transaction(isolation)

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 136
        def begin_isolated_db_transaction(isolation)
          begin_db_transaction
          execute "SET TRANSACTION ISOLATION LEVEL #{transaction_isolation_levels.fetch(isolation)}"
        end
🔎 See on GitHub

commit_db_transaction()

Commits a transaction.

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 142
        def commit_db_transaction
          execute "COMMIT"
        end
🔎 See on GitHub

exec_delete(sql, name = nil, binds = [])

Also aliased as: exec_update
📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 93
        def exec_delete(sql, name = nil, binds = [])
          execute_and_clear(sql, name, binds) { |result| result.cmd_tuples }
        end
🔎 See on GitHub

exec_insert(sql, name = nil, binds = [], pk = nil, sequence_name = nil)

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 113
        def exec_insert(sql, name = nil, binds = [], pk = nil, sequence_name = nil)
          if use_insert_returning? || pk == false
            super
          else
            result = exec_query(sql, name, binds)
            unless sequence_name
              table_ref = extract_table_ref_from_insert_sql(sql)
              if table_ref
                pk = primary_key(table_ref) if pk.nil?
                pk = suppress_composite_primary_key(pk)
                sequence_name = default_sequence_name(table_ref, pk)
              end
              return result unless sequence_name
            end
            last_insert_id_result(sequence_name)
          end
        end
🔎 See on GitHub

exec_query(sql, name = "SQL", binds = [], prepare: false)

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 80
        def exec_query(sql, name = "SQL", binds = [], prepare: false)
          execute_and_clear(sql, name, binds, prepare: prepare) do |result|
            types = {}
            fields = result.fields
            fields.each_with_index do |fname, i|
              ftype = result.ftype i
              fmod  = result.fmod i
              types[fname] = get_oid_type(ftype, fmod, fname)
            end
            ActiveRecord::Result.new(fields, result.values, types)
          end
        end
🔎 See on GitHub

exec_rollback_db_transaction()

Aborts a transaction.

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 147
        def exec_rollback_db_transaction
          execute "ROLLBACK"
        end
🔎 See on GitHub

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

Alias for: exec_delete

execute(sql, name = nil)

Executes an SQL statement, returning a PG::Result object on success or raising a PG::Error exception otherwise. Note: the PG::Result object is manually memory managed; if you don't need it specifically, you may want consider the exec_query wrapper.

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 72
        def execute(sql, name = nil)
          log(sql, name) do
            ActiveSupport::Dependencies.interlock.permit_concurrent_loads do
              @connection.async_exec(sql)
            end
          end
        end
🔎 See on GitHub

explain(arel, binds = [])

📝 Source code 
# File activerecord/lib/active_record/connection_adapters/postgresql/database_statements.rb, line 7
        def explain(arel, binds = [])
          sql = "EXPLAIN #{to_sql(arel, binds)}"
          PostgreSQL::ExplainPrettyPrinter.new.pp(exec_query(sql, "EXPLAIN", binds))
        end
🔎 See on GitHub