diff options
Diffstat (limited to 'activerecord/lib')
| -rw-r--r-- | activerecord/lib/active_record/relation.rb | 16 | ||||
| -rw-r--r-- | activerecord/lib/active_record/relation/query_methods.rb | 35 | ||||
| -rw-r--r-- | activerecord/lib/active_record/statement_cache.rb | 8 |
3 files changed, 54 insertions, 5 deletions
diff --git a/activerecord/lib/active_record/relation.rb b/activerecord/lib/active_record/relation.rb index ae3fa85da9..13fab1d9f1 100644 --- a/activerecord/lib/active_record/relation.rb +++ b/activerecord/lib/active_record/relation.rb @@ -202,7 +202,8 @@ module ActiveRecord # Please see further details in the # {Active Record Query Interface guide}[http://guides.rubyonrails.org/active_record_querying.html#running-explain]. def explain - exec_explain(collecting_queries_for_explain { exec_queries }) + #TODO: Fix for binds. + #exec_explain(collecting_queries_for_explain { exec_queries }) end # Converts relation objects to Array. @@ -566,6 +567,19 @@ module ActiveRecord "#<#{self.class.name} [#{entries.join(', ')}]>" end + def replace_binds(bind_values) + temp_binds = [] + bind_values.map do |column, value| + case value + when String, Integer + if @klass.column_names.include? column.to_s + temp_binds.push([@klass.columns_hash[column.to_s], value]) + end + end + end + self.bind_values = temp_binds + end + private def exec_queries diff --git a/activerecord/lib/active_record/relation/query_methods.rb b/activerecord/lib/active_record/relation/query_methods.rb index d020f1ba52..4628a5811b 100644 --- a/activerecord/lib/active_record/relation/query_methods.rb +++ b/activerecord/lib/active_record/relation/query_methods.rb @@ -377,6 +377,9 @@ module ActiveRecord end end + #For bind param caching. TODO: VALIDATE AND CORRECT THIS + self.bind_values = [] + #end self end @@ -804,7 +807,7 @@ module ActiveRecord build_joins(arel, joins_values) unless joins_values.empty? - collapse_wheres(arel, (where_values - ['']).uniq) + collapse_wheres(arel, (where_values - [''])) #TODO: Add uniq with real value comparison / ignore uniqs that have binds arel.having(*having_values.uniq.reject{|h| h.blank?}) unless having_values.empty? @@ -893,8 +896,12 @@ module ActiveRecord when String, Array [@klass.send(:sanitize_sql, other.empty? ? opts : ([opts] + other))] when Hash - attributes = @klass.send(:expand_hash_conditions_for_aggregates, opts) + temp_opts = opts.dup + create_binds(temp_opts) + temp_opts = substitute_opts(temp_opts) + + attributes = @klass.send(:expand_hash_conditions_for_aggregates, temp_opts) attributes.values.grep(ActiveRecord::Relation) do |rel| self.bind_values += rel.bind_values end @@ -905,6 +912,30 @@ module ActiveRecord end end + def create_binds(temp_opts) + binds = [] + temp_opts.map do |column, value| + case value + when String, Integer + if @klass.column_names.include? column.to_s + binds.push([@klass.columns_hash[column.to_s], value]) + end + end + end + self.bind_values += binds + end + + def substitute_opts(temp_opts) + temp_opts = temp_opts.each_with_index do |(column,value), index| + if @klass.columns_hash[column.to_s] != nil + case value + when String, Integer + temp_opts[column] = connection.substitute_at(column, index) + end + end + end + end + def build_from opts, name = from_value case opts diff --git a/activerecord/lib/active_record/statement_cache.rb b/activerecord/lib/active_record/statement_cache.rb index dd4ee0c4a0..3fadc38543 100644 --- a/activerecord/lib/active_record/statement_cache.rb +++ b/activerecord/lib/active_record/statement_cache.rb @@ -19,8 +19,12 @@ module ActiveRecord raise ArgumentError.new("Statement cannot be nil") if @relation.nil? end - def execute - @relation.dup.to_a + def execute(binds = nil) + rel = @relation.dup + if (binds != nil) + rel.replace_binds binds + end + rel.to_a end end end |