added raw and text

Author: wilsonfreitas

bcb/odata/api.py

@@ -44,11 +44,12 @@ class EndpointQuery(ODataQuery):
     def collect(self):
         raw_data = super().collect()
         data = pd.DataFrame(raw_data["value"])
-        for col in self._DATE_COLUMN_NAMES:
-            if self.entity.name in self._DATE_COLUMN_NAMES_BY_ENDPOINT and col in self._DATE_COLUMN_NAMES_BY_ENDPOINT[self.entity.name]:
-                data[col] = pd.to_datetime(data[col], format=self._DATE_COLUMN_NAMES_BY_ENDPOINT[self.entity.name][col])
-            elif col in data.columns:
-                data[col] = pd.to_datetime(data[col])
+        if not self._raw:
+            for col in self._DATE_COLUMN_NAMES:
+                if self.entity.name in self._DATE_COLUMN_NAMES_BY_ENDPOINT and col in self._DATE_COLUMN_NAMES_BY_ENDPOINT[self.entity.name]:
+                    data[col] = pd.to_datetime(data[col], format=self._DATE_COLUMN_NAMES_BY_ENDPOINT[self.entity.name][col])
+                elif col in data.columns:
+                    data[col] = pd.to_datetime(data[col])
         return data
 
 

bcb/odata/framework.py

@@ -155,6 +155,9 @@ def __init__(self, obj, order):
     def __str__(self):
         return f"{self.obj.name} {self.order}"
 
+    def __repr__(self):
+        return f"<{str(self)}>"
+
 
 class ODataPropertyFilter:
     def __init__(self, obj, oth, operator):
@@ -177,6 +180,9 @@ def statement(self):
     def __str__(self):
         return self.statement()
 
+    def __repr__(self):
+        return f"<filter: {str(self)}>"
+
 
 class ODataProperty:
     def __init__(self, **kwargs):
@@ -216,7 +222,7 @@ def __eq__(self, other):
         return ODataPropertyFilter(self, other, "eq")
 
     def __repr__(self):
-        return f"<Property {self.name}>"
+        return f"<Property {self.name}<{self.ftype}>>"
 
 
 class ODataFunction:
@@ -396,6 +402,7 @@ def __init__(self, entity, url):
         self._filter = []
         self._select = []
         self._orderby = []
+        self._raw = False
         self.is_function = isinstance(entity, ODataFunctionImport)
         if self.is_function:
             self.function_parameters = {
@@ -450,8 +457,12 @@ def select(self, *args):
             self._select.extend(args)
         return self
 
+    def raw(self):
+        self._raw = True
+        return self
+
     def _build_parameters(self):
-        params = {"$format": "json"}
+        params = {"$format": self._params.get("$format", "json")}
         if len(self._filter):
             _filter = " and ".join(str(f) for f in self._filter)
             params["$filter"] = _filter
@@ -470,6 +481,9 @@ def reset(self):
         self._params = {}
 
     def collect(self):
+        return json.loads(self.text())
+
+    def text(self):
         params = self._build_parameters()
         if self.is_function and len(self.function_parameters):
             for p in self.entity.function.parameters:
@@ -480,8 +494,7 @@ def collect(self):
         qs = "&".join([f"{quote(k)}={quote(str(v))}" for k, v in params.items()])
         headers = {"OData-Version": "4.0", "OData-MaxVersion": "4.0"}
         res = httpx.get(self.odata_url() + "?" + qs, headers=headers, timeout=60.0)
-        logging.debug(res.text)
-        return json.loads(res.text)
+        return res.text
 
     def show(self):
         print(f"URL:")