Class: ActiveRecord::ConnectionAdapters::AbstractAdapter

Inherits:

Object

• Object
• ActiveRecord::ConnectionAdapters::AbstractAdapter

show all

Includes:

DatabaseLimits, DatabaseStatements, Quoting, SchemaStatements, QueryCache, ActiveSupport::Callbacks

Defined in:

activerecord/lib/active_record/connection_adapters/abstract_adapter.rb

Overview

Instance Method Summary (collapse)

• - (Boolean) active?

  Checks whether the connection to the database is still active.

• - (Object) adapter_name

  Returns the human-readable name of the adapter.

• - (Object) create_savepoint
• - (Object) current_savepoint_name
• - (Object) decrement_open_transactions
• - (Object) disable_referential_integrity

  Override to turn off referential integrity while executing &block.

• - (Object) disconnect!

  Disconnects from the database if already connected.

• - (Object) increment_open_transactions
• - (AbstractAdapter) initialize(connection, logger = nil) constructor

  :nodoc:.

• - (Object) open_transactions
• - (Boolean) prefetch_primary_key?(table_name = nil)

  Should primary key values be selected from their corresponding sequence before the insert statement? If true, next_sequence_value is called before each insert to set the record's primary key.

• - (Object) quote_table_name(name)

  Override to return the quoted table name.

• - (Object) raw_connection

  Provides access to the underlying database driver for this adapter.

• - (Object) reconnect!

  Disconnects from the database if already connected, and establishes a new connection with the database.

• - (Object) release_savepoint
• - (Boolean) requires_reloading?

  Returns true if its required to reload the connection between requests for development mode.

• - (Object) reset!

  Reset the state of this connection, directing the DBMS to clear transactions and other connection-related server-side state.

• - (Object) rollback_to_savepoint
• - (Boolean) supports_count_distinct?

  Does this adapter support using DISTINCT within COUNT? This is true for all adapters except sqlite.

• - (Boolean) supports_ddl_transactions?

  Does this adapter support DDL rollbacks in transactions? That is, would CREATE TABLE or ALTER TABLE get rolled back by a transaction? PostgreSQL, SQL Server, and others support this.

• - (Boolean) supports_migrations?

  Does this adapter support migrations? Backend specific, as the abstract adapter always returns false.

• - (Boolean) supports_primary_key?

  Can this adapter determine the primary key for tables not attached to an Active Record class, such as join tables? Backend specific, as the abstract adapter always returns false.

• - (Boolean) supports_savepoints?

  Does this adapter support savepoints? PostgreSQL and MySQL do, SQLite does not.

• - (Object) transaction_joinable=(joinable)
• - (Object) verify!(*ignored)

  Checks whether the connection to the database is still active (i.e. not stale).

Methods included from ActiveSupport::Callbacks

#callback, #run_callbacks

Methods included from ActiveSupport::Concern

#append_features, extended, #included

Methods inherited from QueryCache

#call

Methods included from DatabaseLimits

#column_name_length, #columns_per_multicolumn_index, #columns_per_table, #in_clause_length, #index_name_length, #indexes_per_table, #joins_per_query, #sql_query_length, #table_alias_length, #table_name_length

Methods included from SchemaStatements

#add_column, #add_column_options!, #add_index, #add_timestamps, #assume_migrated_upto_version, #change_column, #change_column_default, #change_table, #column_exists?, #columns, #create_table, #distinct, #drop_table, #dump_schema_information, #index_exists?, #index_name, #index_name_exists?, #initialize_schema_migrations_table, #native_database_types, #remove_column, #remove_index, #remove_index!, #remove_timestamps, #rename_column, #rename_index, #rename_table, #structure_dump, #table_alias_for, #table_exists?, #type_to_sql

Methods included from DatabaseStatements

#add_limit_offset!, #add_transaction_record, #begin_db_transaction, #case_sensitive_equality_operator, #commit_db_transaction, #default_sequence_name, #delete, #empty_insert_statement_value, #execute, #insert, #insert_fixture, #limited_update_conditions, #outside_transaction?, #reset_sequence!, #rollback_db_transaction, #select_all, #select_one, #select_rows, #select_value, #select_values, #transaction, #update

Methods included from Quoting

#quote, #quote_column_name, #quote_string, #quoted_date, #quoted_false, #quoted_true

39
40
41
42
43
44
45

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 39

def initialize(connection, logger = nil) #:nodoc:
  @active = nil
  @connection, @logger = connection, logger
  @query_cache_enabled = false
  @query_cache = {}
  @instrumenter = ActiveSupport::Notifications.instrumenter
end

112
113
114

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 112

def active?
  @active != false
end

49
50
51

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 49

def adapter_name
  'Abstract'
end

178
179

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 178

def create_savepoint
end

187
188
189

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 187

def current_savepoint_name
  "active_record_#{open_transactions}"
end

170
171
172

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 170

def decrement_open_transactions
  @open_transactions -= 1
end

103
104
105

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 103

def disable_referential_integrity
  yield
end

124
125
126

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 124

def disconnect!
  @active = false
end

165
166
167
168

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 165

def increment_open_transactions
  @open_transactions ||= 0
  @open_transactions += 1
end

161
162
163

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 161

def open_transactions
  @open_transactions ||= 0
end

89
90
91

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 89

def prefetch_primary_key?(table_name = nil)
  false
end

96
97
98

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 96

def quote_table_name(name)
  quote_column_name(name)
end

157
158
159

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 157

def raw_connection
  @connection
end

118
119
120

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 118

def reconnect!
  @active = true
end

184
185

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 184

def release_savepoint
end

140
141
142

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 140

def requires_reloading?
  false
end

134
135
136

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 134

def reset!
  # this should be overridden by concrete adapters
end

181
182

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 181

def rollback_to_savepoint
end

68
69
70

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 68

def supports_count_distinct?
  true
end

75
76
77

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 75

def supports_ddl_transactions?
  false
end

55
56
57

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 55

def supports_migrations?
  false
end

62
63
64

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 62

def supports_primary_key?
  false
end

81
82
83

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 81

def supports_savepoints?
  false
end

174
175
176

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 174

def transaction_joinable=(joinable)
  @transaction_joinable = joinable
end

147
148
149

# File 'activerecord/lib/active_record/connection_adapters/abstract_adapter.rb', line 147

def verify!(*ignored)
  reconnect! unless active?
end