added select_txt and select_distinct function to main pipestat class

pipestat/backends/abstract.py

@@ -148,3 +148,11 @@ def remove_record(
     def select(self):
         _LOGGER.warning("Not implemented yet for this backend")
         pass
+
+    def select_txt(self):
+        _LOGGER.warning("Not implemented yet for this backend")
+        pass
+
+    def select_distinct(self):
+        _LOGGER.warning("Not implemented yet for this backend")
+        pass

pipestat/pipestat.py

@@ -484,6 +484,44 @@ def select(self, **kwargs):
 
         return result
 
+    @require_backend
+    def select_txt(self, **kwargs):
+        """
+        Execute a query with a textual filter. Returns all results.
+
+        To retrieve all table contents, leave the filter arguments out.
+        Table name uses pipeline_type
+
+        :param str filter_templ: filter template with value placeholders,
+             formatted as follows `id<:value and name=:name`
+        :param Dict[str, Any] filter_params: a mapping keys specified in the `filter_templ`
+            to parameters that are supposed to replace the placeholders
+        :param str table_name: name of the table to query
+        :param int offset: skip this number of rows
+        :param int limit: include this number of rows
+        :param str pipeline_type: sample vs project pipeline
+        :return List[Any]: a list of matched records
+        """
+        # Note this is only implemented for DBBackend
+        result = self.backend.select_txt(**kwargs)
+
+        return result
+
+    @require_backend
+    def select_distinct(self, **kwargs):
+        """
+        Perform a `SELECT DISTINCT` on given table and column
+
+        :param str table_name: name of the table to SELECT from
+        :param List[str] columns: columns to include in the result
+        :param str pipeline_type: "sample" or "project"
+        :return List[Any]: returns distinct values.
+        """
+        # Note this is only implemented for DBBackend
+        results = self.backend.select_distinct(**kwargs)
+
+        return results
+
     @require_backend
     def set_status(
         self,

tests/test_db_only_mode.py

@@ -284,5 +284,5 @@ def test_select_txt(
             psm.report(values=val, force_overwrite=True)
             val_name = list(val.keys())[0]
             # assert psm.backend.select(filter_conditions=[(val_name, "eq", val[val_name])])[0]
-            assert val_name in str(psm.backend.select_txt())
-            assert val_name not in str(psm.backend.select_txt(offset=2))
+            assert val_name in str(psm.select_txt())
+            assert val_name not in str(psm.select_txt(offset=2))

tests/test_pipestat.py

@@ -466,7 +466,7 @@ def test_remove_basic(
             else:
                 col_name = list(vals[0].keys())[0]
                 value = list(vals[0].values())[0]
-                result = psm.backend.select(filter_conditions=[(col_name, "eq", value)])
+                result = psm.select(filter_conditions=[(col_name, "eq", value)])
                 assert len(result) == 0
 
     @pytest.mark.parametrize("rec_id", ["sample1", "sample2"])
@@ -496,7 +496,7 @@ def test_remove_record(
             else:
                 col_name = list(vals[0].keys())[0]
                 value = list(vals[0].values())[0]
-                result = psm.backend.select(filter_conditions=[(col_name, "eq", value)])
+                result = psm.select(filter_conditions=[(col_name, "eq", value)])
                 assert len(result) == 0
 
     @pytest.mark.parametrize(
@@ -615,7 +615,7 @@ def test_report(
                 )
             if backend == "db":
                 val_name = list(val.keys())[0]
-                assert psm.backend.select(filter_conditions=[(val_name, "eq", val[val_name])])
+                assert psm.select(filter_conditions=[(val_name, "eq", val[val_name])])
 
     @pytest.mark.parametrize(
         "val",