/[thuban]/branches/WIP-pyshapelib-bramz/Thuban/Model/transientdb.py

Diff of /branches/WIP-pyshapelib-bramz/Thuban/Model/transientdb.py

Parent Directory | Revision Log | View Patch Patch

-revision 849 by bh,
Wed May  7 11:55:31 2003 UTC
+revision 1009 by frank,
Fri May 23 08:26:58 2003 UTC
 Line 280 
 class TransientTableBase(table.OldTableI
              result.append(row[0])
          return result
+     def Dependencies(self):
+         """Placeholder for a method in a derived class.
+         Return a sequence with the tables and other data objects that
+         self depends on.
+         """
+         raise NotImplementedError
  class TransientTable(TransientTableBase):
-Line 292 
 class TransientTable(TransientTableBase)
+Line 300 
 class TransientTable(TransientTableBase)
          interface.
          """
          TransientTableBase.__init__(self, transient_db)
+         self.title = table.Title()
          self.create(table)
+     def Title(self):
+         """Return the title of the table.
+         The title is the same as that of the original table
+         """
+         return self.title
      def create(self, table):
          columns = []
          for col in table.Columns():
-Line 330 
 class TransientJoinedTable(TransientTabl
+Line 346 
 class TransientJoinedTable(TransientTabl
      """A Table in the transient DB that contains a join of two tables"""
      def __init__(self, transient_db, left_table, left_field,
-                  right_table, right_field = None):
+                  right_table, right_field = None, outer_join = False):
          """Create a new table in the transient DB as a join of two tables.
          Both input tables, left_table and right_table must have a
          transient_table method that returns a table object for a table
-         in the trnsient database. The join is performed on the condition
+         in the transient database. The join is performed on the condition
          that the value of the left_field column the the left table is
          equal to the value of the right_field in the right_table.
-Line 347 
 class TransientJoinedTable(TransientTabl
+Line 363 
 class TransientJoinedTable(TransientTabl
          names of the input tables without having to create prefixes.
          """
          TransientTableBase.__init__(self, transient_db)
+         self.dependencies = (left_table, right_table)
          self.left_table = left_table.transient_table()
          self.left_field = left_field
          self.right_table = right_table.transient_table()
-Line 354 
 class TransientJoinedTable(TransientTabl
+Line 371 
 class TransientJoinedTable(TransientTabl
              self.right_field = right_field
          else:
              self.right_field = self.left_field
+         self.outer_join = outer_join
          self.create()
+     def Title(self):
+         """Return the title of the joined table"""
+         return "Join of %(left)s and %(right)s" \
+                % {"left": self.left_table.Title(),
+                   "right": self.right_table.Title()}
      def create(self):
          """Internal: Create the table with the joined data"""
          self.tablename = self.db.new_table_name()
-Line 376 
 class TransientJoinedTable(TransientTabl
+Line 400 
 class TransientJoinedTable(TransientTabl
          # Copy the joined data to the table.
          internal_names = [col.internal_name for col in self.columns]
+         if self.outer_join:
+             join_operator = 'LEFT OUTER JOIN'
+         else:
+             join_operator = 'JOIN'
          stmt = ("INSERT INTO %s (id, %s) SELECT %s.id, %s FROM %s"
-                 " JOIN %s ON %s = %s;"
+                 " %s %s ON %s = %s;"
                  % (self.tablename,
                     ", ".join(internal_names),
                     self.left_table.tablename,
                     ", ".join(internal_names),
                     self.left_table.tablename,
+                    join_operator,
                     self.right_table.tablename,
                     self.orig_to_internal[self.left_field],
                     self.orig_to_internal[self.right_field]))
          self.db.execute(stmt)
+     def Dependencies(self):
+         """Return a tuple with the two tables the join depends on."""
+         return self.dependencies
  class AutoTransientTable(table.OldTableInterfaceMixin):
-Line 402 
 class AutoTransientTable(table.OldTableI
+Line 435 
 class AutoTransientTable(table.OldTableI
          self.table = table
          self.t_table = None
+     def Title(self):
+         """Return the title of the table.
+         The title is the same as that of the original table.
+         """
+         return self.table.Title()
      def Columns(self):
          return self.table.Columns()
-Line 465 
 class AutoTransientTable(table.OldTableI
+Line 505 
 class AutoTransientTable(table.OldTableI
          # Make sure to use the column object of the transient table. The
          # left argument is always a column object so we can just ask the
          # t_table for the right object.
-         return self.t_table.SimpleQuery(self.t_table.Column(left.name),
+         if hasattr(right, "name"):
-                                         comparison, right)
+             return self.t_table.SimpleQuery(self.t_table.Column(left.name),
+                                             comparison,
+                                             self.t_table.Column(right.name))
+         else:
+             return self.t_table.SimpleQuery(self.t_table.Column(left.name),
+                                             comparison, right)
+     def Dependencies(self):
+         """Return a tuple containing the original table"""
+         return (self.table,)

 Legend:



Removed from v.849
 


changed lines


 
Added in v.1009
 Legend:



Removed from v.849
 


changed lines


 
Added in v.1009
-Removed from v.849
+Added in v.1009

[email protected]	ViewVC Help
Powered by ViewVC 1.1.26