From 7da2dd34f240eb4d5f48a07f9ab561e3cbeb853e Mon Sep 17 00:00:00 2001 From: XANTRONIX Industrial Date: Mon, 31 Mar 2025 14:35:24 -0400 Subject: [PATCH] Add limit argument to Database.query() --- lib/xmet/db.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/lib/xmet/db.py b/lib/xmet/db.py index 2b0f20e..90b33fc 100644 --- a/lib/xmet/db.py +++ b/lib/xmet/db.py @@ -212,7 +212,7 @@ class Database(): return cr - def query(self, table, clauses=list(), values=None, order_by=list()): + def query(self, table, clauses=list(), values=None, order_by=list(), limit=None): selectors = getattr(table, '__columns_read__', None) if selectors is None: @@ -247,6 +247,9 @@ class Database(): elif order is DatabaseOrder.DESC: sql += f" {column} desc" + if limit is not None: + sql += f" limit {limit}" + return self.query_sql(table, sql, values) def get(self, table, values: dict=dict()):