Skip to content

Commit 68d8072

Browse files
author
setiawanisasi
committed
change select query to delete query
1 parent cf519f6 commit 68d8072

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

casbin_databases_adapter/adapter.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ async def remove_policy(self, sec, p_type, rule):
7171

7272
@to_sync()
7373
async def remove_filtered_policy(self, sec, ptype, field_index, *field_values):
74-
query = self.table.select().where(self.table.columns.ptype == ptype)
74+
query = self.table.delete().where(self.table.columns.ptype == ptype)
7575
if not (0 <= field_index <= 5):
7676
return False
7777
if not (1 <= field_index + len(field_values) <= 6):
@@ -80,7 +80,7 @@ async def remove_filtered_policy(self, sec, ptype, field_index, *field_values):
8080
if len(value) > 0:
8181
query = query.where(self.table.columns[f"v{field_index+1}"] == value)
8282
result = await self.db.execute(query)
83-
return True if result > 0 else False
83+
return True if result else False
8484

8585
@to_sync()
8686
async def load_filtered_policy(self, model: Model, filter_: Filter) -> None:

0 commit comments

Comments
 (0)