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

Method QueryContext

flightsqlserver/sqlite_server.go:486–486  ·  view source on GitHub ↗
(context.Context, string, ...any)

Source from the content-addressed store, hash-verified

484type dbQueryCtx interface {
485 QueryContext(context.Context, string, ...any) (*sql.Rows, error)
486}
487
488func doGetQuery(ctx context.Context, db *sql.DB, query string, schema *arrow.Schema, args ...interface{}) (*arrow.Schema, <-chan flight.StreamChunk, error) {
489

Callers 15

executeQueryMethod · 0.80
DoGetTablesMethod · 0.80
doGetQueryFunction · 0.80
DoGetPreparedStatementMethod · 0.80
NextMethod · 0.80
QueryFunction · 0.80
QueryCatalogFunction · 0.80
TestRowsManualPrematureCloseMethod · 0.80
TestRowsNormalExhaustionMethod · 0.80
TestRowsPrematureCloseDuringNextLoopMethod · 0.80
TestRowsInterruptionByContextManualCancellationMethod · 0.80
TestRowsInterruptionByContextTimeoutMethod · 0.80

Calls

no outgoing calls

Tested by 10

TestRowsManualPrematureCloseMethod · 0.64
TestRowsNormalExhaustionMethod · 0.64
TestRowsPrematureCloseDuringNextLoopMethod · 0.64
TestRowsInterruptionByContextManualCancellationMethod · 0.64
TestRowsInterruptionByContextTimeoutMethod · 0.64
TestRowsManualPrematureCloseStmtMethod · 0.64
TestRowsNormalExhaustionStmtMethod · 0.64
TestRowsPrematureCloseDuringNextLoopStmtMethod · 0.64
TestRowsInterruptionByContextManualCancellationStmtMethod · 0.64
TestRowsInterruptionByContextTimeoutStmtMethod · 0.64