feat: add PurgeCache function to remove dead connections from cache

flarco · flarco · commit 588fdd32c8ba · 2026-05-04T17:13:10.000-03:00
diff --git a/core/dbio/connection/connection.go b/core/dbio/connection/connection.go
@@ -1097,6 +1097,13 @@ func CloseAll() {
 	}
 }
 
+// PurgeCache removes a connection from the cache by hash so the next
+// AsDatabaseContext / AsFileContext / AsAPIContext call rebuilds it.
+// Use this after detecting a dead underlying handle (e.g. "sql: database is closed").
+func PurgeCache(hash string) {
+	connCache.Remove(hash)
+}
+
 // CopyDirect copies directly from cloud files
 // (without passing through dbio)
 func CopyDirect(conn database.Connection, tableFName string, srcFile Connection) (cnt uint64, ok bool, err error) {

Original file line number	Diff line number	Diff line change
`@@ -1097,6 +1097,13 @@ func CloseAll() {`
`1097`	`1097`	`}`
`1098`	`1098`	`}`
`1099`	`1099`
	`1100`	`+// PurgeCache removes a connection from the cache by hash so the next`
	`1101`	`+// AsDatabaseContext / AsFileContext / AsAPIContext call rebuilds it.`
	`1102`	`+// Use this after detecting a dead underlying handle (e.g. "sql: database is closed").`
	`1103`	`+func PurgeCache(hash string) {`
	`1104`	`+ connCache.Remove(hash)`
	`1105`	`+}`
	`1106`	`+`
`1100`	`1107`	`// CopyDirect copies directly from cloud files`
`1101`	`1108`	`// (without passing through dbio)`
`1102`	`1109`	`func CopyDirect(conn database.Connection, tableFName string, srcFile Connection) (cnt uint64, ok bool, err error) {`