if 'limit' in parsed_sql:
limit = int(parsed_sql['limit'])
+ # Offset
+ offset = None
+ if 'offset' in parsed_sql:
+ offset = int(parsed_sql['offset'])
+
# Truncate if needed
if page_size and max_returned_rows and truncate:
if max_returned_rows == page_size:
# 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
fetched.extend(response.json['rows'])
path = response.json['next_url']
if path:
+ path = path.replace('http://localhost', '')
assert response.json['next']
assert '_next={}'.format(response.json['next']) in path