base.rb 80.9 KB
Newer Older
1 2 3 4 5
begin
  require 'psych'
rescue LoadError
end

D
Initial  
David Heinemeier Hansson 已提交
6
require 'yaml'
7
require 'set'
J
José Valim 已提交
8
require 'active_support/benchmarkable'
J
Jeremy Kemper 已提交
9
require 'active_support/dependencies'
10
require 'active_support/descendants_tracker'
11
require 'active_support/time'
12
require 'active_support/core_ext/class/attribute'
J
Jeremy Kemper 已提交
13 14
require 'active_support/core_ext/class/attribute_accessors'
require 'active_support/core_ext/class/delegating_attributes'
15
require 'active_support/core_ext/class/attribute'
J
Jeremy Kemper 已提交
16 17 18 19 20
require 'active_support/core_ext/array/extract_options'
require 'active_support/core_ext/hash/deep_merge'
require 'active_support/core_ext/hash/indifferent_access'
require 'active_support/core_ext/hash/slice'
require 'active_support/core_ext/string/behavior'
21
require 'active_support/core_ext/kernel/singleton_class'
22
require 'active_support/core_ext/module/delegation'
23
require 'active_support/core_ext/module/introspection'
24
require 'active_support/core_ext/object/duplicable'
25
require 'active_support/core_ext/object/blank'
26 27
require 'arel'
require 'active_record/errors'
28
require 'active_record/log_subscriber'
D
Initial  
David Heinemeier Hansson 已提交
29 30

module ActiveRecord #:nodoc:
31
  # = Active Record
32
  #
33 34 35
  # Active Record objects don't specify their attributes directly, but rather infer them from
  # the table definition with which they're linked. Adding, removing, and changing attributes
  # and their type is done directly in the database. Any change is instantly reflected in the
36
  # Active Record objects. The mapping that binds a given Active Record class to a certain
37 38
  # database table will happen automatically in most common cases, but can be overwritten for the uncommon ones.
  #
39
  # See the mapping rules in table_name and the full example in link:files/activerecord/README_rdoc.html for more insight.
40
  #
D
Initial  
David Heinemeier Hansson 已提交
41
  # == Creation
42
  #
43 44
  # Active Records accept constructor parameters either in a hash or as a block. The hash
  # method is especially useful when you're receiving the data from somewhere else, like an
45
  # HTTP request. It works like this:
46
  #
47
  #   user = User.new(:name => "David", :occupation => "Code Artist")
D
Initial  
David Heinemeier Hansson 已提交
48
  #   user.name # => "David"
49
  #
D
Initial  
David Heinemeier Hansson 已提交
50
  # You can also use block initialization:
51
  #
D
Initial  
David Heinemeier Hansson 已提交
52 53 54 55
  #   user = User.new do |u|
  #     u.name = "David"
  #     u.occupation = "Code Artist"
  #   end
56
  #
D
Initial  
David Heinemeier Hansson 已提交
57
  # And of course you can just create a bare object and specify the attributes after the fact:
58
  #
D
Initial  
David Heinemeier Hansson 已提交
59 60 61
  #   user = User.new
  #   user.name = "David"
  #   user.occupation = "Code Artist"
62
  #
D
Initial  
David Heinemeier Hansson 已提交
63
  # == Conditions
64
  #
65
  # Conditions can either be specified as a string, array, or hash representing the WHERE-part of an SQL statement.
D
Initial  
David Heinemeier Hansson 已提交
66
  # The array form is to be used when the condition input is tainted and requires sanitization. The string form can
67
  # be used for statements that don't involve tainted data. The hash form works much like the array form, except
68
  # only equality and range is possible. Examples:
69
  #
70
  #   class User < ActiveRecord::Base
D
Initial  
David Heinemeier Hansson 已提交
71
  #     def self.authenticate_unsafely(user_name, password)
72
  #       where("user_name = '#{user_name}' AND password = '#{password}'").first
D
Initial  
David Heinemeier Hansson 已提交
73
  #     end
74
  #
D
Initial  
David Heinemeier Hansson 已提交
75
  #     def self.authenticate_safely(user_name, password)
76
  #       where("user_name = ? AND password = ?", user_name, password).first
D
Initial  
David Heinemeier Hansson 已提交
77
  #     end
78 79
  #
  #     def self.authenticate_safely_simply(user_name, password)
80
  #       where(:user_name => user_name, :password => password).first
81
  #     end
D
Initial  
David Heinemeier Hansson 已提交
82
  #   end
83
  #
84 85
  # The <tt>authenticate_unsafely</tt> method inserts the parameters directly into the query
  # and is thus susceptible to SQL-injection attacks if the <tt>user_name</tt> and +password+
86
  # parameters come directly from an HTTP request. The <tt>authenticate_safely</tt>  and
87 88
  # <tt>authenticate_safely_simply</tt> both will sanitize the <tt>user_name</tt> and +password+
  # before inserting them in the query, which will ensure that an attacker can't escape the
89
  # query and fake the login (or worse).
90
  #
91 92 93
  # When using multiple parameters in the conditions, it can easily become hard to read exactly
  # what the fourth or fifth question mark is supposed to represent. In those cases, you can
  # resort to named bind variables instead. That's done by replacing the question marks with
94
  # symbols and supplying a hash with values for the matching symbol keys:
95
  #
96
  #   Company.where(
97
  #     "id = :id AND name = :name AND division = :division AND created_at > :accounting_date",
98
  #     { :id => 3, :name => "37signals", :division => "First", :accounting_date => '2005-01-01' }
99
  #   ).first
100
  #
101 102 103
  # Similarly, a simple hash without a statement will generate conditions based on equality with the SQL AND
  # operator. For instance:
  #
104 105
  #   Student.where(:first_name => "Harvey", :status => 1)
  #   Student.where(params[:student])
106
  #
107 108
  # A range may be used in the hash to use the SQL BETWEEN operator:
  #
109
  #   Student.where(:grade => 9..12)
110
  #
P
Pratik Naik 已提交
111 112
  # An array may be used in the hash to use the SQL IN operator:
  #
113
  #   Student.where(:grade => [9,11,12])
P
Pratik Naik 已提交
114
  #
115
  # When joining tables, nested hashes or keys written in the form 'table_name.column_name'
116
  # can be used to qualify the table name of a particular condition. For instance:
P
Pratik Naik 已提交
117
  #
118 119
  #   Student.joins(:schools).where(:schools => { :type => 'public' })
  #   Student.joins(:schools).where('schools.type' => 'public' )
P
Pratik Naik 已提交
120
  #
D
Initial  
David Heinemeier Hansson 已提交
121
  # == Overwriting default accessors
122
  #
123 124 125 126
  # All column values are automatically available through basic accessors on the Active Record
  # object, but sometimes you want to specialize this behavior. This can be done by overwriting
  # the default accessors (using the same name as the attribute) and calling
  # <tt>read_attribute(attr_name)</tt> and <tt>write_attribute(attr_name, value)</tt> to actually
127
  # change things.
128
  #
D
Initial  
David Heinemeier Hansson 已提交
129 130
  #   class Song < ActiveRecord::Base
  #     # Uses an integer of seconds to hold the length of the song
131
  #
D
Initial  
David Heinemeier Hansson 已提交
132
  #     def length=(minutes)
133
  #       write_attribute(:length, minutes.to_i * 60)
D
Initial  
David Heinemeier Hansson 已提交
134
  #     end
135
  #
D
Initial  
David Heinemeier Hansson 已提交
136
  #     def length
137
  #       read_attribute(:length) / 60
D
Initial  
David Heinemeier Hansson 已提交
138 139
  #     end
  #   end
140
  #
141
  # You can alternatively use <tt>self[:attribute]=(value)</tt> and <tt>self[:attribute]</tt>
142
  # instead of <tt>write_attribute(:attribute, value)</tt> and <tt>read_attribute(:attribute)</tt>.
143
  #
144 145 146 147
  # == Attribute query methods
  #
  # In addition to the basic accessors, query methods are also automatically available on the Active Record object.
  # Query methods allow you to test whether an attribute value is present.
148
  #
149 150 151 152 153 154 155 156 157
  # For example, an Active Record User with the <tt>name</tt> attribute has a <tt>name?</tt> method that you can call
  # to determine whether the user has a name:
  #
  #   user = User.new(:name => "David")
  #   user.name? # => true
  #
  #   anonymous = User.new(:name => "")
  #   anonymous.name? # => false
  #
158
  # == Accessing attributes before they have been typecasted
159
  #
160 161 162
  # Sometimes you want to be able to read the raw attribute data without having the column-determined
  # typecast run its course first. That can be done by using the <tt><attribute>_before_type_cast</tt>
  # accessors that all attributes have. For example, if your Account model has a <tt>balance</tt> attribute,
163
  # you can call <tt>account.balance_before_type_cast</tt> or <tt>account.id_before_type_cast</tt>.
164
  #
165 166
  # This is especially useful in validation situations where the user might supply a string for an
  # integer field and you want to display the original string back in an error message. Accessing the
167
  # attribute normally would typecast the string to 0, which isn't what you want.
168
  #
169 170
  # == Dynamic attribute-based finders
  #
171 172 173 174 175
  # Dynamic attribute-based finders are a cleaner way of getting (and/or creating) objects
  # by simple queries without turning to SQL. They work by appending the name of an attribute
  # to <tt>find_by_</tt>, <tt>find_last_by_</tt>, or <tt>find_all_by_</tt> and thus produces finders
  # like <tt>Person.find_by_user_name</tt>, <tt>Person.find_all_by_last_name</tt>, and
  # <tt>Payment.find_by_transaction_id</tt>. Instead of writing
176
  # <tt>Person.where(:user_name => user_name).first</tt>, you just do <tt>Person.find_by_user_name(user_name)</tt>.
177
  # And instead of writing <tt>Person.where(:last_name => last_name).all</tt>, you just do
178
  # <tt>Person.find_all_by_last_name(last_name)</tt>.
179
  #
180
  # It's also possible to use multiple attributes in the same find by separating them with "_and_".
181
  #
182 183
  #  Person.where(:user_name => user_name, :password => password).first
  #  Person.find_by_user_name_and_password #with dynamic finder
184
  #
185 186
  #  Person.where(:user_name => user_name, :password => password, :gender => 'male').first
  #  Payment.find_by_user_name_and_password_and_gender
187
  #
188
  # It's even possible to call these dynamic finder methods on relations and named scopes.
189 190 191
  #
  #   Payment.order("created_on").find_all_by_amount(50)
  #   Payment.pending.find_last_by_amount(100)
192
  #
193 194 195 196
  # The same dynamic finder style can be used to create the object if it doesn't already exist.
  # This dynamic finder is called with <tt>find_or_create_by_</tt> and will return the object if
  # it already exists and otherwise creates it, then returns it. Protected attributes won't be set
  # unless they are given in a block.
197 198 199
  #
  #   # No 'Summer' tag exists
  #   Tag.find_or_create_by_name("Summer") # equal to Tag.create(:name => "Summer")
200
  #
201 202 203
  #   # Now the 'Summer' tag does exist
  #   Tag.find_or_create_by_name("Summer") # equal to Tag.find_by_name("Summer")
  #
204 205 206
  #   # Now 'Bob' exist and is an 'admin'
  #   User.find_or_create_by_name('Bob', :age => 40) { |u| u.admin = true }
  #
207
  # Use the <tt>find_or_initialize_by_</tt> finder if you want to return a new record without
208
  # saving it first. Protected attributes won't be set unless they are given in a block.
209 210 211
  #
  #   # No 'Winter' tag exists
  #   winter = Tag.find_or_initialize_by_name("Winter")
212
  #   winter.persisted? # false
213
  #
214
  # To find by a subset of the attributes to be used for instantiating a new object, pass a hash instead of
215
  # a list of parameters.
