Class: ActiveRecord::ConnectionAdapters::PostgreSQLAdapter
Overview
Instance Method Summary
collapse
#add_limit!, #initialize, #quote_string, #reset_runtime, #structure_dump, #transaction
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
|