Method DoGetTables

flightsqlserver/sqlite_server.go:348–380

(ctx context.Context, cmd flightsql.GetTables)

	return &flight.FlightInfo{
		Endpoint:         []*flight.FlightEndpoint{{Ticket: &flight.Ticket{Ticket: tkt}}},
		FlightDescriptor: desc,
		TotalRecords:     -1,
		TotalBytes:       -1,
	}, nil
}

func (s *SQLiteFlightSQLServer) DoGetStatement(ctx context.Context, cmd flightsql.StatementQueryTicket) (*arrow.Schema, <-chan flight.StreamChunk, error) {
	txnid, query, err := decodeTransactionQuery(cmd.GetStatementHandle())
	if err != nil {
		return nil, nil, err
	}
	if txnid != "" {
		return nil, nil, fmt.Errorf("transactions not yet supported with DuckDB")
	}
	if s.provider != nil {
		return s.managedStatelessQuery(ctx, query)
	}

	// var db dbQueryCtx = s.db
	// if txnid != "" {
	// 	tx, loaded := s.openTransactions.Load(txnid)
	// 	if !loaded {
	// 		return nil, nil, fmt.Errorf("%w: invalid transaction id specified: %s", arrow.ErrInvalid, txnid)
	// 	}
	// 	db = tx.(*sql.Tx)
	// }

	return doGetQueryWithInitializer(ctx, s.initializeStorage, s.db, query, nil)
}

func (s *SQLiteFlightSQLServer) GetFlightInfoCatalogs(_ context.Context, desc *flight.FlightDescriptor) (*flight.FlightInfo, error) {
	return s.flightInfoForCommand(desc, schema_ref.Catalogs), nil
}

func (s *SQLiteFlightSQLServer) DoGetCatalogs(context.Context) (*arrow.Schema, <-chan flight.StreamChunk, error) {
	// https://www.sqlite.org/cli.html