- 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
+
+ # Get results
+ get_rowid = make_get_rowid()
+ get_row_value = make_get_row_value()
+ if offset:
+ table_rows = table_rows[offset:]
+ count = 0
+ for table_row in table_rows:
+ count += 1
+ if limit is not None and count > limit:
+ break
+ if truncate and max_returned_rows and count > max_returned_rows:
+ truncated = True
+ break
+ row = {}
+ for field in fields:
+ field_name = field
+ if isinstance(field, dict):
+ field_name = field['value']
+ if isinstance(field_name, 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))
+ elif isinstance(field_name, dict):
+ if field_name.get('count') == '*':
+ row['count(*)'] = int(table.nrows)
+ elif field_name.get('json_type'):
+ field_name = field_name.get('json_type')
+ row['json_type(' + field_name + ')'] = _get_field_type(field_name)
+ else:
+ raise Exception("Function not recognized")
+ else:
+ row[field_name] = normalize_field_value(get_row_value(table_row, field_name))
+ results.append(row)