Begins a transaction.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 203 def begin_db_transaction execute "BEGIN" end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 207 def begin_isolated_db_transaction(isolation) begin_db_transaction execute "SET TRANSACTION ISOLATION LEVEL #{transaction_isolation_levels.fetch(isolation)}" end
Commits a transaction.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 213 def commit_db_transaction execute "COMMIT" end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 71 def create super.insert end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 229 def create_savepoint execute("SAVEPOINT #{current_savepoint_name}") end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 158 def exec_delete(sql, name = 'SQL', binds = []) log(sql, name, binds) do result = without_prepared_statement?(binds) ? exec_no_cache(sql, binds) : exec_cache(sql, binds) affected = result.cmd_tuples result.clear affected end end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 183 def exec_insert(sql, name, binds, pk = nil, sequence_name = nil) val = exec_query(sql, name, binds) if !use_insert_returning? && pk unless sequence_name table_ref = extract_table_ref_from_insert_sql(sql) sequence_name = default_sequence_name(table_ref, pk) return val unless sequence_name end last_insert_id_result(sequence_name) else val end end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 136 def exec_query(sql, name = 'SQL', binds = []) log(sql, name, binds) do result = without_prepared_statement?(binds) ? exec_no_cache(sql, binds) : exec_cache(sql, binds) types = {} fields = result.fields fields.each_with_index do |fname, i| ftype = result.ftype i fmod = result.fmod i types[fname] = OID::TYPE_MAP.fetch(ftype, fmod) { |oid, mod| warn "unknown OID: #{fname}(#{oid}) (#{sql})" OID::Identity.new } end ret = ActiveRecord::Result.new(fields, result.values, types) result.clear return ret end end
Executes an SQL statement, returning a PGresult object on success or raising a PGError exception otherwise.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 126 def execute(sql, name = nil) log(sql, name) do @connection.async_exec(sql) end end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 5 def explain(arel, binds = []) sql = "EXPLAIN #{to_sql(arel, binds)}" ExplainPrettyPrinter.new.pp(exec_query(sql, 'EXPLAIN', binds)) end
Executes an INSERT query and returns the new record's ID
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 54 def insert_sql(sql, name = nil, pk = nil, id_value = nil, sequence_name = nil) unless pk # Extract the table from the insert sql. Yuck. table_ref = extract_table_ref_from_insert_sql(sql) pk = primary_key(table_ref) if table_ref end if pk && use_insert_returning? select_value("#{sql} RETURNING #{quote_column_name(pk)}") elsif pk super last_insert_id_value(sequence_name || default_sequence_name(table_ref, pk)) else super end end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 222 def outside_transaction? message = "#outside_transaction? is deprecated. This method was only really used " "internally, but you can use #transaction_open? instead." ActiveSupport::Deprecation.warn message @connection.transaction_status == PGconn::PQTRANS_IDLE end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 237 def release_savepoint execute("RELEASE SAVEPOINT #{current_savepoint_name}") end
Aborts a transaction.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 218 def rollback_db_transaction execute "ROLLBACK" end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 233 def rollback_to_savepoint execute("ROLLBACK TO SAVEPOINT #{current_savepoint_name}") end
Executes a SELECT query and returns an array of rows. Each row is an array of field values.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 49 def select_rows(sql, name = nil) select_raw(sql, name).last end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 169 def sql_for_insert(sql, pk, id_value, sequence_name, binds) unless pk # Extract the table from the insert sql. Yuck. table_ref = extract_table_ref_from_insert_sql(sql) pk = primary_key(table_ref) if table_ref end if pk && use_insert_returning? sql = "#{sql} RETURNING #{quote_column_name(pk)}" end [sql, binds] end
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 132 def substitute_at(column, index) Arel::Nodes::BindParam.new "$#{index + 1}" end
Executes an UPDATE query and returns the number of affected tuples.
# File lib/active_record/connection_adapters/postgresql/database_statements.rb, line 198 def update_sql(sql, name = nil) super.cmd_tuples end