216 217 218
  #
  #   Tag.find_or_create_by_name(:name => "rails", :creator => current_user)
  #
219
  # That will either find an existing tag named "rails", or create a new one while setting the
220
  # user that created it.
221
  #
222 223 224 225
  # Just like <tt>find_by_*</tt>, you can also use <tt>scoped_by_*</tt> to retrieve data. The good thing about
  # using this feature is that the very first time result is returned using <tt>method_missing</tt> technique
  # but after that the method is declared on the class. Henceforth <tt>method_missing</tt> will not be hit.
  #
226
  #  User.scoped_by_user_name('David')
227
  #
228
  # == Saving arrays, hashes, and other non-mappable objects in text columns
229
  #
230
  # Active Record can serialize any object in text columns using YAML. To do so, you must
231
  # specify this with a call to the class method +serialize+.
232 233
  # This makes it possible to store arrays, hashes, and other non-mappable objects without doing
  # any additional work.
234
  #
D
Initial  
David Heinemeier Hansson 已提交
235 236 237
  #   class User < ActiveRecord::Base
  #     serialize :preferences
  #   end
238
  #
239
  #   user = User.create(:preferences => { "background" => "black", "display" => large })
D
Initial  
David Heinemeier Hansson 已提交
240
  #   User.find(user.id).preferences # => { "background" => "black", "display" => large }
241
  #
242
  # You can also specify a class option as the second parameter that'll raise an exception
243
  # if a serialized object is retrieved as a descendant of a class not in the hierarchy.
244
  #
D
Initial  
David Heinemeier Hansson 已提交
245
  #   class User < ActiveRecord::Base
246
  #     serialize :preferences, Hash
D
Initial  
David Heinemeier Hansson 已提交
247
  #   end
248
  #
249
  #   user = User.create(:preferences => %w( one two three ))
D
Initial  
David Heinemeier Hansson 已提交
250
  #   User.find(user.id).preferences    # raises SerializationTypeMismatch
251
  #
252 253 254 255 256 257 258 259 260 261 262
  # When you specify a class option, the default value for that attribute will be a new
  # instance of that class.
  #
  #   class User < ActiveRecord::Base
  #     serialize :preferences, OpenStruct
  #   end
  #
  #   user = User.new
  #   user.preferences.theme_color = "red"
  #
  #
D
Initial  
David Heinemeier Hansson 已提交
263 264
  # == Single table inheritance
  #
265 266
  # Active Record allows inheritance by storing the name of the class in a column that by
  # default is named "type" (can be changed by overwriting <tt>Base.inheritance_column</tt>).
267
  # This means that an inheritance looking like this:
D
Initial  
David Heinemeier Hansson 已提交
268 269 270 271 272 273
  #
  #   class Company < ActiveRecord::Base; end
  #   class Firm < Company; end
  #   class Client < Company; end
  #   class PriorityClient < Client; end
  #
274 275
  # When you do <tt>Firm.create(:name => "37signals")</tt>, this record will be saved in
  # the companies table with type = "Firm". You can then fetch this row again using
276
  # <tt>Company.where(:name => '37signals').first</tt> and it will return a Firm object.
D
Initial  
David Heinemeier Hansson 已提交
277
  #
278 279
  # If you don't have a type column defined in your table, single-table inheritance won't
  # be triggered. In that case, it'll work just like normal subclasses with no special magic
280
  # for differentiating between them or reloading the right type with find.
281
  #
D
Initial  
David Heinemeier Hansson 已提交
282 283
  # Note, all the attributes for all the cases are kept in the same table. Read more:
  # http://www.martinfowler.com/eaaCatalog/singleTableInheritance.html
284
  #
D
Initial  
David Heinemeier Hansson 已提交
285 286
  # == Connection to multiple databases in different models
  #
287 288 289
  # Connections are usually created through ActiveRecord::Base.establish_connection and retrieved
  # by ActiveRecord::Base.connection. All classes inheriting from ActiveRecord::Base will use this
  # connection. But you can also set a class-specific connection. For example, if Course is an
290
  # ActiveRecord::Base, but resides in a different database, you can just say <tt>Course.establish_connection</tt>
P
Pratik Naik 已提交
291
  # and Course and all of its subclasses will use this connection instead.
D
Initial  
David Heinemeier Hansson 已提交
292
  #
293 294
  # This feature is implemented by keeping a connection pool in ActiveRecord::Base that is
  # a Hash indexed by the class. If a connection is requested, the retrieve_connection method
295
  # will go up the class-hierarchy until a connection is found in the connection pool.
D
Initial  
David Heinemeier Hansson 已提交
296 297
  #
  # == Exceptions
298
  #
P
Pratik Naik 已提交
299 300
  # * ActiveRecordError - Generic error class and superclass of all other errors raised by Active Record.
  # * AdapterNotSpecified - The configuration hash used in <tt>establish_connection</tt> didn't include an
D
Initial  
David Heinemeier Hansson 已提交
301
  #   <tt>:adapter</tt> key.
302
  # * AdapterNotFound - The <tt>:adapter</tt> key used in <tt>establish_connection</tt> specified a
303
  #   non-existent adapter
304
  #   (or a bad spelling of an existing one).
305
  # * AssociationTypeMismatch - The object assigned to the association wasn't of the type
306
  #   specified in the association definition.
P
Pratik Naik 已提交
307
  # * SerializationTypeMismatch - The serialized object wasn't of the class specified as the second parameter.
308
  # * ConnectionNotEstablished+ - No connection has been established. Use <tt>establish_connection</tt>
309
  #   before querying.
P
Pratik Naik 已提交
310 311 312 313 314
  # * RecordNotFound - No record responded to the +find+ method. Either the row with the given ID doesn't exist
  #   or the row didn't meet the additional restrictions. Some +find+ calls do not raise this exception to signal
  #   nothing was found, please check its documentation for further details.
  # * StatementInvalid - The database server rejected the SQL statement. The precise error is added in the message.
  # * MultiparameterAssignmentErrors - Collection of errors that occurred during a mass assignment using the
315
  #   <tt>attributes=</tt> method. The +errors+ property of this exception contains an array of
316
  #   AttributeAssignmentError
317
  #   objects that should be inspected to determine which attributes triggered the errors.
318
  # * AttributeAssignmentError - An error occurred while doing a mass assignment through the
319
  #   <tt>attributes=</tt> method.
320
  #   You can inspect the +attribute+ property of the exception object to determine which attribute
321
  #   triggered the error.
322
  #
323
  # *Note*: The attributes listed are class-level attributes (accessible from both the class and instance level).
P
Pratik Naik 已提交
324
  # So it's possible to assign a logger to the class through <tt>Base.logger=</tt> which will then be used by all
D
Initial  
David Heinemeier Hansson 已提交
325 326
  # instances in the current object space.
  class Base
E
Emilio Tagua 已提交
327
    ##
P
Pratik Naik 已提交
328
    # :singleton-method:
329 330
    # Accepts a logger conforming to the interface of Log4r or the default Ruby 1.8+ Logger class,
    # which is then passed on to any new database connections made and which can be retrieved on both
331
    # a class and instance level by calling +logger+.
332
    cattr_accessor :logger, :instance_writer => false
J
Jeremy Kemper 已提交
333

P
Pratik Naik 已提交
334 335
    ##
    # :singleton-method:
P
Pratik Naik 已提交
336 337 338 339
    # Contains the database configuration - as is typically stored in config/database.yml -
    # as a Hash.
    #
    # For example, the following database.yml...
E
Emilio Tagua 已提交
340
    #
P
Pratik Naik 已提交
341 342 343
    #   development:
    #     adapter: sqlite3
    #     database: db/development.sqlite3
E
Emilio Tagua 已提交
344
    #
P
Pratik Naik 已提交
345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360
    #   production:
    #     adapter: sqlite3
    #     database: db/production.sqlite3
    #
    # ...would result in ActiveRecord::Base.configurations to look like this:
    #
    #   {
    #      'development' => {
    #         'adapter'  => 'sqlite3',
    #         'database' => 'db/development.sqlite3'
    #      },
    #      'production' => {
    #         'adapter'  => 'sqlite3',
    #         'database' => 'db/production.sqlite3'
    #      }
    #   }
361
    cattr_accessor :configurations, :instance_writer => false
362 363
    @@configurations = {}

P
Pratik Naik 已提交
364 365
    ##
    # :singleton-method:
366 367 368
    # Accessor for the prefix type that will be prepended to every primary key column name.
    # The options are :table_name and :table_name_with_underscore. If the first is specified,
    # the Product class will look for "productid" instead of "id" as the primary column. If the
369
    # latter is specified, the Product class will look for "product_id" instead of "id". Remember
370
    # that this is a global setting for all Active Records.
371
    cattr_accessor :primary_key_prefix_type, :instance_writer => false
D
Initial  
David Heinemeier Hansson 已提交
372 373
    @@primary_key_prefix_type = nil

P
Pratik Naik 已提交
374 375
    ##
    # :singleton-method:
376 377 378
    # Accessor for the name of the prefix string to prepend to every table name. So if set
    # to "basecamp_", all table names will be named like "basecamp_projects", "basecamp_people",
    # etc. This is a convenient way of creating a namespace for tables in a shared database.
379
    # By default, the prefix is the empty string.
380
    #
381 382
    # If you are organising your models within modules you can add a prefix to the models within
    # a namespace by defining a singleton method in the parent module called table_name_prefix which
383
    # returns your chosen prefix.
384 385
    class_attribute :table_name_prefix, :instance_writer => false
    self.table_name_prefix = ""
D
Initial  
David Heinemeier Hansson 已提交
386

P
Pratik Naik 已提交
387 388
    ##
    # :singleton-method:
D
Initial  
David Heinemeier Hansson 已提交
389 390
    # Works like +table_name_prefix+, but appends instead of prepends (set to "_basecamp" gives "projects_basecamp",
    # "people_basecamp"). By default, the suffix is the empty string.
391 392
    class_attribute :table_name_suffix, :instance_writer => false
    self.table_name_suffix = ""
D
Initial  
David Heinemeier Hansson 已提交
393

P
Pratik Naik 已提交
394 395
    ##
    # :singleton-method:
396
    # Indicates whether table names should be the pluralized versions of the corresponding class names.
P
Pratik Naik 已提交
397
    # If true, the default table name for a Product class will be +products+. If false, it would just be +product+.
D
Initial  
David Heinemeier Hansson 已提交
398
    # See table_name for the full rules on table/class naming. This is true, by default.
399
    cattr_accessor :pluralize_table_names, :instance_writer => false
D
Initial  
David Heinemeier Hansson 已提交
400 401
    @@pluralize_table_names = true

P
Pratik Naik 已提交
402 403
    ##
    # :singleton-method:
404
    # Determines whether to use Time.local (using :local) or Time.utc (using :utc) when pulling
405
    # dates and times from the database. This is set to :local by default.
406
    cattr_accessor :default_timezone, :instance_writer => false
407
    @@default_timezone = :local
408

P
Pratik Naik 已提交
409 410
    ##
    # :singleton-method:
411 412
    # Specifies the format to use when dumping the database schema with Rails'
    # Rakefile.  If :sql, the schema is dumped as (potentially database-
413
    # specific) SQL statements.  If :ruby, the schema is dumped as an
414 415 416
    # ActiveRecord::Schema file which can be loaded into any database that
    # supports migrations.  Use :ruby if you want to have different database
    # adapters for, e.g., your development and test environments.
417
    cattr_accessor :schema_format , :instance_writer => false
418
    @@schema_format = :ruby
419

P
Pratik Naik 已提交
420 421
    ##
    # :singleton-method:
422
    # Specify whether or not to use timestamps for migration versions
423 424 425
    cattr_accessor :timestamped_migrations , :instance_writer => false
    @@timestamped_migrations = true

426
    # Determine whether to store the full constant name including namespace when using STI
