diff --git a/db/posthooks.go b/db/posthooks.go index 3b6b1e3ffafda9916fa06eb5da9ab81ca008af7a..e9823a0d4214af50e1e0bb35d7d45ccacfc2a7cd 100644 --- a/db/posthooks.go +++ b/db/posthooks.go @@ -51,6 +51,10 @@ func generateAndInsertProjectIDs(tx *sql.Tx) error { } } + if err := rows.Err(); err != nil { + return fmt.Errorf("failed to iterate over rows: %w", err) + } + if _, err := tx.Exec("DROP TABLE projects_tmp"); err != nil { return fmt.Errorf("failed to drop projects_tmp: %w", err) } @@ -89,5 +93,9 @@ func correctProjectIDs(tx *sql.Tx) error { } } + if err := rows.Err(); err != nil { + return fmt.Errorf("failed to iterate over rows: %w", err) + } + return nil } diff --git a/db/project.go b/db/project.go index 085fbc1075ac92c8de47a869dc211e981967ef5c..a47fa8407feae2d0b1dbb4e05e3dac27393aa031 100644 --- a/db/project.go +++ b/db/project.go @@ -94,5 +94,9 @@ func GetProjects(db *sql.DB) ([]map[string]string, error) { projects = append(projects, project) } + if err = rows.Err(); err != nil { + return nil, fmt.Errorf("failed to iterate over rows: %w", err) + } + return projects, nil } diff --git a/db/release.go b/db/release.go index e8c21a68535b6879d8fdf274060be2da86a3be3d..f88d9ec35d809ef9cb49f59b8df5a5018ba54248 100644 --- a/db/release.go +++ b/db/release.go @@ -65,5 +65,9 @@ func GetReleases(db *sql.DB, projectID string) ([]map[string]string, error) { }) } + if err := rows.Err(); err != nil { + return nil, fmt.Errorf("failed to iterate rows: %w", err) + } + return releases, nil } diff --git a/db/users.go b/db/users.go index 5cb7e1af8bf9ef8d5a730f590f4b979aa40f1728..5a21955f94619b6308633b45c62ab4eef5d0c48d 100644 --- a/db/users.go +++ b/db/users.go @@ -71,6 +71,10 @@ func GetUsers(db *sql.DB) ([]string, error) { users = append(users, user) } + if err = rows.Err(); err != nil { + return nil, fmt.Errorf("failed to iterate rows: %w", err) + } + return users, nil }