Archive/rdio-scanner
1
0
Fork 0
mirror of https://github.com/chuot/rdio-scanner.git synced 2026-08-13 08:33:00 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: streamline error handling in migrateCalls function

Browse source
This commit is contained in:
Chrystian Huot 2026-05-17 08:57:24 -04:00
parent b7975763cf
commit 7edf0df1ac
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
server/migrations.go
View file

@ -425,8 +425,7 @@ func migrateCalls(db *Database) error {
query = fmt.Sprintf(`SELECT COUNT(*) FROM "units" WHERE "systemId" = %d AND "unitRef" = %d`, systems[systemRef.Int32], source.Int32) query = fmt.Sprintf(`SELECT COUNT(*) FROM "units" WHERE "systemId" = %d AND "unitRef" = %d`, systems[systemRef.Int32], source.Int32)
if err = tx.QueryRow(query).Scan(&c); err == nil && c == 0 { if err = tx.QueryRow(query).Scan(&c); err == nil && c == 0 {
query = fmt.Sprintf(`INSERT INTO "units" ("label", "systemId", "unitRef") VALUES(%d, %d, %d)`, source.Int32, systems[systemRef.Int32], source.Int32) query = fmt.Sprintf(`INSERT INTO "units" ("label", "systemId", "unitRef") VALUES(%d, %d, %d)`, source.Int32, systems[systemRef.Int32], source.Int32)
if _, err = tx.Exec(query); err != nil {
if err == nil {
query = fmt.Sprintf(`INSERT INTO "callUnits" ("callId", "offset", "unitRef") VALUES (%d, %d, %d)`, call.Id, 0, source.Int32) query = fmt.Sprintf(`INSERT INTO "callUnits" ("callId", "offset", "unitRef") VALUES (%d, %d, %d)`, call.Id, 0, source.Int32)
if _, err = tx.Exec(query); err != nil { if _, err = tx.Exec(query); err != nil {
log.Println(formatError(err, query)) log.Println(formatError(err, query))