300 |
interface. |
interface. |
301 |
""" |
""" |
302 |
TransientTableBase.__init__(self, transient_db) |
TransientTableBase.__init__(self, transient_db) |
303 |
|
self.title = table.Title() |
304 |
self.create(table) |
self.create(table) |
305 |
|
|
306 |
|
def Title(self): |
307 |
|
"""Return the title of the table. |
308 |
|
|
309 |
|
The title is the same as that of the original table |
310 |
|
""" |
311 |
|
return self.title |
312 |
|
|
313 |
def create(self, table): |
def create(self, table): |
314 |
columns = [] |
columns = [] |
315 |
for col in table.Columns(): |
for col in table.Columns(): |
346 |
"""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""" |
347 |
|
|
348 |
def __init__(self, transient_db, left_table, left_field, |
def __init__(self, transient_db, left_table, left_field, |
349 |
right_table, right_field = None): |
right_table, right_field = None, outer_join = False): |
350 |
"""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. |
351 |
|
|
352 |
Both input tables, left_table and right_table must have a |
Both input tables, left_table and right_table must have a |
353 |
transient_table method that returns a table object for a table |
transient_table method that returns a table object for a table |
354 |
in the trnsient database. The join is performed on the condition |
in the transient database. The join is performed on the condition |
355 |
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 |
356 |
equal to the value of the right_field in the right_table. |
equal to the value of the right_field in the right_table. |
357 |
|
|
371 |
self.right_field = right_field |
self.right_field = right_field |
372 |
else: |
else: |
373 |
self.right_field = self.left_field |
self.right_field = self.left_field |
374 |
|
self.outer_join = outer_join |
375 |
self.create() |
self.create() |
376 |
|
|
377 |
|
def Title(self): |
378 |
|
"""Return the title of the joined table""" |
379 |
|
return "Join of %(left)s and %(right)s" \ |
380 |
|
% {"left": self.left_table.Title(), |
381 |
|
"right": self.right_table.Title()} |
382 |
|
|
383 |
def create(self): |
def create(self): |
384 |
"""Internal: Create the table with the joined data""" |
"""Internal: Create the table with the joined data""" |
385 |
self.tablename = self.db.new_table_name() |
self.tablename = self.db.new_table_name() |
400 |
|
|
401 |
# Copy the joined data to the table. |
# Copy the joined data to the table. |
402 |
internal_names = [col.internal_name for col in self.columns] |
internal_names = [col.internal_name for col in self.columns] |
403 |
|
if self.outer_join: |
404 |
|
join_operator = 'LEFT OUTER JOIN' |
405 |
|
else: |
406 |
|
join_operator = 'JOIN' |
407 |
stmt = ("INSERT INTO %s (id, %s) SELECT %s.id, %s FROM %s" |
stmt = ("INSERT INTO %s (id, %s) SELECT %s.id, %s FROM %s" |
408 |
" JOIN %s ON %s = %s;" |
" %s %s ON %s = %s;" |
409 |
% (self.tablename, |
% (self.tablename, |
410 |
", ".join(internal_names), |
", ".join(internal_names), |
411 |
self.left_table.tablename, |
self.left_table.tablename, |
412 |
", ".join(internal_names), |
", ".join(internal_names), |
413 |
self.left_table.tablename, |
self.left_table.tablename, |
414 |
|
join_operator, |
415 |
self.right_table.tablename, |
self.right_table.tablename, |
416 |
self.orig_to_internal[self.left_field], |
self.orig_to_internal[self.left_field], |
417 |
self.orig_to_internal[self.right_field])) |
self.orig_to_internal[self.right_field])) |
435 |
self.table = table |
self.table = table |
436 |
self.t_table = None |
self.t_table = None |
437 |
|
|
438 |
|
def Title(self): |
439 |
|
"""Return the title of the table. |
440 |
|
|
441 |
|
The title is the same as that of the original table. |
442 |
|
""" |
443 |
|
return self.table.Title() |
444 |
|
|
445 |
def Columns(self): |
def Columns(self): |
446 |
return self.table.Columns() |
return self.table.Columns() |
447 |
|
|