245 |
def Width(self, col): |
def Width(self, col): |
246 |
"""Return the maximum width of values in the column |
"""Return the maximum width of values in the column |
247 |
|
|
248 |
The return value is the the maximum length of string representation |
The return value is the the maximum length of string |
249 |
of the values in the column (represented by index or name).""" |
representation of the values in the column (represented by index |
250 |
|
or name). |
251 |
|
""" |
252 |
max = 0 |
max = 0 |
253 |
|
|
254 |
type = self.column_map[col].type |
type = self.column_map[col].type |
255 |
iname = self.column_map[col].internal_name |
iname = self.column_map[col].internal_name |
256 |
cursor = self.db.cursor() |
cursor = self.db.cursor() |
259 |
if not values: |
if not values: |
260 |
return None |
return None |
261 |
|
|
262 |
if type == sql_type_map[table.FIELDTYPE_DOUBLE]: |
if type == table.FIELDTYPE_DOUBLE: |
263 |
format = "%.12f" |
format = "%.12f" |
264 |
elif type == sql_type_map[table.FIELDTYPE_INT]: |
elif type == table.FIELDTYPE_INT: |
265 |
format = "%d" |
format = "%d" |
266 |
else: |
else: |
267 |
format = "%s" |
format = "%s" |
381 |
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 |
382 |
equal to the value of the right_field in the right_table. |
equal to the value of the right_field in the right_table. |
383 |
|
|
384 |
The joined table contains all columns of the input tables with |
The joined table contains all columns of the input tables, |
385 |
one exception: Any column in the right_table with the same name |
however, the column names of the right table may be changed |
386 |
as one of the columns in the left_table will be omitted. This is |
slightly to make them unique in the joined table. This is |
387 |
somewhat of an implementation detail, but is done so that the |
currently done by appending a sufficient number of underscores |
388 |
column names of the joined table can be the same as the column |
('_'). |
|
names of the input tables without having to create prefixes. |
|
389 |
""" |
""" |
390 |
TransientTableBase.__init__(self, transient_db) |
TransientTableBase.__init__(self, transient_db) |
391 |
self.dependencies = (left_table, right_table) |
self.dependencies = (left_table, right_table) |
416 |
# column names are the same they will be mapped to the same |
# column names are the same they will be mapped to the same |
417 |
# internal name afterwards. |
# internal name afterwards. |
418 |
internal_left_col = self.left_table.orig_to_internal[self.left_field] |
internal_left_col = self.left_table.orig_to_internal[self.left_field] |
419 |
internal_right_col = self.right_table.orig_to_internal[self.right_field] |
internal_right_col =self.right_table.orig_to_internal[self.right_field] |
420 |
|
|
421 |
# Coalesce the column information |
# Coalesce the column information |
422 |
visited = {} |
visited = {} |
423 |
columns = [] |
columns = [] |
424 |
newcolumns = [] |
newcolumns = [] |
425 |
for table, col in ( |
for table in (self.left_table, self.right_table): |
426 |
[ (self.left_table.tablename, c) for c in self.left_table.columns ] |
for col in table.Columns(): |
427 |
+ [ (self.right_table.tablename, c) for c in self.right_table.columns]): |
colname = col.name |
428 |
if col.name in visited: |
# We can't allow multiple columns with the same |
429 |
if col.name == self.left_field: |
# original name, so append '_' to this one until |
430 |
continue |
# it is unique. |
431 |
else: |
# FIXME: There should be a better solution. |
432 |
# We can't allow multiple columns with the same original |
while colname in visited: |
433 |
# name, so append '_' to this one until it is unique. |
colname = colname + '_' |
434 |
# FIXME: There should be a better solution. |
columns.append((table.tablename, col)) |
435 |
while col.name in visited: |
newcol = ColumnReference(colname, col.type, |
436 |
col.name = col.name + '_' |
"Col%03d" % (len(newcolumns)+1)) |
437 |
columns.append((table, col)) |
newcolumns.append(newcol) |
438 |
newcol = ColumnReference(col.name, col.type, |
visited[colname] = 1 |
|
"Col%03d" % (len(newcolumns)+1)) |
|
|
newcolumns.append(newcol) |
|
|
visited[col.name] = 1 |
|
439 |
TransientTableBase.create(self, newcolumns) |
TransientTableBase.create(self, newcolumns) |
440 |
|
|
441 |
# Copy the joined data to the table. |
# Copy the joined data to the table. |
465 |
"""Return a tuple with the two tables the join depends on.""" |
"""Return a tuple with the two tables the join depends on.""" |
466 |
return self.dependencies |
return self.dependencies |
467 |
|
|
468 |
|
def JoinType(self): |
469 |
|
"""Return the type of the join (either 'INNER' or 'LEFT OUTER')""" |
470 |
|
if self.outer_join: |
471 |
|
return "LEFT OUTER" |
472 |
|
else: |
473 |
|
return "INNER" |
474 |
|
|
475 |
|
|
476 |
class AutoTransientTable(TitledObject, table.OldTableInterfaceMixin): |
class AutoTransientTable(TitledObject, table.OldTableInterfaceMixin): |
477 |
|
|