427
    class_attribute :store_full_sti_class
428
    self.store_full_sti_class = true
429

430
    # Stores the default scope for the class
431
    class_attribute :default_scoping, :instance_writer => false
432 433
    self.default_scoping = []

J
Jeremy Kemper 已提交
434 435 436 437 438
    # Returns a hash of all the attributes that have been specified for serialization as
    # keys and their class restriction as values.
    class_attribute :serialized_attributes
    self.serialized_attributes = {}

439 440 441
    class_attribute :_attr_readonly, :instance_writer => false
    self._attr_readonly = []

D
Initial  
David Heinemeier Hansson 已提交
442
    class << self # Class methods
443
      delegate :find, :first, :last, :all, :destroy, :destroy_all, :exists?, :delete, :delete_all, :update, :update_all, :to => :scoped
P
Pratik Naik 已提交
444
      delegate :find_each, :find_in_batches, :to => :scoped
445
      delegate :select, :group, :order, :except, :limit, :offset, :joins, :where, :preload, :eager_load, :includes, :from, :lock, :readonly, :having, :create_with, :to => :scoped
446
      delegate :count, :average, :minimum, :maximum, :sum, :calculate, :to => :scoped
447

P
Pratik Naik 已提交
448
      # Executes a custom SQL query against your database and returns all the results.  The results will
449
      # be returned as an array with columns requested encapsulated as attributes of the model you call
P
Pratik Naik 已提交
450 451
      # this method from.  If you call <tt>Product.find_by_sql</tt> then the results will be returned in
      # a Product object with the attributes you specified in the SQL query.
452
      #
453 454
      # If you call a complicated SQL query which spans multiple tables the columns specified by the
      # SELECT will be attributes of the model, whether or not they are columns of the corresponding
455 456
      # table.
      #
P
Pratik Naik 已提交
457
      # The +sql+ parameter is a full SQL query as a string.  It will be called as is, there will be
458 459
      # no database agnostic conversions performed.  This should be a last resort because using, for example,
      # MySQL specific terms will lock you to using that particular database engine or require you to
P
Pratik Naik 已提交
460
      # change your call if you switch engines.
461 462
      #
      # ==== Examples
P
Pratik Naik 已提交
463
      #   # A simple SQL query spanning multiple tables
464 465 466 467 468 469
      #   Post.find_by_sql "SELECT p.title, c.author FROM posts p, comments c WHERE p.id = c.post_id"
      #   > [#<Post:0x36bff9c @attributes={"title"=>"Ruby Meetup", "first_name"=>"Quentin"}>, ...]
      #
      #   # You can use the same string replacement techniques as you can with ActiveRecord#find
      #   Post.find_by_sql ["SELECT title FROM posts WHERE author = ? AND created > ?", author_id, start_date]
      #   > [#<Post:0x36bff9c @attributes={"first_name"=>"The Cheap Man Buys Twice"}>, ...]
470 471
      def find_by_sql(sql, binds = [])
        connection.select_all(sanitize_sql(sql), "#{name} Load", binds).collect! { |record| instantiate(record) }
D
Initial  
David Heinemeier Hansson 已提交
472
      end
473

474
      # Creates an object (or multiple objects) and saves it to the database, if validations pass.
475 476 477 478 479 480 481 482
      # The resulting object is returned whether the object was saved successfully to the database or not.
      #
      # The +attributes+ parameter can be either be a Hash or an Array of Hashes.  These Hashes describe the
      # attributes on the objects that are to be created.
      #
      # ==== Examples
      #   # Create a single new object
      #   User.create(:first_name => 'Jamie')
483
      #
484
      #   # Create an Array of new objects
P
Pratik Naik 已提交
485
      #   User.create([{ :first_name => 'Jamie' }, { :first_name => 'Jeremy' }])
486 487 488 489 490 491 492
      #
      #   # Create a single object and pass it into a block to set other attributes.
      #   User.create(:first_name => 'Jamie') do |u|
      #     u.is_admin = false
      #   end
      #
      #   # Creating an Array of new objects using a block, where the block is executed for each object:
P
Pratik Naik 已提交
493
      #   User.create([{ :first_name => 'Jamie' }, { :first_name => 'Jeremy' }]) do |u|
494
      #     u.is_admin = false
495
      #   end
496
      def create(attributes = nil, &block)
497
        if attributes.is_a?(Array)
498
          attributes.collect { |attr| create(attr, &block) }
499 500
        else
          object = new(attributes)
501
          yield(object) if block_given?
502 503 504
          object.save
          object
        end
D
Initial  
David Heinemeier Hansson 已提交
505 506 507
      end

      # Returns the result of an SQL statement that should only include a COUNT(*) in the SELECT part.
508
      # The use of this method should be restricted to complicated SQL queries that can't be executed
509 510
      # using the ActiveRecord::Calculations class methods.  Look into those before using this.
      #
P
Pratik Naik 已提交
511
      # ==== Parameters
512
      #
P
Pratik Naik 已提交
513
      # * +sql+ - An SQL statement which should return a count query from the database, see the example below.
514 515 516
      #
      # ==== Examples
      #
517
      #   Product.count_by_sql "SELECT COUNT(*) FROM sales s, customers c WHERE s.customer_id = c.id"
D
Initial  
David Heinemeier Hansson 已提交
518
      def count_by_sql(sql)
519
        sql = sanitize_conditions(sql)
520
        connection.select_value(sql, "#{name} Count").to_i
D
Initial  
David Heinemeier Hansson 已提交
521
      end
522

N
Neeraj Singh 已提交
523 524
      # Attributes listed as readonly will be used to create a new record but update operations will
      # ignore these fields.
525
      def attr_readonly(*attributes)
526
        self._attr_readonly = Set.new(attributes.map { |a| a.to_s }) + (self._attr_readonly || [])
D
Initial  
David Heinemeier Hansson 已提交
527
      end
528

529 530
      # Returns an array of all the attributes that have been specified as readonly.
      def readonly_attributes
531
        self._attr_readonly
D
Initial  
David Heinemeier Hansson 已提交
532 533
      end

534 535 536
      # If you have an attribute that needs to be saved to the database as an object, and retrieved as the same object,
      # then specify the name of that attribute using this method and it will be handled automatically.
      # The serialization is done through YAML. If +class_name+ is specified, the serialized object must be of that
P
Pratik Naik 已提交
537
      # class on retrieval or SerializationTypeMismatch will be raised.
D
David Heinemeier Hansson 已提交
538
      #
P
Pratik Naik 已提交
539
      # ==== Parameters
D
David Heinemeier Hansson 已提交
540
      #
P
Pratik Naik 已提交
541 542
      # * +attr_name+ - The field name that should be serialized.
      # * +class_name+ - Optional, class name that the object type should be equal to.
D
David Heinemeier Hansson 已提交
543 544 545 546 547 548
      #
      # ==== Example
      #   # Serialize a preferences attribute
      #   class User
      #     serialize :preferences
      #   end
D
Initial  
David Heinemeier Hansson 已提交
549
      def serialize(attr_name, class_name = Object)
550 551 552 553 554 555 556
        coder = if [:load, :dump].all? { |x| class_name.respond_to?(x) }
                  class_name
                else
                  Coders::YAMLColumn.new(class_name)
                end

        serialized_attributes[attr_name.to_s] = coder
D
Initial  
David Heinemeier Hansson 已提交
557
      end
558

559 560
      # Guesses the table name (in forced lower-case) based on the name of the class in the
      # inheritance hierarchy descending directly from ActiveRecord::Base. So if the hierarchy
561
      # looks like: Reply < Message < ActiveRecord::Base, then Message is used
562 563
      # to guess the table name even when called on Reply. The rules used to do the guess
      # are handled by the Inflector class in Active Support, which knows almost all common
564
      # English inflections. You can add new inflections in config/initializers/inflections.rb.
D
Initial  
David Heinemeier Hansson 已提交
565
      #
566
      # Nested classes are given table names prefixed by the singular form of
P
Pratik Naik 已提交
567 568 569
      # the parent's table name. Enclosing modules are not considered.
      #
      # ==== Examples
570 571
      #
      #   class Invoice < ActiveRecord::Base; end;
572 573
      #   file                  class               table_name
      #   invoice.rb            Invoice             invoices
574 575 576 577 578 579 580 581
      #
      #   class Invoice < ActiveRecord::Base; class Lineitem < ActiveRecord::Base; end; end;
      #   file                  class               table_name
      #   invoice.rb            Invoice::Lineitem   invoice_lineitems
      #
      #   module Invoice; class Lineitem < ActiveRecord::Base; end; end;
      #   file                  class               table_name
      #   invoice/lineitem.rb   Invoice::Lineitem   lineitems
D
Initial  
David Heinemeier Hansson 已提交
582
      #
P
Pratik Naik 已提交
583 584
      # Additionally, the class-level +table_name_prefix+ is prepended and the
      # +table_name_suffix+ is appended.  So if you have "myapp_" as a prefix,
585 586 587 588 589
      # the table name guess for an Invoice class becomes "myapp_invoices".
      # Invoice::Lineitem becomes "myapp_invoice_lineitems".
      #
      # You can also overwrite this class method to allow for unguessable
      # links, such as a Mouse class with a link to a "mice" table. Example:
D
Initial  
David Heinemeier Hansson 已提交
590 591
      #
      #   class Mouse < ActiveRecord::Base
592
      #     set_table_name "mice"
D
Initial  
David Heinemeier Hansson 已提交
593
      #   end
594
      def table_name
595 596 597
        reset_table_name
      end

598
      # Returns a quoted version of the table name, used to construct SQL statements.
P
Pratik Naik 已提交
599 600 601 602
      def quoted_table_name
        @quoted_table_name ||= connection.quote_table_name(table_name)
      end

603
      # Computes the table name, (re)sets it internally, and returns it.
D
David Heinemeier Hansson 已提交
604
      def reset_table_name #:nodoc:
605
        self.table_name = compute_table_name
D
Initial  
David Heinemeier Hansson 已提交
606 607
      end

608
      def full_table_name_prefix #:nodoc:
609 610 611
        (parents.detect{ |p| p.respond_to?(:table_name_prefix) } || self).table_name_prefix
      end

612
      # Defines the column name for use with single table inheritance. Use
N
Neeraj Singh 已提交
613
      # <tt>set_inheritance_column</tt> to set a different value.
D
Initial  
David Heinemeier Hansson 已提交
614
      def inheritance_column
A
Aaron Patterson 已提交
615
        @inheritance_column ||= "type"
D
Initial  
David Heinemeier Hansson 已提交
616 617
      end

618 619
      # Lazy-set the sequence name to the connection's default.  This method
      # is only ever called once since set_sequence_name overrides it.
D
David Heinemeier Hansson 已提交
620
      def sequence_name #:nodoc:
621 622 623
        reset_sequence_name
      end

D
David Heinemeier Hansson 已提交
624
      def reset_sequence_name #:nodoc:
625 626 627
        default = connection.default_sequence_name(table_name, primary_key)
        set_sequence_name(default)
        default
628 629
      end

630
      # Sets the table name. If the value is nil or false  then the value returned by the given
N
Neeraj Singh 已提交
631
      # block is used.
632 633 634 635
      #
      #   class Project < ActiveRecord::Base
      #     set_table_name "project"
      #   end
636
      def set_table_name(value = nil, &block)
637
        @quoted_table_name = nil
638 639 640 641 642 643
        define_attr_method :table_name, value, &block
      end
      alias :table_name= :set_table_name

      # Sets the name of the inheritance column to use to the given value,
      # or (if the value # is nil or false) to the value returned by the
644
      # given block.
645 646 647 648 649 650
      #
      #   class Project < ActiveRecord::Base
      #     set_inheritance_column do
      #       original_inheritance_column + "_id"
      #     end
      #   end
651
      def set_inheritance_column(value = nil, &block)
