Skip to content
This repository was archived by the owner on Sep 8, 2025. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 10 additions & 3 deletions postgrest/base_request_builder.py
Original file line number Diff line number Diff line change
Expand Up @@ -565,7 +565,14 @@ def offset(self: _FilterT, size: int) -> _FilterT:
)
return self

def range(self: Self, start: int, end: int) -> Self:
self.headers["Range-Unit"] = "items"
self.headers["Range"] = f"{start}-{end - 1}"
def range(
self: Self, start: int, end: int, foreign_table: Optional[str] = None
) -> Self:
self.params = self.params.add(
f"{foreign_table}.offset" if foreign_table else "offset", start
)
self.params = self.params.add(
f"{foreign_table}.limit" if foreign_table else "limit",
end - start + 1,
)
return self
15 changes: 15 additions & 0 deletions tests/_async/test_request_builder.py
Original file line number Diff line number Diff line change
Expand Up @@ -152,6 +152,21 @@ def test_explain_options(self, request_builder: AsyncRequestBuilder):
)


class TestRange:
def test_range_on_own_table(self, request_builder: AsyncRequestBuilder):
builder = request_builder.select("*").range(0, 1)
assert builder.params["select"] == "*"
assert builder.params["limit"] == "2"
assert builder.params["offset"] == "0"

def test_range_on_foreign_table(self, request_builder: AsyncRequestBuilder):
foreign_table = "cities"
builder = request_builder.select("*").range(1, 2, foreign_table)
assert builder.params["select"] == "*"
assert builder.params[f"{foreign_table}.limit"] == "2"
assert builder.params[f"{foreign_table}.offset"] == "1"


@pytest.fixture
def csv_api_response() -> str:
return "id,name\n1,foo\n"
Expand Down
15 changes: 15 additions & 0 deletions tests/_sync/test_request_builder.py
Original file line number Diff line number Diff line change
Expand Up @@ -152,6 +152,21 @@ def test_explain_options(self, request_builder: SyncRequestBuilder):
)


class TestRange:
def test_range_on_own_table(self, request_builder: SyncRequestBuilder):
builder = request_builder.select("*").range(0, 1)
assert builder.params["select"] == "*"
assert builder.params["limit"] == "2"
assert builder.params["offset"] == "0"

def test_range_on_foreign_table(self, request_builder: SyncRequestBuilder):
foreign_table = "cities"
builder = request_builder.select("*").range(1, 2, foreign_table)
assert builder.params["select"] == "*"
assert builder.params[f"{foreign_table}.limit"] == "2"
assert builder.params[f"{foreign_table}.offset"] == "1"


@pytest.fixture
def csv_api_response() -> str:
return "id,name\n1,foo\n"
Expand Down