- for field in fields:
- field_name = field['value']
- if type(field_name) is dict and 'distinct' in field_name:
- field_name = field_name['distinct']
- if field_name == 'rowid':
- row['rowid'] = rowid
- else:
- value = table_row
- if type(value) is bytes:
- value = value.decode('utf-8')
- row['value'] = value
- rows.append(row)
+ return rowid
+ return get_rowid
+
+ def make_get_row_value():
+ if type(table) is tables.table.Table:
+ def get_row_value(row, field):
+ return row[field]
+ else:
+ def get_row_value(row, field):
+ return row
+ return get_row_value
+
+ if len(fields) == 1 and type(fields[0]['value']) is dict and \
+ fields[0]['value'].get('count') == '*':
+ rows.append(Row({'count(*)': int(table.nrows)}))
+ else:
+ get_rowid = make_get_rowid()
+ get_row_value = make_get_row_value()
+ count = 0
+ for table_row in table_rows:
+ count += 1
+ if limit and count > limit:
+ break
+ if truncate and max_returned_rows and count > max_returned_rows:
+ truncated = True
+ break
+ row = Row()
+ for field in fields:
+ field_name = field['value']
+ if type(field_name) is dict and 'distinct' in field_name:
+ field_name = field_name['distinct']
+ if field_name == 'rowid':
+ row['rowid'] = get_rowid(table_row)
+ elif field_name == '*':
+ for col in colnames:
+ row[col] = normalize_field_value(get_row_value(table_row, col))
+ else:
+ row[field_name] = normalize_field_value(get_row_value(table_row, field_name))
+ rows.append(row)