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

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

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 984 by bh, Thu May 22 16:37:48 2003 UTC revision 1020 by jan, Fri May 23 13:03:07 2003 UTC
# Line 22  import os Line 22  import os
22  import weakref  import weakref
23  from sqlite import connect  from sqlite import connect
24    
25    from base import TitledObject
26    
27  import table  import table
28    
29  sql_type_map = {  sql_type_map = {
# Line 289  class TransientTableBase(table.OldTableI Line 291  class TransientTableBase(table.OldTableI
291          raise NotImplementedError          raise NotImplementedError
292    
293    
294  class TransientTable(TransientTableBase):  class TransientTable(TitledObject, TransientTableBase):
295    
296      """A Table in a transient DB that starts as the copy of a Thuban Table."""      """A Table in a transient DB that starts as the copy of a Thuban Table."""
297    
# Line 300  class TransientTable(TransientTableBase) Line 302  class TransientTable(TransientTableBase)
302          interface.          interface.
303          """          """
304          TransientTableBase.__init__(self, transient_db)          TransientTableBase.__init__(self, transient_db)
305            TitledObject.__init__(self, table.Title())
306          self.create(table)          self.create(table)
307    
308      def create(self, table):      def create(self, table):
# Line 333  class TransientTable(TransientTableBase) Line 336  class TransientTable(TransientTableBase)
336    
337    
338    
339  class TransientJoinedTable(TransientTableBase):  class TransientJoinedTable(TitledObject, TransientTableBase):
340    
341      """A Table in the transient DB that contains a join of two tables"""      """A Table in the transient DB that contains a join of two tables"""
342    
343      def __init__(self, transient_db, left_table, left_field,      def __init__(self, transient_db, left_table, left_field,
344                   right_table, right_field = None):                   right_table, right_field = None, outer_join = False):
345          """Create a new table in the transient DB as a join of two tables.          """Create a new table in the transient DB as a join of two tables.
346    
347          Both input tables, left_table and right_table must have a          Both input tables, left_table and right_table must have a
348          transient_table method that returns a table object for a table          transient_table method that returns a table object for a table
349          in the trnsient database. The join is performed on the condition          in the transient database. The join is performed on the condition
350          that the value of the left_field column the the left table is          that the value of the left_field column the the left table is
351          equal to the value of the right_field in the right_table.          equal to the value of the right_field in the right_table.
352    
# Line 363  class TransientJoinedTable(TransientTabl Line 366  class TransientJoinedTable(TransientTabl
366              self.right_field = right_field              self.right_field = right_field
367          else:          else:
368              self.right_field = self.left_field              self.right_field = self.left_field
369            self.outer_join = outer_join
370    
371            title = "Join of %(left)s and %(right)s" \
372                    % {"left": self.left_table.Title(),
373                       "right": self.right_table.Title()}
374            TitledObject.__init__(self, title)
375    
376          self.create()          self.create()
377    
378      def create(self):      def create(self):
# Line 385  class TransientJoinedTable(TransientTabl Line 395  class TransientJoinedTable(TransientTabl
395    
396          # Copy the joined data to the table.          # Copy the joined data to the table.
397          internal_names = [col.internal_name for col in self.columns]          internal_names = [col.internal_name for col in self.columns]
398            if self.outer_join:
399                join_operator = 'LEFT OUTER JOIN'
400            else:
401                join_operator = 'JOIN'
402          stmt = ("INSERT INTO %s (id, %s) SELECT %s.id, %s FROM %s"          stmt = ("INSERT INTO %s (id, %s) SELECT %s.id, %s FROM %s"
403                  " JOIN %s ON %s = %s;"                  " %s %s ON %s = %s;"
404                  % (self.tablename,                  % (self.tablename,
405                     ", ".join(internal_names),                     ", ".join(internal_names),
406                     self.left_table.tablename,                     self.left_table.tablename,
407                     ", ".join(internal_names),                     ", ".join(internal_names),
408                     self.left_table.tablename,                     self.left_table.tablename,
409                       join_operator,
410                     self.right_table.tablename,                     self.right_table.tablename,
411                     self.orig_to_internal[self.left_field],                     self.orig_to_internal[self.left_field],
412                     self.orig_to_internal[self.right_field]))                     self.orig_to_internal[self.right_field]))
# Line 402  class TransientJoinedTable(TransientTabl Line 417  class TransientJoinedTable(TransientTabl
417          return self.dependencies          return self.dependencies
418    
419    
420  class AutoTransientTable(table.OldTableInterfaceMixin):  class AutoTransientTable(TitledObject, table.OldTableInterfaceMixin):
421    
422      """Table that copies data to a transient table on demand.      """Table that copies data to a transient table on demand.
423    
# Line 411  class AutoTransientTable(table.OldTableI Line 426  class AutoTransientTable(table.OldTableI
426      """      """
427    
428      def __init__(self, transient_db, table):      def __init__(self, transient_db, table):
429            TitledObject.__init__(self, table.Title())
430          self.transient_db = transient_db          self.transient_db = transient_db
431          self.table = table          self.table = table
432          self.t_table = None          self.t_table = None
Legend:
Removed from v.984  
changed lines
  Added in v.1020
[email protected]
 ViewVC Help
Powered by ViewVC 1.1.26