mirror of
https://github.com/davidallendj/magellan.git
synced 2025-12-20 03:27:03 -07:00
Minor changes
This commit is contained in:
parent
91cc277863
commit
6e483064e0
1 changed files with 7 additions and 1 deletions
8
internal/cache/sqlite/sqlite.go
vendored
8
internal/cache/sqlite/sqlite.go
vendored
|
|
@ -113,7 +113,13 @@ func DeleteRemoteAssets(path string, assets ...magellan.RemoteAsset) error {
|
||||||
}
|
}
|
||||||
tx = db.MustBegin()
|
tx = db.MustBegin()
|
||||||
for _, asset := range assets {
|
for _, asset := range assets {
|
||||||
sql := fmt.Sprintf(`DELETE FROM %s WHERE host=:host AND port=:port;`, TABLE_NAME)
|
if asset.Host == "" && asset.Port <= 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
sql := fmt.Sprintf(`DELETE FROM %s WHERE port=:port;`, TABLE_NAME)
|
||||||
|
if asset.Host != "" {
|
||||||
|
sql += "AND host=:host"
|
||||||
|
}
|
||||||
_, err := tx.NamedExec(sql, &asset)
|
_, err := tx.NamedExec(sql, &asset)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("failed to execute DELETE transaction: %v\n", err)
|
fmt.Printf("failed to execute DELETE transaction: %v\n", err)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue