aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorNick Kallen <nkallen@nick-kallens-computer-2.local>2008-05-27 14:37:11 -0700
committerBryan Helmkamp <bryan@brynary.com>2009-05-17 15:46:19 -0400
commit20b28b441b651d0404d64049253898c061a039be (patch)
tree4b9a8fc9e8f9207017248f129550c0283b0f520b /lib
parent2fe585328d6a24df310d3e60059c9c7b05b64bac (diff)
downloadrails-20b28b441b651d0404d64049253898c061a039be.tar.gz
rails-20b28b441b651d0404d64049253898c061a039be.tar.bz2
rails-20b28b441b651d0404d64049253898c061a039be.zip
using in memory relations as results from sql relation
Conflicts: lib/arel/algebra/primitives/expression.rb lib/arel/algebra/relations/relation.rb
Diffstat (limited to 'lib')
-rw-r--r--lib/arel/algebra/extensions.rb1
-rw-r--r--lib/arel/algebra/extensions/symbol.rb5
-rw-r--r--lib/arel/algebra/primitives/attribute.rb4
-rw-r--r--lib/arel/algebra/primitives/expression.rb2
-rw-r--r--lib/arel/algebra/relations/relation.rb11
-rw-r--r--lib/arel/algebra/relations/utilities/externalization.rb2
-rw-r--r--lib/arel/engines/memory/relations.rb1
-rw-r--r--lib/arel/engines/memory/relations/array.rb4
-rw-r--r--lib/arel/engines/memory/relations/relation.rb7
-rw-r--r--lib/arel/engines/sql/engine.rb10
-rw-r--r--lib/arel/engines/sql/relations/operations/join.rb2
11 files changed, 27 insertions, 22 deletions
diff --git a/lib/arel/algebra/extensions.rb b/lib/arel/algebra/extensions.rb
index 5338fee989..694dc60a2a 100644
--- a/lib/arel/algebra/extensions.rb
+++ b/lib/arel/algebra/extensions.rb
@@ -1,4 +1,5 @@
require 'arel/algebra/extensions/object'
require 'arel/algebra/extensions/class'
require 'arel/algebra/extensions/array'
+require 'arel/algebra/extensions/symbol'
require 'arel/algebra/extensions/hash'
diff --git a/lib/arel/algebra/extensions/symbol.rb b/lib/arel/algebra/extensions/symbol.rb
new file mode 100644
index 0000000000..787867bdc3
--- /dev/null
+++ b/lib/arel/algebra/extensions/symbol.rb
@@ -0,0 +1,5 @@
+class Symbol
+ def to_attribute(relation)
+ Arel::Attribute.new(relation, self)
+ end
+end \ No newline at end of file
diff --git a/lib/arel/algebra/primitives/attribute.rb b/lib/arel/algebra/primitives/attribute.rb
index 7a4411e248..aa1f2ae00c 100644
--- a/lib/arel/algebra/primitives/attribute.rb
+++ b/lib/arel/algebra/primitives/attribute.rb
@@ -39,8 +39,8 @@ module Arel
relation == new_relation ? self : Attribute.new(new_relation, name, :alias => @alias, :ancestor => self)
end
- def to_attribute
- self
+ def to_attribute(relation)
+ bind(relation)
end
end
include Transformations
diff --git a/lib/arel/algebra/primitives/expression.rb b/lib/arel/algebra/primitives/expression.rb
index 989397720c..5566e2d0b7 100644
--- a/lib/arel/algebra/primitives/expression.rb
+++ b/lib/arel/algebra/primitives/expression.rb
@@ -22,7 +22,7 @@ module Arel
new_relation == relation ? self : self.class.new(attribute.bind(new_relation), @alias, self)
end
- def to_attribute
+ def to_attribute(relation)
Attribute.new(relation, @alias, :ancestor => self)
end
end
diff --git a/lib/arel/algebra/relations/relation.rb b/lib/arel/algebra/relations/relation.rb
index fe8cab4b02..c38ab0e9c5 100644
--- a/lib/arel/algebra/relations/relation.rb
+++ b/lib/arel/algebra/relations/relation.rb
@@ -31,7 +31,7 @@ module Arel
def join(other_relation = nil, join_class = InnerJoin)
case other_relation
when String
- StringJoin.new(other_relation, self)
+ StringJoin.new(self, other_relation)
when Relation
JoinOperation.new(join_class, self, other_relation)
else
@@ -85,7 +85,8 @@ module Arel
find_attribute_matching_name(index)
when Attribute, Expression
find_attribute_matching_attribute(index)
- when Array
+ when ::Array
+ # TESTME
index.collect { |i| self[i] }
end
end
@@ -100,6 +101,12 @@ module Arel
end
end
+ def position_of(attribute)
+ (@position_of ||= Hash.new do |h, attribute|
+ h[attribute] = attributes.index(self[attribute])
+ end)[attribute]
+ end
+
private
def matching_attributes(attribute)
(@matching_attributes ||= attributes.inject({}) do |hash, a|
diff --git a/lib/arel/algebra/relations/utilities/externalization.rb b/lib/arel/algebra/relations/utilities/externalization.rb
index bd067f2304..13758ccec9 100644
--- a/lib/arel/algebra/relations/utilities/externalization.rb
+++ b/lib/arel/algebra/relations/utilities/externalization.rb
@@ -8,7 +8,7 @@ module Arel
end
def attributes
- @attributes ||= relation.attributes.collect(&:to_attribute).collect { |a| a.bind(self) }
+ @attributes ||= relation.attributes.collect { |a| a.to_attribute(self) }
end
end
diff --git a/lib/arel/engines/memory/relations.rb b/lib/arel/engines/memory/relations.rb
index 820b0af4b2..1b009537b9 100644
--- a/lib/arel/engines/memory/relations.rb
+++ b/lib/arel/engines/memory/relations.rb
@@ -1,4 +1,3 @@
-require 'arel/engines/memory/relations/relation'
require 'arel/engines/memory/relations/array'
require 'arel/engines/memory/relations/operations'
require 'arel/engines/memory/relations/compound'
diff --git a/lib/arel/engines/memory/relations/array.rb b/lib/arel/engines/memory/relations/array.rb
index ea0b5af5ba..15a3e95e1b 100644
--- a/lib/arel/engines/memory/relations/array.rb
+++ b/lib/arel/engines/memory/relations/array.rb
@@ -1,8 +1,8 @@
module Arel
class Array < Relation
attributes :array, :attribute_names
- deriving :initialize
include Recursion::BaseCase
+ deriving :==, :initialize
def engine
@engine ||= Memory::Engine.new
@@ -10,7 +10,7 @@ module Arel
def attributes
@attributes ||= @attribute_names.collect do |name|
- Attribute.new(self, name.to_sym)
+ name.to_attribute(self)
end
end
diff --git a/lib/arel/engines/memory/relations/relation.rb b/lib/arel/engines/memory/relations/relation.rb
deleted file mode 100644
index abfb8bb37f..0000000000
--- a/lib/arel/engines/memory/relations/relation.rb
+++ /dev/null
@@ -1,7 +0,0 @@
-module Arel
- class Relation
- def position_of(attribute)
- attributes.index(self[attribute])
- end
- end
-end \ No newline at end of file
diff --git a/lib/arel/engines/sql/engine.rb b/lib/arel/engines/sql/engine.rb
index e5d1a8b0ca..0700ae9733 100644
--- a/lib/arel/engines/sql/engine.rb
+++ b/lib/arel/engines/sql/engine.rb
@@ -19,12 +19,12 @@ module Arel
end
def read(relation)
- results = connection.execute(relation.to_sql)
- rows = []
- results.each do |row|
- rows << attributes.zip(row).to_hash
+ # FIXME
+ class << rows = connection.execute(relation.to_sql)
+ include Enumerable
end
- rows
+
+ Array.new(rows, relation.attributes)
end
def update(relation)
diff --git a/lib/arel/engines/sql/relations/operations/join.rb b/lib/arel/engines/sql/relations/operations/join.rb
index 2f5e23644e..f848fd3268 100644
--- a/lib/arel/engines/sql/relations/operations/join.rb
+++ b/lib/arel/engines/sql/relations/operations/join.rb
@@ -22,7 +22,7 @@ module Arel
end
class OuterJoin < Join
- def join_sql; "OUTER JOIN" end
+ def join_sql; "LEFT OUTER JOIN" end
end
class StringJoin < Join