Class: ActiveRecord::ConnectionAdapters::PostgreSQLAdapter

Inherits:
AbstractAdapter show all
Defined in:
lib/active_record/connection_adapters/postgresql_adapter.rb

Overview

:nodoc:

Instance Method Summary collapse

Methods inherited from AbstractAdapter

#add_limit!, #initialize, #quote_string, #reset_runtime, #structure_dump, #transaction

Constructor Details

This class inherits a constructor from ActiveRecord::ConnectionAdapters::AbstractAdapter

Instance Method Details

#begin_db_transaction ⇒ Object 



76
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 76

def begin_db_transaction()    execute "BEGIN" end

#columns(table_name, name = nil) ⇒ Object 



51
52
53
54
55
56
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 51

def columns(table_name, name = nil)
  table_structure(table_name).inject([]) do |columns, field|
    columns << Column.new(field[0], field[2], field[1])
    columns
  end
end

#commit_db_transaction ⇒ Object 



77
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 77

def commit_db_transaction()   execute "COMMIT" end

#execute(sql, name = nil) ⇒ Object 



64
65
66
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 64

def execute(sql, name = nil)
  log(sql, name, @connection) { |connection| connection.query(sql) }
end

#insert(sql, name = nil, pk = nil, id_value = nil) ⇒ Object 



58
59
60
61
62
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 58

def insert(sql, name = nil, pk = nil, id_value = nil)
  execute(sql, name = nil)
  table = sql.split(" ", 4)[2]
  return id_value || last_insert_id(table, pk)
end

#quote(value, column = nil) ⇒ Object 



80
81
82
83
84
85
86
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 80

def quote(value, column = nil)
  if value.class == String && column && column.type == :binary
    quote_bytea(value)
  else
    super
  end
end

#quote_column_name(name) ⇒ Object 



88
89
90
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 88

def quote_column_name(name)
  return "\"#{name}\""
end

#rollback_db_transaction ⇒ Object 



78
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 78

def rollback_db_transaction() execute "ROLLBACK" end

#select_all(sql, name = nil) ⇒ Object 



42
43
44
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 42

def select_all(sql, name = nil)
  select(sql, name)
end

#select_one(sql, name = nil) ⇒ Object 



46
47
48
49
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 46

def select_one(sql, name = nil)
  result = select(sql, name)
  result.nil? ? nil : result.first
end

#update(sql, name = nil) ⇒ Object Also known as: delete 



68
69
70
71
72
 
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 68

def update(sql, name = nil)
  result = nil
  log(sql, name, @connection) { |connection| result = connection.exec(sql) }
  result.cmdtuples
end