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

Run all statements in one transaction

Browse Source
This commit is contained in:
Denis Makogon
2017-09-12 23:39:18 +03:00
parent 93d4a5730b
commit b2ca5ebc64
1 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -221,18 +221,17 @@ func (ds *sqlStore) UpdateApp(ctx context.Context, newapp *models.App) (*models.
}
func (ds *sqlStore) RemoveApp(ctx context.Context, appName string) error {
query := ds.db.Rebind(`DELETE FROM apps WHERE name = ?`)
res, err := ds.db.ExecContext(ctx, query, appName)
if _, err := res.RowsAffected(); err != nil {
return models.ErrAppsNotFound
}
_, err = ds.db.ExecContext(ctx, ds.db.Rebind(
`DELETE FROM logs WHERE app_name=?;
res, err := ds.db.ExecContext(ctx, ds.db.Rebind(
`DELETE FROM apps WHERE name = ?;
DELETE FROM logs WHERE app_name=?;
DELETE FROM calls WHERE app_name=?;
DELETE FROM routes WHERE app_name=?;`), appName, appName, appName)
DELETE FROM routes WHERE app_name=?;`), appName, appName, appName, appName)
if err != nil {
return err
}
if _, err := res.RowsAffected(); err != nil {
return models.ErrAppsNotFound
}
return nil
}