652 653 654 655
        define_attr_method :inheritance_column, value, &block
      end
      alias :inheritance_column= :set_inheritance_column

656 657
      # Sets the name of the sequence to use when generating ids to the given
      # value, or (if the value is nil or false) to the value returned by the
658 659
      # given block. This is required for Oracle and is useful for any
      # database which relies on sequences for primary key generation.
660
      #
661 662 663 664 665
      # If a sequence name is not explicitly set when using Oracle or Firebird,
      # it will default to the commonly used pattern of: #{table_name}_seq
      #
      # If a sequence name is not explicitly set when using PostgreSQL, it
      # will discover the sequence corresponding to your primary key for you.
666 667 668 669
      #
      #   class Project < ActiveRecord::Base
      #     set_sequence_name "projectseq"   # default would have been "project_seq"
      #   end
670
      def set_sequence_name(value = nil, &block)
671 672 673 674
        define_attr_method :sequence_name, value, &block
      end
      alias :sequence_name= :set_sequence_name

675 676
      # Indicates whether the table associated with this class exists
      def table_exists?
677
        connection.table_exists?(table_name)
678 679
      end

D
Initial  
David Heinemeier Hansson 已提交
680 681
      # Returns an array of column objects for the table associated with this class.
      def columns
682 683 684 685 686
        @@columns[table_name] ||= connection.columns(
          table_name, "#{name} Columns"
        ).tap { |columns|
          columns.each { |column| column.primary = column.name == primary_key }
        }
D
Initial  
David Heinemeier Hansson 已提交
687
      end
688

689
      # Returns a hash of column objects for the table associated with this class.
D
Initial  
David Heinemeier Hansson 已提交
690
      def columns_hash
691
        @@columns_hash[table_name] ||= Hash[columns.map { |column| [column.name, column] }]
D
Initial  
David Heinemeier Hansson 已提交
692
      end
693

D
David Heinemeier Hansson 已提交
694
      # Returns an array of column names as strings.
695
      def column_names
696
        @column_names ||= columns.map { |column| column.name }
697
      end
D
Initial  
David Heinemeier Hansson 已提交
698

699 700
      # Returns an array of column objects where the primary id, all columns ending in "_id" or "_count",
      # and columns used for single table inheritance have been removed.
D
Initial  
David Heinemeier Hansson 已提交
701
      def content_columns
702
        @content_columns ||= columns.reject { |c| c.primary || c.name =~ /(_id|_count)$/ || c.name == inheritance_column }
D
Initial  
David Heinemeier Hansson 已提交
703 704 705 706
      end

      # Returns a hash of all the methods added to query each of the columns in the table with the name of the method as the key
      # and true as the value. This makes it possible to do O(1) lookups in respond_to? to check if a given method for attribute
707
      # is available.
D
David Heinemeier Hansson 已提交
708
      def column_methods_hash #:nodoc:
709
        @dynamic_methods_hash ||= column_names.inject(Hash.new(false)) do |methods, attr|
710 711 712 713 714
          attr_name = attr.to_s
          methods[attr.to_sym]       = attr_name
          methods["#{attr}=".to_sym] = attr_name
          methods["#{attr}?".to_sym] = attr_name
          methods["#{attr}_before_type_cast".to_sym] = attr_name
D
Initial  
David Heinemeier Hansson 已提交
715 716 717
          methods
        end
      end
718

P
Pratik Naik 已提交
719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744
      # Resets all the cached information about columns, which will cause them
      # to be reloaded on the next request.
      #
      # The most common usage pattern for this method is probably in a migration,
      # when just after creating a table you want to populate it with some default
      # values, eg:
      #
      #  class CreateJobLevels < ActiveRecord::Migration
      #    def self.up
      #      create_table :job_levels do |t|
      #        t.integer :id
      #        t.string :name
      #
      #        t.timestamps
      #      end
      #
      #      JobLevel.reset_column_information
      #      %w{assistant executive manager director}.each do |type|
      #        JobLevel.create(:name => type)
      #      end
      #    end
      #
      #    def self.down
      #      drop_table :job_levels
      #    end
      #  end
745
      def reset_column_information
A
Aaron Patterson 已提交
746
        connection.clear_cache!
747
        undefine_attribute_methods
748 749
        reset_column_cache
        @column_names = @content_columns = @dynamic_methods_hash = @inheritance_column = nil
750
        @arel_engine = @relation = nil
751 752
      end

753 754 755
      def reset_column_cache # :nodoc:
        @@columns.delete table_name
        @@columns_hash.delete table_name
756
        @@arel_tables.delete table_name
757 758
      end

759
      def attribute_method?(attribute)
J
José Valim 已提交
760
        super || (table_exists? && column_names.include?(attribute.to_s.sub(/=$/, '')))
761 762
      end

763 764
      # Set the lookup ancestors for ActiveModel.
      def lookup_ancestors #:nodoc:
765 766
        klass = self
        classes = [klass]
767 768
        return classes if klass == ActiveRecord::Base

E
Emilio Tagua 已提交
769
        while klass != klass.base_class
770 771 772 773 774
          classes << klass = klass.superclass
        end
        classes
      end

775 776 777
      # Set the i18n scope to overwrite ActiveModel.
      def i18n_scope #:nodoc:
        :activerecord
D
Initial  
David Heinemeier Hansson 已提交
778
      end
779

780 781 782 783 784 785 786
      # True if this isn't a concrete subclass needing a STI type condition.
      def descends_from_active_record?
        if superclass.abstract_class?
          superclass.descends_from_active_record?
        else
          superclass == Base || !columns_hash.include?(inheritance_column)
        end
D
Initial  
David Heinemeier Hansson 已提交
787 788
      end

789 790 791 792 793
      def finder_needs_type_condition? #:nodoc:
        # This is like this because benchmarking justifies the strange :false stuff
        :true == (@finder_needs_type_condition ||= descends_from_active_record? ? :false : :true)
      end

A
Akira Matsuda 已提交
794
      # Returns a string like 'Post(id:integer, title:string, body:text)'
795
      def inspect
796 797 798 799
        if self == Base
          super
        elsif abstract_class?
          "#{super}(abstract)"
800
        elsif table_exists?
801 802
          attr_list = columns.map { |c| "#{c.name}: #{c.type}" } * ', '
          "#{super}(#{attr_list})"
803 804
        else
          "#{super}(Table doesn't exist)"
805
        end
806 807
      end

808
      def quote_value(value, column = nil) #:nodoc:
809
        connection.quote(value,column)
810 811
      end

812
      # Used to sanitize objects before they're used in an SQL SELECT statement. Delegates to <tt>connection.quote</tt>.
813
      def sanitize(object) #:nodoc:
814
        connection.quote(object)
D
Initial  
David Heinemeier Hansson 已提交
815 816
      end

817 818 819
      # Overwrite the default class equality method to provide support for association proxies.
      def ===(object)
        object.is_a?(self)
820
      end
821

822 823 824
      # Returns the base AR subclass that this class descends from. If A
      # extends AR::Base, A.base_class will return A. If B descends from A
      # through some arbitrarily deep hierarchy, B.base_class will return A.
825 826 827
      #
      # If B < A and C < B and if A is an abstract_class then both B.base_class
      # and C.base_class would return B as the answer since A is an abstract_class.
828 829 830 831
      def base_class
        class_of_active_record_descendant(self)
      end

P
Pratik Naik 已提交
832
      # Set this to true if this is an abstract class (see <tt>abstract_class?</tt>).
833 834
      attr_accessor :abstract_class

835
      # Returns whether this class is an abstract class or not.
836
      def abstract_class?
837
        defined?(@abstract_class) && @abstract_class == true
838 839
      end

840
      def respond_to?(method_id, include_private = false)
841 842
        if match = DynamicFinderMatch.match(method_id)
          return true if all_attributes_exists?(match.attribute_names)
843 844
        elsif match = DynamicScopeMatch.match(method_id)
          return true if all_attributes_exists?(match.attribute_names)
845
        end
846

847 848 849
        super
      end

850 851 852 853
      def sti_name
        store_full_sti_class ? name : name.demodulize
      end

P
Pratik Naik 已提交
854
      def arel_table
855
        @@arel_tables[table_name] ||= Arel::Table.new(table_name, arel_engine)
856 857
      end

858
      def arel_engine
859 860 861 862 863 864 865
        @arel_engine ||= begin
          if self == ActiveRecord::Base
            ActiveRecord::Base
          else
            connection_handler.connection_pools[name] ? self : superclass.arel_engine
          end
        end
866 867
      end

868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883
      # Returns a scope for this class without taking into account the default_scope.
      #
      #   class Post < ActiveRecord::Base
      #     default_scope :published => true
      #   end
      #
      #   Post.all          # Fires "SELECT * FROM posts WHERE published = true"
      #   Post.unscoped.all # Fires "SELECT * FROM posts"
      #
      # This method also accepts a block meaning that all queries inside the block will
      # not use the default_scope:
      #
      #   Post.unscoped {
      #     limit(10) # Fires "SELECT * FROM posts LIMIT 10"
      #   }
      #
884 885
      # It is recommended to use block form of unscoped because chaining unscoped with <tt>scope</tt>
      # does not work. Assuming that <tt>published</tt> is a <tt>scope</tt> following two statements are same.
886
      #
887 888
      # Post.unscoped.published
      # Post.published
889
      def unscoped #:nodoc:
890 891 892 893 894 895 896 897
        block_given? ? relation.scoping { yield } : relation
      end

      def scoped_methods #:nodoc:
        key = :"#{self}_scoped_methods"
        Thread.current[key] = Thread.current[key].presence || self.default_scoping.dup
      end

898 899 900 901
      def before_remove_const #:nodoc:
        reset_scoped_methods
      end

J
Jon Leighton 已提交
902 903 904 905 906 907 908 909 910 911
      # Specifies how the record is loaded by +Marshal+.
      #
      # +_load+ sets an instance variable for each key in the hash it takes as input.
      # Override this method if you require more complex marshalling.
      def _load(data)
        record = allocate
        record.init_with(Marshal.load(data))
        record
      end

912 913 914 915 916 917 918 919 920 921

      # Finder methods must instantiate through this method to work with the
      # single-table inheritance model that makes it possible to create
      # objects of different types from the same table.
      def instantiate(record) # :nodoc:
        model = find_sti_class(record[inheritance_column]).allocate
        model.init_with('attributes' => record)
        model
      end

D
Initial  
David Heinemeier Hansson 已提交
922
      private
J
José Valim 已提交
923 924 925

        def relation #:nodoc:
          @relation ||= Relation.new(self, arel_table)
926 927 928 929 930 931

          if finder_needs_type_condition?
            @relation.where(type_condition).create_with(inheritance_column.to_sym => sti_name)
          else
            @relation
          end
J
José Valim 已提交
932 933
        end

934
        def find_sti_class(type_name)
935
          if type_name.blank? || !columns_hash.include?(inheritance_column)
936 937 938
            self
          else
            begin
939 940 941 942 943
              if store_full_sti_class
                ActiveSupport::Dependencies.constantize(type_name)
              else
                compute_type(type_name)
              end
944 945 946 947 948 949 950 951 952 953
            rescue NameError
              raise SubclassNotFound,
                "The single-table inheritance mechanism failed to locate the subclass: '#{type_name}'. " +
                "This error is raised because the column '#{inheritance_column}' is reserved for storing the class in case of inheritance. " +
                "Please rename this column if you didn't intend it to be used for storing the inheritance class " +
                "or overwrite #{name}.inheritance_column to use another column for that information."
            end
          end
        end

954
        def construct_finder_arel(options = {}, scope = nil)
955
          relation = options.is_a?(Hash) ? unscoped.apply_finder_options(options) : options
956
          relation = scope.merge(relation) if scope
957
          relation
958 959
        end

960
        def type_condition
961
          sti_column = arel_table[inheritance_column.to_sym]
