specify table when to delete records (#5)

JunNishimura · Mar 30, 2024 · 5d7a098 · 5d7a098
1 parent fef1a94
commit 5d7a098
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/adapter.go b/adapter.go
@@ -244,6 +244,7 @@ func (a *bunAdapter) RemovePolicies(sec string, ptype string, rules [][]string)
 
 func (a *bunAdapter) deleteRecord(existingPolicy CasbinPolicy) error {
 	query := a.db.NewDelete().
+		Model((*CasbinPolicy)(nil)).
 		Where("ptype = ?", existingPolicy.PType)
 
 	values := existingPolicy.filterValuesWithKey()
@@ -253,6 +254,7 @@ func (a *bunAdapter) deleteRecord(existingPolicy CasbinPolicy) error {
 
 func (a *bunAdapter) deleteRecordInTx(tx bun.Tx, existingPolicy CasbinPolicy) error {
 	query := tx.NewDelete().
+		Model((*CasbinPolicy)(nil)).
 		Where("ptype = ?", existingPolicy.PType)
 
 	values := existingPolicy.filterValuesWithKey()