[SQL-CVS] r2340 - SQLObject/branches/sqlbuilder-views/sqlobject

[<sub...@co...>]

Author: luke
Date: 2007-02-21 14:39:09 -0700 (Wed, 21 Feb 2007)
New Revision: 2340

Modified:
   SQLObject/branches/sqlbuilder-views/sqlobject/sresults.py
Log:
SelectResults.throughTo use select's connection

Modified: SQLObject/branches/sqlbuilder-views/sqlobject/sresults.py
===================================================================
--- SQLObject/branches/sqlbuilder-views/sqlobject/sresults.py	2007-02-21 21:26:44 UTC (rev 2339)
+++ SQLObject/branches/sqlbuilder-views/sqlobject/sresults.py	2007-02-21 21:39:09 UTC (rev 2340)
@@ -304,7 +304,8 @@
         otherClass = getattr(self.sourceClass, "_SO_class_"+col.foreignKey)
         query = sqlbuilder.Alias(self.queryForSelect(), "%s_%s" % (self.sourceClass.__name__, col.name))
         return otherClass.select(otherClass.q.id==getattr(query.q, getattr(self.sourceClass.q, col.name).fieldName),
-                                distinct=True)
+                                distinct=True,
+                                connection=self._getConnection())
         
     def _throughToMultipleJoin(self, join):
         otherClass = join.otherClass
@@ -313,7 +314,8 @@
         joinColumn = getattr(otherClass.q, join.soClass.sqlmeta.style.dbColumnToPythonAttr(join.joinColumn))
         return otherClass.select(joinColumn == getattr(query.q, self.sourceClass.q.id.fieldName),
                                 distinct=True,
-                                orderBy=join.orderBy)
+                                orderBy=join.orderBy,
+                                connection=self._getConnection())
     
     def _throughToRelatedJoin(self, join):
         otherClass = join.otherClass
@@ -326,7 +328,8 @@
                      getattr(intTable, join.joinColumn) == getattr(query.q, join.joinColumn))
         ret = otherClass.select(clause,
                                 distinct=True,
-                                orderBy=join.orderBy)
+                                orderBy=join.orderBy,
+                                connection=self._getConnection())
         print ret
         return ret