962
          sti_names  = ([self] + descendants).map { |model| model.sti_name }
963

964
          sti_column.in(sti_names)
D
Initial  
David Heinemeier Hansson 已提交
965 966 967
        end

        # Guesses the table name, but does not decorate it with prefix and suffix information.
968
        def undecorated_table_name(class_name = base_class.name)
969 970
          table_name = class_name.to_s.demodulize.underscore
          table_name = table_name.pluralize if pluralize_table_names
971
          table_name
D
Initial  
David Heinemeier Hansson 已提交
972 973
        end

974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990
        # Computes and returns a table name according to default conventions.
        def compute_table_name
          base = base_class
          if self == base
            # Nested classes are prefixed with singular parent table name.
            if parent < ActiveRecord::Base && !parent.abstract_class?
              contained = parent.table_name
              contained = contained.singularize if parent.pluralize_table_names
              contained << '_'
            end
            "#{full_table_name_prefix}#{contained}#{undecorated_table_name(name)}#{table_name_suffix}"
          else
            # STI subclasses always use their superclass' table.
            base.table_name
          end
        end

991
        # Enables dynamic finders like <tt>User.find_by_user_name(user_name)</tt> and
992 993
        # <tt>User.scoped_by_user_name(user_name). Refer to Dynamic attribute-based finders
        # section at the top of this file for more detailed information.
994
        #
995
        # It's even possible to use all the additional parameters to +find+. For example, the
996
        # full interface for +find_all_by_amount+ is actually <tt>find_all_by_amount(amount, options)</tt>.
997
        #
998
        # Each dynamic finder using <tt>scoped_by_*</tt> is also defined in the class after it
999
        # is first invoked, so that future attempts to use it do not run through method_missing.
1000
        def method_missing(method_id, *arguments, &block)
1001 1002
          if match = DynamicFinderMatch.match(method_id)
            attribute_names = match.attribute_names
1003
            super unless all_attributes_exists?(attribute_names)
1004
            if match.finder?
1005
              options = arguments.extract_options!
1006
              relation = options.any? ? construct_finder_arel(options, current_scoped_methods) : scoped
1007
              relation.send :find_by_attributes, match, attribute_names, *arguments
1008
            elsif match.instantiator?
1009
              scoped.send :find_or_instantiator_by_attributes, match, attribute_names, *arguments, &block
1010
            end
1011 1012 1013 1014
          elsif match = DynamicScopeMatch.match(method_id)
            attribute_names = match.attribute_names
            super unless all_attributes_exists?(attribute_names)
            if match.scope?
1015
              self.class_eval <<-METHOD, __FILE__, __LINE__ + 1
