alihan/fn-serverless
1
0
Fork 0
mirror of https://github.com/fnproject/fn.git synced 2022-10-28 21:29:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

Running deletes in single transaction

Browse Source
This commit is contained in:
Denis Makogon
2017-09-12 23:30:31 +03:00
parent 0b47c8c40c
commit 93d4a5730b
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
api/datastore/sql/sql.go
View File

@@ -227,21 +227,13 @@ func (ds *sqlStore) RemoveApp(ctx context.Context, appName string) error {
return models.ErrAppsNotFound return models.ErrAppsNotFound
} }
_, err = ds.db.ExecContext(ctx, ds.db.Rebind( _, err = ds.db.ExecContext(ctx, ds.db.Rebind(
`DELETE FROM logs WHERE app_name=?`), appName) `DELETE FROM logs WHERE app_name=?;
DELETE FROM calls WHERE app_name=?;
DELETE FROM routes WHERE app_name=?;`), appName, appName, appName)
if err != nil { if err != nil {
return err return err
} }
_, err = ds.db.ExecContext(ctx, ds.db.Rebind( return nil
`DELETE FROM calls WHERE app_name=?`), appName)
if err != nil {
return err
}
_, err = ds.db.ExecContext(ctx, ds.db.Rebind(
`DELETE FROM routes WHERE app_name=?`), appName)
if err != nil {
return err
}
return err
} }
func (ds *sqlStore) GetApp(ctx context.Context, name string) (*models.App, error) { func (ds *sqlStore) GetApp(ctx context.Context, name string) (*models.App, error) {