Skip to content

Commit 688db86

Browse files
committed
implement count functionality
Signed-off-by: wiseaidev <[email protected]>
1 parent dcd84e0 commit 688db86

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

aredis_om/model/model.py

+3
Original file line numberDiff line numberDiff line change
@@ -760,6 +760,9 @@ async def all(self, batch_size=10):
760760
return await query.execute()
761761
return await self.execute()
762762

763+
async def count(self, batch_size=10):
764+
return len(await self.all(batch_size))
765+
763766
def sort_by(self, *fields: str):
764767
if not fields:
765768
return self

tests/test_hash_model.py

+7
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,13 @@ async def members(m):
9595

9696
yield member1, member2, member3
9797

98+
@py_test_mark_asyncio
99+
async def test_count_query(members, m):
100+
101+
count = await m.Member.find(m.Member.first_name="Kim").count()
102+
assert count == 1
103+
count = await m.Member.find().count()
104+
assert count == 3
98105

99106
@py_test_mark_asyncio
100107
async def test_exact_match_queries(members, m):

0 commit comments

Comments
 (0)