| Module | ActiveRecord::ConnectionAdapters::DatabaseStatements |
| In: |
vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
|
Alias for add_limit_offset!.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 97
97: def add_limit!(sql, options)
98: add_limit_offset!(sql, options) if options
99: end
Appends LIMIT and OFFSET options to an SQL statement. This method modifies the sql parameter.
add_limit_offset!('SELECT * FROM suppliers', {:limit => 10, :offset => 50})
generates
SELECT * FROM suppliers LIMIT 10 OFFSET 50
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 107
107: def add_limit_offset!(sql, options)
108: if limit = options[:limit]
109: sql << " LIMIT #{limit}"
110: if offset = options[:offset]
111: sql << " OFFSET #{offset}"
112: end
113: end
114: end
Appends a locking clause to an SQL statement. This method modifies the sql parameter.
# SELECT * FROM suppliers FOR UPDATE add_lock! 'SELECT * FROM suppliers', :lock => true add_lock! 'SELECT * FROM suppliers', :lock => ' FOR UPDATE'
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 121
121: def add_lock!(sql, options)
122: case lock = options[:lock]
123: when true; sql << ' FOR UPDATE'
124: when String; sql << " #{lock}"
125: end
126: end
Begins the transaction (and turns off auto-committing).
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 87
87: def begin_db_transaction() end
Commits the transaction (and turns on auto-committing).
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 90
90: def commit_db_transaction() end
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 128
128: def default_sequence_name(table, column)
129: nil
130: end
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 143
143: def empty_insert_statement(table_name)
144: "INSERT INTO #{quote_table_name(table_name)} VALUES(DEFAULT)"
145: end
Executes the SQL statement in the context of this connection.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 38
38: def execute(sql, name = nil)
39: raise NotImplementedError, "execute is an abstract method"
40: end
Returns the last auto-generated ID from the affected table.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 43
43: def insert(sql, name = nil, pk = nil, id_value = nil, sequence_name = nil)
44: insert_sql(sql, name, pk, id_value, sequence_name)
45: end
Inserts the given fixture into the table. Overridden in adapters that require something beyond a simple insert (eg. Oracle).
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 139
139: def insert_fixture(fixture, table_name)
140: execute "INSERT INTO #{quote_table_name(table_name)} (#{fixture.key_list}) VALUES (#{fixture.value_list})", 'Fixture Insert'
141: end
Set the sequence to the max value of the table‘s column.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 133
133: def reset_sequence!(table, column, sequence = nil)
134: # Do nothing by default. Implement for PostgreSQL, Oracle, ...
135: end
Rolls back the transaction (and turns on auto-committing). Must be done if the transaction block raises an exception or returns false.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 94
94: def rollback_db_transaction() end
Returns an array of record hashes with the column names as keys and column values as values.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 6 6: def select_all(sql, name = nil) 7: select(sql, name) 8: end
Returns a record hash with the column names as keys and column values as values.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 12
12: def select_one(sql, name = nil)
13: result = select_all(sql, name)
14: result.first if result
15: end
Returns an array of arrays containing the field values. Order is the same as that returned by columns.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 33
33: def select_rows(sql, name = nil)
34: raise NotImplementedError, "select_rows is an abstract method"
35: end
Returns a single value from a record
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 18
18: def select_value(sql, name = nil)
19: if result = select_one(sql, name)
20: result.values.first
21: end
22: end
Returns an array of the values of the first column in a select:
select_values("SELECT id FROM companies LIMIT 3") => [1,2,3]
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 26
26: def select_values(sql, name = nil)
27: result = select_rows(sql, name)
28: result.map { |v| v[0] }
29: end
Wrap a block in a transaction. Returns result of block.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 58
58: def transaction(start_db_transaction = true)
59: transaction_open = false
60: begin
61: if block_given?
62: if start_db_transaction
63: begin_db_transaction
64: transaction_open = true
65: end
66: yield
67: end
68: rescue Exception => database_transaction_rollback
69: if transaction_open
70: transaction_open = false
71: rollback_db_transaction
72: end
73: raise unless database_transaction_rollback.is_a? ActiveRecord::Rollback
74: end
75: ensure
76: if transaction_open
77: begin
78: commit_db_transaction
79: rescue Exception => database_transaction_rollback
80: rollback_db_transaction
81: raise
82: end
83: end
84: end
Returns the last auto-generated ID from the affected table.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 155
155: def insert_sql(sql, name = nil, pk = nil, id_value = nil, sequence_name = nil)
156: execute(sql, name)
157: id_value
158: end
Returns an array of record hashes with the column names as keys and column values as values.
# File vendor/rails/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb, line 150
150: def select(sql, name = nil)
151: raise NotImplementedError, "select is an abstract method"
152: end