[SQL-CVS] r1948 - SQLObject/trunk/sqlobject

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

Author: phd
Date: 2006-09-26 06:08:10 -0600 (Tue, 26 Sep 2006)
New Revision: 1948

Modified:
   SQLObject/trunk/sqlobject/dbconnection.py
   SQLObject/trunk/sqlobject/main.py
Log:
A patch by David Faure <df...@kl...> implementing
SELECT FOR UPDATE.


Modified: SQLObject/trunk/sqlobject/dbconnection.py
===================================================================
--- SQLObject/trunk/sqlobject/dbconnection.py	2006-09-25 20:18:44 UTC (rev 1947)
+++ SQLObject/trunk/sqlobject/dbconnection.py	2006-09-26 12:08:10 UTC (rev 1948)
@@ -505,6 +505,9 @@
 
         q = startSelect + ' ' + q
 
+        if ops.get('forUpdate'):
+            q += " FOR UPDATE";
+
         if limit and (start or end):
             # @@: Raising an error might be an annoyance, but some warning is
             # in order.

Modified: SQLObject/trunk/sqlobject/main.py
===================================================================
--- SQLObject/trunk/sqlobject/main.py	2006-09-25 20:18:44 UTC (rev 1947)
+++ SQLObject/trunk/sqlobject/main.py	2006-09-26 12:08:10 UTC (rev 1948)
@@ -1319,7 +1319,7 @@
                orderBy=NoDefault, limit=None,
                lazyColumns=False, reversed=False,
                distinct=False, connection=None,
-               join=None):
+               join=None, forUpdate=False):
         return cls.SelectResultsClass(cls, clause,
                              clauseTables=clauseTables,
                              orderBy=orderBy,
@@ -1328,7 +1328,7 @@
                              reversed=reversed,
                              distinct=distinct,
                              connection=connection,
-                             join=join)
+                             join=join, forUpdate=forUpdate)
     select = classmethod(select)
 
     def selectBy(cls, connection=None, **kw):