MCPcopy Create free account
hub / github.com/apecloud/myduckserver / QueryRow

Method QueryRow

backend/session.go:256–262  ·  view source on GitHub ↗
(ctx context.Context, query string, args ...any)

Source from the content-addressed store, hash-verified

254 if sess == nil {
255 return
256 }
257 if len(sess.postPhysical) == 0 {
258 sess.postPhysicalOrder = nil
259 return
260 }
261 for tx, state := range sess.postPhysical {
262 completed, completedAt := state.completionSnapshot()
263 if completed && !completedAt.IsZero() && now.Sub(completedAt) >= postPhysicalTombstoneTTL {
264 delete(sess.postPhysical, tx)
265 }

Callers 5

GetPersistedValueMethod · 0.95
initCatalogMethod · 0.80
replicationSlotExistsMethod · 0.80

Calls 1

GetCatalogConnMethod · 0.95

Tested by 1