From: Rob van der Linde <rob@catalyst.net.nz>
Date: Tue, 7 Nov 2023 23:09:22 +0000 (+1300)
Subject: netcmd: models: add Query class to replace simple generator
X-Git-Tag: talloc-2.4.2~746
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=efedfab33e01c5a422f1ec9dc11bb071298d65b8;p=thirdparty%2Fsamba.git

netcmd: models: add Query class to replace simple generator

This allows other methods to be added on top of the Query class like .first() and .one()

Sometimes it's useful to raise an exception if 0 rows are returned, while other times it's best to return None.
Having a Query class makes it easy to add methods like .one() and .first() to take care of this requirement.

Signed-off-by: Rob van der Linde <rob@catalyst.net.nz>
Reviewed-by: Douglas Bagnall <douglas.bagnall@catalyst.net.nz>
Reviewed-by: Andrew Bartlett <abartlet@samba.org>
---

diff --git a/python/samba/netcmd/domain/models/query.py b/python/samba/netcmd/domain/models/query.py
new file mode 100644
index 00000000000..9cdb65099c1
--- /dev/null
+++ b/python/samba/netcmd/domain/models/query.py
@@ -0,0 +1,81 @@
+# Unix SMB/CIFS implementation.
+#
+# Query class for the ORM to the Ldb database.
+#
+# Copyright (C) Catalyst.Net Ltd. 2023
+#
+# Written by Rob van der Linde <rob@catalyst.net.nz>
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+
+import re
+
+from .exceptions import DoesNotExist, MultipleObjectsReturned
+
+RE_SPLIT_CAMELCASE = re.compile(r"[A-Z](?:[a-z]+|[A-Z]*(?=[A-Z]|$))")
+
+
+class Query:
+    """Simple Query class used by the `Model.query` method."""
+
+    def __init__(self, model, ldb, result):
+        self.model = model
+        self.ldb = ldb
+        self.result = result
+        self.count = result.count
+        self.name = " ".join(RE_SPLIT_CAMELCASE.findall(model.__name__)).lower()
+
+    def __iter__(self):
+        """Loop over Query class yields Model instances."""
+        for message in self.result:
+            yield self.model.from_message(self.ldb, message)
+
+    def first(self):
+        """Returns the first item in the Query or None for no results."""
+        if self.result.count:
+            return self.model.from_message(self.ldb, self.result[0])
+
+    def last(self):
+        """Returns the last item in the Query or None for no results."""
+        if self.result.count:
+            return self.model.from_message(self.ldb, self.result[-1])
+
+    def get(self):
+        """Returns one item or None if no results were found.
+
+        :returns: Model instance or None if not found.
+        :raises MultipleObjectsReturned: if more than one results were returned
+        """
+        if self.count > 1:
+            raise MultipleObjectsReturned(
+                f"More than one {self.name} objects returned (got {self.count}).")
+        elif self.count:
+            return self.model.from_message(self.ldb, self.result[0])
+
+    def one(self):
+        """Must return EXACTLY one item or raise an exception.
+
+        :returns: Model instance
+        :raises DoesNotExist: if no results were returned
+        :raises MultipleObjectsReturned: if more than one results were returned
+        """
+        if self.count < 1:
+            raise DoesNotExist(
+                f"{self.name.capitalize()} matching query not found")
+        elif self.count > 1:
+            raise MultipleObjectsReturned(
+                f"More than one {self.name} objects returned (got {self.count}).")
+        else:
+            return self.model.from_message(self.ldb, self.result[0])