module ActiveRecord::ConnectionAdapters::PostgreSQL::DatabaseStatements
Public Instance Methods
begin_db_transaction()
click to toggle source
Begins a transaction.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 110 def begin_db_transaction execute("BEGIN", "TRANSACTION") end
begin_isolated_db_transaction(isolation)
click to toggle source
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 114 def begin_isolated_db_transaction(isolation) begin_db_transaction execute "SET TRANSACTION ISOLATION LEVEL #{transaction_isolation_levels.fetch(isolation)}" end
commit_db_transaction()
click to toggle source
Commits a transaction.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 120 def commit_db_transaction execute("COMMIT", "TRANSACTION") end
exec_delete(sql, name = nil, binds = [])
click to toggle source
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 71 def exec_delete(sql, name = nil, binds = []) execute_and_clear(sql, name, binds) { |result| result.cmd_tuples } end
Also aliased as: exec_update
exec_insert(sql, name = nil, binds = [], pk = nil, sequence_name = nil)
click to toggle source
Calls superclass method
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 91 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
exec_query(sql, name = "SQL", binds = [], prepare: false)
click to toggle source
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 54 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 case type = get_oid_type(ftype, fmod, fname) when Type::Integer, Type::Float, OID::Decimal, Type::String, Type::DateTime, Type::Boolean # skip if a column has already been type casted by pg decoders else types[fname] = type end end build_result(columns: fields, rows: result.values, column_types: types) end end
exec_rollback_db_transaction()
click to toggle source
Aborts a transaction.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 125 def exec_rollback_db_transaction execute("ROLLBACK", "TRANSACTION") end
execute(sql, name = nil)
click to toggle source
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.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 39 def execute(sql, name = nil) if preventing_writes? && write_query?(sql) raise ActiveRecord::ReadOnlyError, "Write query attempted while in readonly mode: #{sql}" end materialize_transactions mark_transaction_written_if_write(sql) log(sql, name) do ActiveSupport::Dependencies.interlock.permit_concurrent_loads do @connection.async_exec(sql) end end end
explain(arel, binds = [])
click to toggle source
# File 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
Private Instance Methods
build_truncate_statements(table_names)
click to toggle source
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 134 def build_truncate_statements(table_names) ["TRUNCATE TABLE #{table_names.map(&method(:quote_table_name)).join(", ")}"] end
execute_batch(statements, name = nil)
click to toggle source
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 130 def execute_batch(statements, name = nil) execute(combine_multi_statements(statements)) end
last_insert_id_result(sequence_name)
click to toggle source
Returns the current ID of a table's sequence.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 139 def last_insert_id_result(sequence_name) exec_query("SELECT currval(#{quote(sequence_name)})", "SQL") end
suppress_composite_primary_key(pk)
click to toggle source
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 143 def suppress_composite_primary_key(pk) pk unless pk.is_a?(Array) end