| 255 | // not have a foreign key, so clean up rows orphaned by older Duckgres |
| 256 | // versions before this name becomes an org again. |
| 257 | if err := configstore.LockOrgConnectionAdmissionTx(tx, org.Name); err != nil { |
| 258 | return err |
| 259 | } |
| 260 | var existing int64 |
| 261 | if err := tx.Model(&configstore.Org{}).Where("name = ?", org.Name).Count(&existing).Error; err != nil { |
| 262 | return err |
| 263 | } |
| 264 | if existing == 0 { |
| 265 | if err := tx.Where("org_id = ?", org.Name).Delete(&configstore.ServiceGrant{}).Error; err != nil { |
| 266 | return err |