Add Match Command (#18)

Co-authored-by: Joel Lee <[email protected]>

Author: J0

postgrest_py/request_builder.py

@@ -1,4 +1,4 @@
-from typing import Iterable, Tuple
+from typing import Any, Iterable, Tuple, Dict, Optional
 
 from deprecation import deprecated
 from httpx import AsyncClient
@@ -13,7 +13,8 @@ def __init__(self, session: AsyncClient, path: str):
         self.path = path
 
     def select(self, *columns: str):
-        self.session.params = self.session.params.set("select", ",".join(columns))
+        self.session.params = self.session.params.set(
+            "select", ",".join(columns))
         return SelectRequestBuilder(self.session, self.path, "GET", {})
 
     def insert(self, json: dict, *, upsert=False):
@@ -136,6 +137,13 @@ def nxr(self, column: str, range: Tuple[int, int]):
     def adj(self, column: str, range: Tuple[int, int]):
         return self.filter(column, "adj", f"({range[0]},{range[1]})")
 
+    def match(self, query: Dict[str, Any]):
+        updated_query = None
+        for key in query.keys():
+            value = query.get(key, '')
+            updated_query = self.eq(key, value)
+        return updated_query
+
 
 class SelectRequestBuilder(FilterRequestBuilder):
     def __init__(self, session: AsyncClient, path: str, http_method: str, json: dict):

tests/test_filter_request_builder.py

@@ -34,3 +34,8 @@ def test_multivalued_param(filter_request_builder):
     builder = filter_request_builder.lte("x", "a").gte("x", "b")
 
     assert str(builder.session.params) == "x=lte.a&x=gte.b"
+
+
+def test_match(filter_request_builder):
+    builder = filter_request_builder.match({'id': '1', 'done': 'false'})
+    assert str(builder.session.params) == 'id=eq.1&done=eq.false'