From: Mike Bayer <mike_mp@zzzcomputing.com>
Date: Sun, 16 Nov 2008 19:33:26 +0000 (+0000)
Subject: - Query.select_from(), from_statement() ensure
X-Git-Tag: rel_0_5_0~168
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=e1268d4f57ad19d7d38e4f4130e72f44f91fe964;p=thirdparty%2Fsqlalchemy%2Fsqlalchemy.git

- Query.select_from(), from_statement() ensure
that the given argument is a FromClause,
or Text/Select/Union, respectively.

- Query.add_column() can accept FromClause objects
in the same manner as session.query() can.
---

diff --git a/CHANGES b/CHANGES
index fa95094db8..6d26b26884 100644
--- a/CHANGES
+++ b/CHANGES
@@ -6,7 +6,15 @@ CHANGES
 =======
 0.5.0rc5
 ========
-- bugfixes
+- bugfixes, behavioral changes
+- orm
+    - Query.select_from(), from_statement() ensure
+      that the given argument is a FromClause,
+      or Text/Select/Union, respectively.
+
+    - Query.add_column() can accept FromClause objects
+      in the same manner as session.query() can.
+      
 - postgres
     - Calling alias.execute() in conjunction with
       server_side_cursors won't raise AttributeError.
diff --git a/lib/sqlalchemy/orm/query.py b/lib/sqlalchemy/orm/query.py
index 82a698fd07..d888763128 100644
--- a/lib/sqlalchemy/orm/query.py
+++ b/lib/sqlalchemy/orm/query.py
@@ -562,8 +562,11 @@ class Query(object):
         """Add a SQL ColumnElement to the list of result columns to be returned."""
 
         self._entities = list(self._entities)
-        c = _ColumnEntity(self, column)
-        self.__setup_aliasizers([c])
+        l = len(self._entities)
+        _ColumnEntity(self, column)
+        # _ColumnEntity may add many entities if the
+        # given arg is a FROM clause
+        self.__setup_aliasizers(self._entities[l:])
 
     def options(self, *args):
         """Return a new Query object, applying the given list of
@@ -930,6 +933,8 @@ class Query(object):
         if isinstance(from_obj, (tuple, list)):
             util.warn_deprecated("select_from() now accepts a single Selectable as its argument, which replaces any existing FROM criterion.")
             from_obj = from_obj[-1]
+        if not isinstance(from_obj, expression.FromClause):
+            raise sa_exc.ArgumentError("select_from() accepts FromClause objects only.")
         self.__set_select_from(from_obj)
 
     def __getitem__(self, item):
@@ -1013,6 +1018,10 @@ class Query(object):
         """
         if isinstance(statement, basestring):
             statement = sql.text(statement)
+
+        if not isinstance(statement, (expression._TextClause, expression._SelectBaseMixin)):
+            raise sa_exc.ArgumentError("from_statement accepts text(), select(), and union() objects only.")
+        
         self._statement = statement
 
     def first(self):
diff --git a/test/orm/query.py b/test/orm/query.py
index 4121ac0e19..34372b83ab 100644
--- a/test/orm/query.py
+++ b/test/orm/query.py
@@ -236,6 +236,23 @@ class InvalidGenerationsTest(QueryTest):
         # this is fine, however
         q.from_self()
     
+    def test_invalid_select_from(self):
+        s = create_session()
+        q = s.query(User)
+        self.assertRaises(sa_exc.ArgumentError, q.select_from, User.id==5)
+        self.assertRaises(sa_exc.ArgumentError, q.select_from, User.id)
+
+    def test_invalid_from_statement(self):
+        s = create_session()
+        q = s.query(User)
+        self.assertRaises(sa_exc.ArgumentError, q.from_statement, User.id==5)
+        self.assertRaises(sa_exc.ArgumentError, q.from_statement, users.join(addresses))
+    
+    def test_invalid_column(self):
+        s = create_session()
+        q = s.query(User)
+        self.assertRaises(sa_exc.InvalidRequestError, q.add_column, object())
+        
     def test_mapper_zero(self):
         s = create_session()
         
@@ -1783,6 +1800,16 @@ class MixedEntitiesTest(QueryTest):
 
         self.assertRaises(sa_exc.InvalidRequestError, sess.query(User).add_column, object())
     
+    def test_add_multi_columns(self):
+        """test that add_column accepts a FROM clause."""
+        
+        sess = create_session()
+        
+        eq_(
+            sess.query(User.id).add_column(users).all(),
+            [(7, 7, u'jack'), (8, 8, u'ed'), (9, 9, u'fred'), (10, 10, u'chuck')]
+        )
+        
     def test_multi_columns_2(self):
         """test aliased/nonalised joins with the usage of add_column()"""
         sess = create_session()