1016 1017 1018 1019 1020
                def self.#{method_id}(*args)                                    # def self.scoped_by_user_name_and_password(*args)
                  attributes = Hash[[:#{attribute_names.join(',:')}].zip(args)] #   attributes = Hash[[:user_name, :password].zip(args)]
                                                                                #
                  scoped(:conditions => attributes)                             #   scoped(:conditions => attributes)
                end                                                             # end
1021
              METHOD
1022 1023
              send(method_id, *arguments)
            end
1024 1025 1026 1027
          else
            super
          end
        end
D
Initial  
David Heinemeier Hansson 已提交
1028

1029 1030
        # Similar in purpose to +expand_hash_conditions_for_aggregates+.
        def expand_attribute_names_for_aggregates(attribute_names)
1031
          attribute_names.map { |attribute_name|
1032
            unless (aggregation = reflect_on_aggregation(attribute_name.to_sym)).nil?
1033 1034
              aggregate_mapping(aggregation).map do |field_attr, _|
                field_attr.to_sym
1035 1036
              end
            else
1037
              attribute_name.to_sym
1038
            end
1039
          }.flatten
1040 1041
        end

1042
        def all_attributes_exists?(attribute_names)
1043 1044
          (expand_attribute_names_for_aggregates(attribute_names) -
           column_methods_hash.keys).empty?
1045
        end
1046

D
Initial  
David Heinemeier Hansson 已提交
1047
      protected
N
Neeraj Singh 已提交
1048 1049
        # with_scope lets you apply options to inner block incrementally. It takes a hash and the keys must be
        # <tt>:find</tt> or <tt>:create</tt>. <tt>:find</tt> parameter is <tt>Relation</tt> while
1050
        # <tt>:create</tt> parameters are an attributes hash.
1051 1052 1053
        #
        #   class Article < ActiveRecord::Base
        #     def self.create_with_scope
1054
        #       with_scope(:find => where(:blog_id => 1), :create => { :blog_id => 1 }) do
1055 1056 1057 1058 1059 1060 1061
        #         find(1) # => SELECT * from articles WHERE blog_id = 1 AND id = 1
        #         a = create(1)
        #         a.blog_id # => 1
        #       end
        #     end
        #   end
        #
D
David Heinemeier Hansson 已提交
1062
        # In nested scopings, all previous parameters are overwritten by the innermost rule, with the exception of
1063
        # <tt>where</tt>, <tt>includes</tt>, and <tt>joins</tt> operations in <tt>Relation</tt>, which are merged.
P
Pratik Naik 已提交
1064
        #
1065
        # <tt>joins</tt> operations are uniqued so multiple scopes can join in the same table without table aliasing
P
Pratik Naik 已提交
1066 1067
        # problems.  If you need to join multiple tables, but still want one of the tables to be uniqued, use the
        # array of strings format for your joins.
1068 1069 1070
        #
        #   class Article < ActiveRecord::Base
        #     def self.find_with_scope
1071 1072 1073
        #       with_scope(:find => where(:blog_id => 1).limit(1), :create => { :blog_id => 1 }) do
        #         with_scope(:find => limit(10)) do
        #           all # => SELECT * from articles WHERE blog_id = 1 LIMIT 10
1074
        #         end
1075 1076
        #         with_scope(:find => where(:author_id => 3)) do
        #           all # => SELECT * from articles WHERE blog_id = 1 AND author_id = 3 LIMIT 1
1077 1078 1079 1080 1081
        #         end
        #       end
        #     end
        #   end
        #
1082
        # You can ignore any previous scopings by using the <tt>with_exclusive_scope</tt> method.
1083 1084 1085
        #
        #   class Article < ActiveRecord::Base
        #     def self.find_with_exclusive_scope
1086
        #       with_scope(:find => where(:blog_id => 1).limit(1)) do
1087
        #         with_exclusive_scope(:find => limit(10)) do
1088
        #           all # => SELECT * from articles LIMIT 10
1089 1090 1091 1092
        #         end
        #       end
        #     end
        #   end
P
Pratik Naik 已提交
1093
        #
N
Neeraj Singh 已提交
1094
        # *Note*: the +:find+ scope also has effect on update and deletion methods, like +update_all+ and +delete_all+.
1095 1096 1097
        def with_scope(method_scoping = {}, action = :merge, &block)
          method_scoping = method_scoping.method_scoping if method_scoping.respond_to?(:method_scoping)

1098 1099
          if method_scoping.is_a?(Hash)
            # Dup first and second level of hash (method and params).
1100 1101 1102
            method_scoping = method_scoping.dup
            method_scoping.each do |method, params|
              method_scoping[method] = params.dup unless params == true
1103
            end
1104

1105 1106 1107 1108
            method_scoping.assert_valid_keys([ :find, :create ])
            relation = construct_finder_arel(method_scoping[:find] || {})

            if current_scoped_methods && current_scoped_methods.create_with_value && method_scoping[:create]
1109
              scope_for_create = if action == :merge
1110 1111 1112
                current_scoped_methods.create_with_value.merge(method_scoping[:create])
              else
                method_scoping[:create]
1113
              end
1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124

              relation = relation.create_with(scope_for_create)
            else
              scope_for_create = method_scoping[:create]
              scope_for_create ||= current_scoped_methods.create_with_value if current_scoped_methods
              relation = relation.create_with(scope_for_create) if scope_for_create
            end

            method_scoping = relation
          end

1125
          method_scoping = current_scoped_methods.merge(method_scoping) if current_scoped_methods && action ==  :merge
1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136

          self.scoped_methods << method_scoping
          begin
            yield
          ensure
            self.scoped_methods.pop
          end
        end

        # Works like with_scope, but discards any nested properties.
        def with_exclusive_scope(method_scoping = {}, &block)
1137
          if method_scoping.values.any? { |e| e.is_a?(ActiveRecord::Relation) }
1138 1139
            raise ArgumentError, <<-MSG
New finder API can not be used with_exclusive_scope. You can either call unscoped to get an anonymous scope not bound to the default_scope:
1140

1141 1142 1143 1144 1145 1146 1147 1148 1149
  User.unscoped.where(:active => true)

Or call unscoped with a block:

  User.unscoped do
    User.where(:active => true).all
  end

MSG
1150
          end
1151 1152 1153
          with_scope(method_scoping, :overwrite, &block)
        end

1154
        # Sets the default options for the model. The format of the
1155
        # <tt>options</tt> argument is the same as in find.
1156 1157
        #
        #   class Person < ActiveRecord::Base
1158
        #     default_scope order('last_name, first_name')
1159
        #   end
1160 1161 1162 1163 1164 1165 1166 1167
        #
        # <tt>default_scope</tt> is also applied while creating/building a record. It is not
        # applied while updating a record.
        #
        #   class Article < ActiveRecord::Base
        #     default_scope where(:published => true)
        #   end
        #
1168 1169
        #   Article.new.published    # => true
        #   Article.create.published # => true
1170
        def default_scope(options = {})
1171
          reset_scoped_methods
1172 1173
          default_scoping = self.default_scoping.dup
          self.default_scoping = default_scoping << construct_finder_arel(options, default_scoping.pop)
1174 1175
        end

D
David Heinemeier Hansson 已提交
1176
        def current_scoped_methods #:nodoc:
T
Tim Morgan 已提交
1177 1178
          method = scoped_methods.last
          if method.respond_to?(:call)
1179
            relation.scoping { method.call }
T
Tim Morgan 已提交
1180 1181 1182
          else
            method
          end
1183
        end
1184

1185 1186 1187 1188
        def reset_scoped_methods #:nodoc:
          Thread.current[:"#{self}_scoped_methods"] = nil
        end

P
Pratik Naik 已提交
1189
        # Returns the class type of the record using the current module as a prefix. So descendants of
1190
        # MyApp::Business::Account would appear as MyApp::Business::AccountSubclass.
D
Initial  
David Heinemeier Hansson 已提交
1191
        def compute_type(type_name)
1192 1193 1194
          if type_name.match(/^::/)
            # If the type is prefixed with a scope operator then we assume that
            # the type_name is an absolute reference.
1195
            ActiveSupport::Dependencies.constantize(type_name)
1196 1197 1198 1199 1200 1201 1202 1203
          else
            # Build a list of candidates to search for
            candidates = []
            name.scan(/::|$/) { candidates.unshift "#{$`}::#{type_name}" }
            candidates << type_name

            candidates.each do |candidate|
              begin
1204
                constant = ActiveSupport::Dependencies.constantize(candidate)
1205
                return constant if candidate == constant.to_s
1206 1207 1208
              rescue NameError => e
                # We don't want to swallow NoMethodError < NameError errors
                raise e unless e.instance_of?(NameError)
1209 1210
              rescue ArgumentError
              end
1211
            end
1212 1213

            raise NameError, "uninitialized constant #{candidates.first}"
D
Initial  
David Heinemeier Hansson 已提交
1214 1215 1216
          end
        end

P
Pratik Naik 已提交
1217 1218
        # Returns the class descending directly from ActiveRecord::Base or an
        # abstract class, if any, in the inheritance hierarchy.
1219
        def class_of_active_record_descendant(klass)
1220
          if klass.superclass == Base || klass.superclass.abstract_class?
1221
            klass
D
Initial  
David Heinemeier Hansson 已提交
1222 1223 1224
          elsif klass.superclass.nil?
            raise ActiveRecordError, "#{name} doesn't belong in a hierarchy descending from ActiveRecord"
          else
1225
            class_of_active_record_descendant(klass.superclass)
D
Initial  
David Heinemeier Hansson 已提交
1226 1227 1228
          end
        end

P
Pratik Naik 已提交
1229
        # Accepts an array, hash, or string of SQL conditions and sanitizes
1230
        # them into a valid SQL fragment for a WHERE clause.
1231 1232 1233
        #   ["name='%s' and group_id='%s'", "foo'bar", 4]  returns  "name='foo''bar' and group_id='4'"
        #   { :name => "foo'bar", :group_id => 4 }  returns "name='foo''bar' and group_id='4'"
        #   "name='foo''bar' and group_id='4'" returns "name='foo''bar' and group_id='4'"
1234
        def sanitize_sql_for_conditions(condition, table_name = self.table_name)
1235 1236
          return nil if condition.blank?

1237 1238
          case condition
            when Array; sanitize_sql_array(condition)
1239
            when Hash;  sanitize_sql_hash_for_conditions(condition, table_name)
1240 1241
            else        condition
          end
1242
        end
1243
        alias_method :sanitize_sql, :sanitize_sql_for_conditions
1244

P
Pratik Naik 已提交
1245
        # Accepts an array, hash, or string of SQL conditions and sanitizes
1246 1247 1248 1249 1250 1251 1252 1253 1254 1255
        # them into a valid SQL fragment for a SET clause.
        #   { :name => nil, :group_id => 4 }  returns "name = NULL , group_id='4'"
        def sanitize_sql_for_assignment(assignments)
          case assignments
            when Array; sanitize_sql_array(assignments)
            when Hash;  sanitize_sql_hash_for_assignment(assignments)
            else        assignments
          end
        end

1256 1257 1258 1259 1260
        def aggregate_mapping(reflection)
          mapping = reflection.options[:mapping] || [reflection.name, reflection.name]
          mapping.first.is_a?(Array) ? mapping : [mapping]
        end

P
Pratik Naik 已提交
1261
        # Accepts a hash of SQL conditions and replaces those attributes
1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290
        # that correspond to a +composed_of+ relationship with their expanded
        # aggregate attribute values.
        # Given:
        #     class Person < ActiveRecord::Base
        #       composed_of :address, :class_name => "Address",
        #         :mapping => [%w(address_street street), %w(address_city city)]
        #     end
        # Then:
        #     { :address => Address.new("813 abc st.", "chicago") }
        #       # => { :address_street => "813 abc st.", :address_city => "chicago" }
        def expand_hash_conditions_for_aggregates(attrs)
          expanded_attrs = {}
          attrs.each do |attr, value|
            unless (aggregation = reflect_on_aggregation(attr.to_sym)).nil?
              mapping = aggregate_mapping(aggregation)
              mapping.each do |field_attr, aggregate_attr|
                if mapping.size == 1 && !value.respond_to?(aggregate_attr)
                  expanded_attrs[field_attr] = value
                else
                  expanded_attrs[field_attr] = value.send(aggregate_attr)
                end
              end
            else
              expanded_attrs[attr] = value
            end
          end
          expanded_attrs
        end

1291
        # Sanitizes a hash of attribute/value pairs into SQL conditions for a WHERE clause.
1292 1293 1294 1295
        #   { :name => "foo'bar", :group_id => 4 }
        #     # => "name='foo''bar' and group_id= 4"
        #   { :status => nil, :group_id => [1,2,3] }
        #     # => "status IS NULL and group_id IN (1,2,3)"
1296 1297
        #   { :age => 13..18 }
        #     # => "age BETWEEN 13 AND 18"
1298 1299
        #   { 'other_records.id' => 7 }
        #     # => "`other_records`.`id` = 7"
1300 1301
        #   { :other_records => { :id => 7 } }
        #     # => "`other_records`.`id` = 7"
1302 1303 1304
        # And for value objects on a composed_of relationship:
        #   { :address => Address.new("123 abc st.", "chicago") }
        #     # => "address_street='123 abc st.' and address_city='chicago'"
1305
        def sanitize_sql_hash_for_conditions(attrs, default_table_name = self.table_name)
1306 1307
          attrs = expand_hash_conditions_for_aggregates(attrs)

1308
          table = Arel::Table.new(self.table_name, :engine => arel_engine, :as => default_table_name)
1309 1310 1311 1312
          viz = Arel::Visitors.for(arel_engine)
          PredicateBuilder.build_from_hash(arel_engine, attrs, table).map { |b|
            viz.accept b
          }.join(' AND ')
1313
        end
1314 1315 1316 1317 1318 1319
        alias_method :sanitize_sql_hash, :sanitize_sql_hash_for_conditions

        # Sanitizes a hash of attribute/value pairs into SQL conditions for a SET clause.
        #   { :status => nil, :group_id => 1 }
        #     # => "status = NULL , group_id = 1"
        def sanitize_sql_hash_for_assignment(attrs)
1320
          attrs.map do |attr, value|
1321 1322 1323
            "#{connection.quote_column_name(attr)} = #{quote_bound_value(value)}"
          end.join(', ')
        end
1324

1325
        # Accepts an array of conditions.  The array has each value
P
Pratik Naik 已提交
1326
        # sanitized and interpolated into the SQL statement.
1327
        #   ["name='%s' and group_id='%s'", "foo'bar", 4]  returns  "name='foo''bar' and group_id='4'"
1328
        def sanitize_sql_array(ary)
1329
          statement, *values = ary
1330
          if values.first.is_a?(Hash) && statement =~ /:\w+/
1331 1332
            replace_named_bind_variables(statement, values.first)
          elsif statement.include?('?')
1333
            replace_bind_variables(statement, values)
1334 1335
          elsif statement.blank?
            statement
1336
          else
1337
            statement % values.collect { |value| connection.quote_string(value.to_s) }
1338
          end
1339 1340
        end

1341 1342
        alias_method :sanitize_conditions, :sanitize_sql

D
David Heinemeier Hansson 已提交
1343
        def replace_bind_variables(statement, values) #:nodoc:
1344
          raise_if_bind_arity_mismatch(statement, statement.count('?'), values.size)
1345
          bound = values.dup
C
Comron Sattari 已提交
1346 1347
          c = connection
          statement.gsub('?') { quote_bound_value(bound.shift, c) }
1348 1349
        end

D
David Heinemeier Hansson 已提交
1350
        def replace_named_bind_variables(statement, bind_vars) #:nodoc:
1351 1352 1353 1354
          statement.gsub(/(:?):([a-zA-Z]\w*)/) do
            if $1 == ':' # skip postgresql casts
              $& # return the whole match
            elsif bind_vars.include?(match = $2.to_sym)
1355
              quote_bound_value(bind_vars[match])
1356 1357
            else
              raise PreparedStatementInvalid, "missing value for :#{match} in #{statement}"
1358 1359
            end
          end
1360 1361
        end

1362
        def expand_range_bind_variables(bind_vars) #:nodoc:
1363 1364 1365
          expanded = []

          bind_vars.each do |var|
1366 1367
            next if var.is_a?(Hash)

1368
            if var.is_a?(Range)
1369 1370
              expanded << var.first
              expanded << var.last
1371
            else
1372
              expanded << var
1373
            end
1374
          end
1375 1376

          expanded
1377 1378
        end

C
Comron Sattari 已提交
1379
        def quote_bound_value(value, c = connection) #:nodoc:
1380
          if value.respond_to?(:map) && !value.acts_like?(:string)
1381
            if value.respond_to?(:empty?) && value.empty?
C
Comron Sattari 已提交
1382
              c.quote(nil)
1383
            else
C
Comron Sattari 已提交
1384
              value.map { |v| c.quote(v) }.join(',')
1385
            end
1386
          else
C
Comron Sattari 已提交
1387
            c.quote(value)
1388 1389 1390
          end
        end

D
David Heinemeier Hansson 已提交
1391
        def raise_if_bind_arity_mismatch(statement, expected, provided) #:nodoc:
1392 1393 1394
          unless expected == provided
            raise PreparedStatementInvalid, "wrong number of bind variables (#{provided} for #{expected}) in: #{statement}"
          end
1395
        end
1396

D
David Heinemeier Hansson 已提交
1397
        def encode_quoted_value(value) #:nodoc:
1398
          quoted_value = connection.quote(value)
1399 1400
          quoted_value = "'#{quoted_value[1..-2].gsub(/\'/, "\\\\'")}'" if quoted_value.include?("\\\'") # (for ruby mode) "
          quoted_value
1401
        end
D
Initial  
David Heinemeier Hansson 已提交
1402
    end
1403 1404
    @@columns_hash = {}
    @@columns      = {}
1405
    @@arel_tables  = {}
D
Initial  
David Heinemeier Hansson 已提交
1406 1407 1408 1409

    public
      # New objects can be instantiated as either empty (pass no construction parameter) or pre-set with
      # attributes but not yet saved (pass a hash with key names matching the associated table column names).
1410
      # In both instances, valid attribute keys are determined by the column names of the associated table --
D
Initial  
David Heinemeier Hansson 已提交
1411 1412
      # hence you can't have attributes that aren't part of the table columns.
      def initialize(attributes = nil)
1413
        @attributes = attributes_from_column_definition
1414
        @association_cache = {}
1415
        @aggregation_cache = {}
1416
        @attributes_cache = {}
1417
        @new_record = true
1418
        @readonly = false
1419 1420
        @destroyed = false
        @marked_for_destruction = false
1421 1422
        @previously_changed = {}
        @changed_attributes = {}
1423

D
Initial  
David Heinemeier Hansson 已提交
1424
        ensure_proper_type
1425
        set_serialized_attributes
P
Pratik Naik 已提交
1426

1427
        populate_with_current_scope_attributes
1428
        self.attributes = attributes unless attributes.nil?
P
Pratik Naik 已提交
1429

1430
        result = yield self if block_given?
1431
        run_callbacks :initialize
1432
        result
D
Initial  
David Heinemeier Hansson 已提交
1433
      end
1434

1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450
      # Populate +coder+ with attributes about this record that should be
      # serialized.  The structure of +coder+ defined in this method is
      # guaranteed to match the structure of +coder+ passed to the +init_with+
      # method.
      #
      # Example:
      #
      #   class Post < ActiveRecord::Base
      #   end
      #   coder = {}
      #   Post.new.encode_with(coder)
      #   coder # => { 'id' => nil, ... }
      def encode_with(coder)
        coder['attributes'] = attributes
      end

1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462
      # Initialize an empty model object from +coder+.  +coder+ must contain
      # the attributes necessary for initializing an empty model object.  For
      # example:
      #
      #   class Post < ActiveRecord::Base
      #   end
      #
      #   post = Post.allocate
      #   post.init_with('attributes' => { 'title' => 'hello world' })
      #   post.title # => 'hello world'
      def init_with(coder)
        @attributes = coder['attributes']
1463

1464
        set_serialized_attributes
1465

1466
        @attributes_cache, @previously_changed, @changed_attributes = {}, {}, {}
1467
        @association_cache = {}
1468
        @aggregation_cache = {}
1469
        @readonly = @destroyed = @marked_for_destruction = false
1470
        @new_record = false
1471 1472
        run_callbacks :find
        run_callbacks :initialize
1473 1474
      end

J
Jon Leighton 已提交
1475 1476 1477 1478 1479 1480 1481 1482 1483 1484
      # Specifies how the record is dumped by +Marshal+.
      #
      # +_dump+ emits a marshalled hash which has been passed to +encode_with+. Override this
      # method if you require more complex marshalling.
      def _dump(level)
        dump = {}
        encode_with(dump)
        Marshal.dump(dump)
      end

P
Pratik Naik 已提交
1485 1486 1487 1488
      # Returns a String, which Action Pack uses for constructing an URL to this
      # object. The default implementation returns this record's id as a String,
      # or nil if this record's unsaved.
      #
P
Pratik Naik 已提交
1489
      # For example, suppose that you have a User model, and that you have a
1490
      # <tt>resources :users</tt> route. Normally, +user_path+ will
P
Pratik Naik 已提交
1491
      # construct a path with the user object's 'id' in it:
P
Pratik Naik 已提交
1492 1493
      #
      #   user = User.find_by_name('Phusion')
1494
      #   user_path(user)  # => "/users/1"
P
Pratik Naik 已提交
1495
      #
P
Pratik Naik 已提交
1496 1497
      # You can override +to_param+ in your model to make +user_path+ construct
      # a path using the user's name instead of the user's id:
P
Pratik Naik 已提交
1498 1499 1500 1501 1502 1503
      #
      #   class User < ActiveRecord::Base
      #     def to_param  # overridden
      #       name
      #     end
      #   end
E
Emilio Tagua 已提交
1504
      #
P
Pratik Naik 已提交
1505
      #   user = User.find_by_name('Phusion')
1506
      #   user_path(user)  # => "/users/Phusion"
1507
      def to_param
1508
        # We can't use alias_method here, because method 'id' optimizes itself on the fly.
1509
        id && id.to_s # Be sure to stringify the id for routes
1510
      end
1511

P
Pratik Naik 已提交
1512 1513 1514
      # Returns a cache key that can be used to identify this record.
      #
      # ==== Examples
1515 1516 1517 1518 1519
      #
      #   Product.new.cache_key     # => "products/new"
      #   Product.find(5).cache_key # => "products/5" (updated_at not available)
      #   Person.find(5).cache_key  # => "people/5-20071224150000" (updated_at available)
      def cache_key
1520
        case
1521
        when new_record?
J
Jeremy Kemper 已提交
1522 1523 1524
          "#{self.class.model_name.cache_key}/new"
        when timestamp = self[:updated_at]
          "#{self.class.model_name.cache_key}/#{id}-#{timestamp.to_s(:number)}"
1525
        else
J
Jeremy Kemper 已提交
1526
          "#{self.class.model_name.cache_key}/#{id}"
1527 1528
        end
      end
1529

1530
      def quoted_id #:nodoc:
1531
        quote_value(id, column_for_attribute(self.class.primary_key))
1532
      end
1533

1534 1535 1536 1537 1538
      # Returns true if the given attribute is in the attributes hash
      def has_attribute?(attr_name)
        @attributes.has_key?(attr_name.to_s)
      end

1539
      # Returns an array of names for the attributes available on this object.
1540
      def attribute_names
1541
        @attributes.keys
1542 1543
      end

D
Initial  
David Heinemeier Hansson 已提交
1544
      # Allows you to set all the attributes at once by passing in a hash with keys
P
Pratik Naik 已提交
1545 1546 1547 1548 1549 1550
      # matching the attribute names (which again matches the column names).
      #
      # If +guard_protected_attributes+ is true (the default), then sensitive
      # attributes can be protected from this form of mass-assignment by using
      # the +attr_protected+ macro. Or you can alternatively specify which
      # attributes *can* be accessed with the +attr_accessible+ macro. Then all the
1551
      # attributes not included in that won't be allowed to be mass-assigned.
P
Pratik Naik 已提交
1552 1553 1554 1555
      #
      #   class User < ActiveRecord::Base
      #     attr_protected :is_admin
      #   end
E
Emilio Tagua 已提交
1556
      #
P
Pratik Naik 已提交
1557 1558 1559 1560
      #   user = User.new
      #   user.attributes = { :username => 'Phusion', :is_admin => true }
      #   user.username   # => "Phusion"
      #   user.is_admin?  # => false
E
Emilio Tagua 已提交
1561
      #
P
Pratik Naik 已提交
1562 1563
      #   user.send(:attributes=, { :username => 'Phusion', :is_admin => true }, false)
      #   user.is_admin?  # => true
1564
      def attributes=(new_attributes, guard_protected_attributes = true)
P
Pratik Naik 已提交
1565
        return unless new_attributes.is_a?(Hash)
1566
        attributes = new_attributes.stringify_keys
D
Initial  
David Heinemeier Hansson 已提交
1567 1568

        multi_parameter_attributes = []
1569
        attributes = sanitize_for_mass_assignment(attributes) if guard_protected_attributes
1570

1571
        attributes.each do |k, v|
1572 1573
          if k.include?("(")
            multi_parameter_attributes << [ k, v ]
J
José Valim 已提交
1574 1575
          elsif respond_to?("#{k}=")
            send("#{k}=", v)
1576
          else
J
José Valim 已提交
1577
            raise(UnknownAttributeError, "unknown attribute: #{k}")
1578
          end
D
Initial  
David Heinemeier Hansson 已提交
1579
        end
D
David Heinemeier Hansson 已提交
1580

D
Initial  
David Heinemeier Hansson 已提交
1581 1582 1583
        assign_multiparameter_attributes(multi_parameter_attributes)
      end

1584
      # Returns a hash of all the attributes with their names as keys and the values of the attributes as values.
1585
      def attributes
1586
        Hash[@attributes.map { |name, _| [name, read_attribute(name)] }]
1587 1588
      end

P
Pratik Naik 已提交
1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601
      # Returns an <tt>#inspect</tt>-like string for the value of the
      # attribute +attr_name+. String attributes are elided after 50
      # characters, and Date and Time attributes are returned in the
      # <tt>:db</tt> format. Other attributes return the value of
      # <tt>#inspect</tt> without modification.
      #
      #   person = Person.create!(:name => "David Heinemeier Hansson " * 3)
      #
      #   person.attribute_for_inspect(:name)
      #   # => '"David Heinemeier Hansson David Heinemeier Hansson D..."'
      #
      #   person.attribute_for_inspect(:created_at)
      #   # => '"2009-01-12 04:48:57"'
1602 1603 1604
      def attribute_for_inspect(attr_name)
        value = read_attribute(attr_name)

1605
        if value.is_a?(String) && value.length > 50
1606
          "#{value[0..50]}...".inspect
1607 1608
        elsif value.is_a?(Date) || value.is_a?(Time)
          %("#{value.to_s(:db)}")
1609 1610 1611 1612 1613
        else
          value.inspect
        end
      end

D
Initial  
David Heinemeier Hansson 已提交
1614
      # Returns true if the specified +attribute+ has been set by the user or by a database load and is neither
1615
      # nil nor empty? (the latter only applies to objects that respond to empty?, most notably Strings).
D
Initial  
David Heinemeier Hansson 已提交
1616
      def attribute_present?(attribute)
1617
        !_read_attribute(attribute).blank?
D
Initial  
David Heinemeier Hansson 已提交
1618 1619 1620 1621
      end

      # Returns the column object for the named attribute.
      def column_for_attribute(name)
1622
        self.class.columns_hash[name.to_s]
D
Initial  
David Heinemeier Hansson 已提交
1623
      end
1624

1625
      # Returns true if +comparison_object+ is the same exact object, or +comparison_object+
X
Xavier Noria 已提交
1626 1627 1628 1629 1630 1631 1632 1633
      # is of the same type and +self+ has an ID and it is equal to +comparison_object.id+.
      #
      # Note that new records are different from any other record by definition, unless the
      # other record is the receiver itself. Besides, if you fetch existing records with
      # +select+ and leave the ID out, you're on your own, this predicate will return false.
      #
      # Note also that destroying a record preserves its ID in the model instance, so deleted
      # models are still comparable.
D
Initial  
David Heinemeier Hansson 已提交
1634
      def ==(comparison_object)
1635
        comparison_object.equal?(self) ||
1636 1637 1638
          comparison_object.instance_of?(self.class) &&
          id.present? &&
          comparison_object.id == id
D
Initial  
David Heinemeier Hansson 已提交
1639 1640 1641 1642
      end

      # Delegates to ==
      def eql?(comparison_object)
E
Emilio Tagua 已提交
1643
        self == comparison_object
D
Initial  
David Heinemeier Hansson 已提交
1644
      end
1645

D
Initial  
David Heinemeier Hansson 已提交
1646 1647 1648
      # Delegates to id in order to allow two records of the same type and id to work with something like:
      #   [ Person.find(1), Person.find(2), Person.find(3) ] & [ Person.find(1), Person.find(4) ] # => [ Person.find(1) ]
      def hash
1649
        id.hash
D
Initial  
David Heinemeier Hansson 已提交
1650 1651
      end

1652
      # Freeze the attributes hash such that associations are still accessible, even on destroyed records.
1653
      def freeze
1654
        @attributes.freeze; self
1655
      end
1656

1657
      # Returns +true+ if the attributes hash has been frozen.
1658 1659 1660
      def frozen?
        @attributes.frozen?
      end
1661

A
Aaron Patterson 已提交
1662 1663 1664 1665 1666 1667 1668 1669 1670
      # Backport dup from 1.9 so that initialize_dup() gets called
      unless Object.respond_to?(:initialize_dup)
        def dup # :nodoc:
          copy = super
          copy.initialize_dup(self)
          copy
        end
      end

A
Aaron Patterson 已提交
1671
      # Duped objects have no id assigned and are treated as new records. Note
A
Aaron Patterson 已提交
1672 1673
      # that this is a "shallow" copy as it copies the object's attributes
      # only, not its associations. The extent of a "deep" copy is application
A
Aaron Patterson 已提交
1674 1675
      # specific and is therefore left to the application to implement according
      # to its need.
1676
      # The dup method does not preserve the timestamps (created|updated)_(at|on).
A
Aaron Patterson 已提交
1677
      def initialize_dup(other)
A
Aaron Patterson 已提交
1678 1679 1680
        cloned_attributes = other.clone_attributes(:read_attribute_before_type_cast)
        cloned_attributes.delete(self.class.primary_key)

A
Aaron Patterson 已提交
1681 1682
        @attributes = cloned_attributes

A
Aaron Patterson 已提交
1683 1684
        _run_after_initialize_callbacks if respond_to?(:_run_after_initialize_callbacks)

A
Aaron Patterson 已提交
1685 1686 1687 1688
        @changed_attributes = {}
        attributes_from_column_definition.each do |attr, orig_value|
          @changed_attributes[attr] = orig_value if field_changed?(attr, orig_value, @attributes[attr])
        end
A
Aaron Patterson 已提交
1689

1690
        @aggregation_cache = {}
1691 1692
        @association_cache = {}
        @attributes_cache = {}
1693
        @new_record  = true
A
Aaron Patterson 已提交
1694

A
Aaron Patterson 已提交
1695 1696
        ensure_proper_type
        populate_with_current_scope_attributes
1697
        clear_timestamp_attributes
A
Aaron Patterson 已提交
1698 1699
      end

1700 1701
      # Returns +true+ if the record is read only. Records loaded through joins with piggy-back
      # attributes will be marked as read only since they cannot be saved.
1702
      def readonly?
1703
        @readonly
1704 1705
      end

1706 1707
      # Marks this record as read only.
      def readonly!
1708 1709
        @readonly = true
      end
1710

1711
      # Returns the contents of the record as a nicely formatted string.
1712
      def inspect
1713
        attributes_as_nice_string = self.class.column_names.collect { |name|
1714
          if has_attribute?(name)
1715 1716 1717
            "#{name}: #{attribute_for_inspect(name)}"
          end
        }.compact.join(", ")
1718
        "#<#{self.class} #{attributes_as_nice_string}>"
1719
      end
1720

1721 1722
    protected
      def clone_attributes(reader_method = :read_attribute, attributes = {})
1723 1724
        attribute_names.each do |name|
          attributes[name] = clone_attribute_value(reader_method, name)
1725
        end
1726
        attributes
1727 1728 1729 1730 1731 1732 1733 1734 1735
      end

      def clone_attribute_value(reader_method, attribute_name)
        value = send(reader_method, attribute_name)
        value.duplicable? ? value.clone : value
      rescue TypeError, NoMethodError
        value
      end

D
Initial  
David Heinemeier Hansson 已提交
1736 1737
    private

A
Aaron Patterson 已提交
1738 1739 1740 1741 1742 1743 1744
      def set_serialized_attributes
        (@attributes.keys & self.class.serialized_attributes.keys).each do |key|
          coder = self.class.serialized_attributes[key]
          @attributes[key] = coder.load @attributes[key]
        end
      end

1745
      # Sets the attribute used for single table inheritance to this class name if this is not the
1746
      # ActiveRecord::Base descendant.
1747 1748
      # Considering the hierarchy Reply < Message < ActiveRecord::Base, this makes it possible to
      # do Reply.new without having to set <tt>Reply[Reply.inheritance_column] = "Reply"</tt> yourself.
1749
      # No such attribute would be set for objects of the Message class in that example.
D
Initial  
David Heinemeier Hansson 已提交
1750 1751
      def ensure_proper_type
        unless self.class.descends_from_active_record?
1752
          write_attribute(self.class.inheritance_column, self.class.sti_name)
D
Initial  
David Heinemeier Hansson 已提交
1753 1754 1755
        end
      end

1756
      # The primary key and inheritance column can never be set by mass-assignment for security reasons.
1757 1758 1759
      def self.attributes_protected_by_default
        default = [ primary_key, inheritance_column ]
        default << 'id' unless primary_key.eql? 'id'
1760
        default
1761 1762
      end

1763 1764
      # Returns a copy of the attributes hash where all the values have been safely quoted for use in
      # an Arel insert/update method.
1765
      def arel_attributes_values(include_primary_key = true, include_readonly_attributes = true, attribute_names = @attributes.keys)
1766 1767 1768 1769
        attrs      = {}
        klass      = self.class
        arel_table = klass.arel_table

1770 1771 1772 1773
        attribute_names.each do |name|
          if (column = column_for_attribute(name)) && (include_primary_key || !column.primary)

            if include_readonly_attributes || (!include_readonly_attributes && !self.class.readonly_attributes.include?(name))
1774

1775 1776
              value = if coder = klass.serialized_attributes[name]
                        coder.dump @attributes[name]
1777 1778 1779 1780 1781 1782 1783 1784
                      else
                        # FIXME: we need @attributes to be used consistently.
                        # If the values stored in @attributes were already type
                        # casted, this code could be simplified
                        read_attribute(name)
                      end

              attrs[arel_table[name]] = value
1785 1786 1787 1788 1789 1790
            end
          end
        end
        attrs
      end

D
Initial  
David Heinemeier Hansson 已提交
1791
      # Quote strings appropriately for SQL statements.
1792
      def quote_value(value, column = nil)
1793
        self.class.connection.quote(value, column)
D
Initial  
David Heinemeier Hansson 已提交
1794 1795
      end

P
Pratik Naik 已提交
1796
      # Interpolate custom SQL string in instance context.
D
Initial  
David Heinemeier Hansson 已提交
1797 1798
      # Optional record argument is meant for custom insert_sql.
      def interpolate_sql(sql, record = nil)
1799
        instance_eval("%@#{sql.gsub('@', '\@')}@", __FILE__, __LINE__)
D
Initial  
David Heinemeier Hansson 已提交
1800 1801 1802 1803 1804 1805
      end

      # Instantiates objects for all attribute classes that needs more than one constructor parameter. This is done
      # by calling new on the column type or aggregation type (through composed_of) object with these parameters.
      # So having the pairs written_on(1) = "2004", written_on(2) = "6", written_on(3) = "24", will instantiate
      # written_on (a date type) with Date.new("2004", "6", "24"). You can also specify a typecast character in the
1806 1807
      # parentheses to have the parameters typecasted before they're used in the constructor. Use i for Fixnum,
      # f for Float, s for String, and a for Array. If all the values for a given attribute are empty, the
1808
      # attribute will be set to nil.
D
Initial  
David Heinemeier Hansson 已提交
1809 1810 1811 1812 1813
      def assign_multiparameter_attributes(pairs)
        execute_callstack_for_multiparameter_attributes(
          extract_callstack_for_multiparameter_attributes(pairs)
        )
      end
1814

1815
      def instantiate_time_object(name, values)
1816
        if self.class.send(:create_time_zone_conversion_attribute?, name, column_for_attribute(name))
1817
          Time.zone.local(*values)
1818
        else
1819
          Time.time_with_datetime_fallback(@@default_timezone, *values)
1820
        end
1821 1822
      end

D
Initial  
David Heinemeier Hansson 已提交
1823
      def execute_callstack_for_multiparameter_attributes(callstack)
1824
        errors = []
1825
        callstack.each do |name, values_with_empty_parameters|
1826 1827
          begin
            klass = (self.class.reflect_on_aggregation(name.to_sym) || column_for_attribute(name)).klass
1828 1829
            # in order to allow a date to be set without a year, we must keep the empty values.
            # Otherwise, we wouldn't be able to distinguish it from a date with an empty day.
1830
            values = values_with_empty_parameters.reject { |v| v.nil? }
1831

1832 1833 1834
            if values.empty?
              send(name + "=", nil)
            else
1835

1836
              value = if Time == klass
1837
                instantiate_time_object(name, values)
1838 1839
              elsif Date == klass
                begin
1840
                  values = values_with_empty_parameters.collect do |v| v.nil? ? 1 : v end
1841 1842
                  Date.new(*values)
                rescue ArgumentError => ex # if Date.new raises an exception on an invalid date
1843
                  instantiate_time_object(name, values).to_date # we instantiate Time object and convert it back to a date thus using Time's logic in handling invalid dates
1844 1845 1846 1847 1848 1849
                end
              else
                klass.new(*values)
              end

              send(name + "=", value)
1850
            end
1851 1852
          rescue => ex
            errors << AttributeAssignmentError.new("error on assignment #{values.inspect} to #{name}", ex, name)
D
Initial  
David Heinemeier Hansson 已提交
1853 1854
          end
        end
1855 1856 1857
        unless errors.empty?
          raise MultiparameterAssignmentErrors.new(errors), "#{errors.size} error(s) on assignment of multiparameter attributes"
        end
D
Initial  
David Heinemeier Hansson 已提交
1858
      end
1859

D
Initial  
David Heinemeier Hansson 已提交
1860 1861 1862 1863 1864 1865 1866 1867
      def extract_callstack_for_multiparameter_attributes(pairs)
        attributes = { }

        for pair in pairs
          multiparameter_name, value = pair
          attribute_name = multiparameter_name.split("(").first
          attributes[attribute_name] = [] unless attributes.include?(attribute_name)

1868 1869
          parameter_value = value.empty? ? nil : type_cast_attribute_value(multiparameter_name, value)
          attributes[attribute_name] << [ find_parameter_position(multiparameter_name), parameter_value ]
D
Initial  
David Heinemeier Hansson 已提交
1870 1871 1872 1873
        end

        attributes.each { |name, values| attributes[name] = values.sort_by{ |v| v.first }.collect { |v| v.last } }
      end
1874

D
Initial  
David Heinemeier Hansson 已提交
1875
      def type_cast_attribute_value(multiparameter_name, value)
1876
        multiparameter_name =~ /\([0-9]*([if])\)/ ? value.send("to_" + $1) : value
D
Initial  
David Heinemeier Hansson 已提交
1877
      end
1878

D
Initial  
David Heinemeier Hansson 已提交
1879 1880 1881
      def find_parameter_position(multiparameter_name)
        multiparameter_name.scan(/\(([0-9]*).*\)/).first.first
      end
1882

D
Initial  
David Heinemeier Hansson 已提交
1883 1884
      # Returns a comma-separated pair list, like "key1 = val1, key2 = val2".
      def comma_pair_list(hash)
1885
        hash.map { |k,v| "#{k} = #{v}" }.join(", ")
D
Initial  
David Heinemeier Hansson 已提交
1886 1887
      end

1888
      def quote_columns(quoter, hash)
1889
        Hash[hash.map { |name, value| [quoter.quote_column_name(name), value] }]
D
Initial  
David Heinemeier Hansson 已提交
1890 1891
      end

1892 1893
      def quoted_comma_pair_list(quoter, hash)
        comma_pair_list(quote_columns(quoter, hash))
D
Initial  
David Heinemeier Hansson 已提交
1894 1895
      end

1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907
      def convert_number_column_value(value)
        if value == false
          0
        elsif value == true
          1
        elsif value.is_a?(String) && value.blank?
          nil
        else
          value
        end
      end

1908 1909 1910
      def populate_with_current_scope_attributes
        if scope = self.class.send(:current_scoped_methods)
          create_with = scope.scope_for_create
1911
          create_with.each { |att,value|
J
José Valim 已提交
1912
            respond_to?("#{att}=") && send("#{att}=", value)
1913
          }
1914 1915
        end
      end
1916

1917
      # Clear attributes and changed_attributes
1918
      def clear_timestamp_attributes
1919 1920 1921
        all_timestamp_attributes_in_model.each do |attribute_name|
          self[attribute_name] = nil
          changed_attributes.delete(attribute_name)
1922 1923
        end
      end
D
Initial  
David Heinemeier Hansson 已提交
1924
  end
J
Joshua Peek 已提交
1925 1926

  Base.class_eval do
1927
    include ActiveRecord::Persistence
J
Joshua Peek 已提交
1928
    extend ActiveModel::Naming
J
Joshua Peek 已提交
1929
    extend QueryCache::ClassMethods
J
José Valim 已提交
1930
    extend ActiveSupport::Benchmarkable
1931
    extend ActiveSupport::DescendantsTracker
J
José Valim 已提交
1932

1933
    include ActiveModel::Conversion
J
Joshua Peek 已提交
1934
    include Validations
1935
    extend CounterCache
J
Joshua Peek 已提交
1936 1937
    include Locking::Optimistic, Locking::Pessimistic
    include AttributeMethods
J
Joshua Peek 已提交
1938
    include AttributeMethods::Read, AttributeMethods::Write, AttributeMethods::BeforeTypeCast, AttributeMethods::Query
1939
    include AttributeMethods::PrimaryKey
J
Joshua Peek 已提交
1940 1941
    include AttributeMethods::TimeZoneConversion
    include AttributeMethods::Dirty
1942
    include ActiveModel::MassAssignmentSecurity
1943
    include Callbacks, ActiveModel::Observing, Timestamp
J
Joshua Peek 已提交
1944
    include Associations, AssociationPreload, NamedScope
1945
    include ActiveModel::SecurePassword
1946 1947 1948 1949

    # AutosaveAssociation needs to be included before Transactions, because we want
    # #save_with_autosave_associations to be wrapped inside a transaction.
    include AutosaveAssociation, NestedAttributes
P
Pratik Naik 已提交
1950
    include Aggregations, Transactions, Reflection, Serialization
1951

1952
    NilClass.add_whiner(self) if NilClass.respond_to?(:add_whiner)
1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963

    # Returns the value of the attribute identified by <tt>attr_name</tt> after it has been typecast (for example,
    # "2004-12-12" in a data column is cast to a date object, like Date.new(2004, 12, 12)).
    # (Alias for the protected read_attribute method).
    alias [] read_attribute

    # Updates the attribute identified by <tt>attr_name</tt> with the specified +value+.
    # (Alias for the protected write_attribute method).
    alias []= write_attribute

    public :[], :[]=
J
Joshua Peek 已提交
1964
  end
1965
end
1966 1967 1968

# TODO: Remove this and make it work with LAZY flag
require 'active_record/connection_adapters/abstract_adapter'
1969
ActiveSupport.run_load_hooks(:active_record, ActiveRecord::Base)