Versions in this module Expand all Collapse all v0 v0.0.1 Aug 10, 2024 Changes in this version + const BeginSavepointActionType + const BeginTransactionActionType + const CancelQueryActionType + const CancelResultCancelled + const CancelResultCancelling + const CancelResultNotCancellable + const CancelResultUnspecified + const CatalogNameKey + const ClosePreparedStatementActionType + const CreatePreparedStatementActionType + const CreatePreparedSubstraitPlanActionType + const EndSavepointActionType + const EndSavepointRelease + const EndSavepointRollback + const EndSavepointUnspecified + const EndTransactionActionType + const EndTransactionCommit + const EndTransactionRollback + const EndTransactionUnspecified + const IsAutoIncrementKey + const IsCaseSensitiveKey + const IsReadOnlyKey + const IsSearchableKey + const PrecisionKey + const ScaleKey + const SchemaNameKey + const SqlCaseSensitivityCaseInsensitive + const SqlCaseSensitivityLowerCase + const SqlCaseSensitivityUnknown + const SqlCaseSensitivityUpperCase + const SqlConvertBigInt + const SqlConvertBinary + const SqlConvertBit + const SqlConvertChar + const SqlConvertDate + const SqlConvertDecimal + const SqlConvertFloat + const SqlConvertInteger + const SqlConvertIntervalDayTime + const SqlConvertIntervalYearMonth + const SqlConvertLongVarbinary + const SqlConvertLongVarchar + const SqlConvertNumeric + const SqlConvertReal + const SqlConvertSmallInt + const SqlConvertTime + const SqlConvertTimestamp + const SqlConvertTinyInt + const SqlConvertVarbinary + const SqlConvertVarchar + const SqlInfoANSI92SupportedLevel + const SqlInfoAllTablesAreASelectable + const SqlInfoBatchUpdatesSupported + const SqlInfoCatalogAtStart + const SqlInfoCatalogTerm + const SqlInfoCatalogsSupportedActions + const SqlInfoCorrelatedSubqueriesSupported + const SqlInfoDBSchemaNameLen + const SqlInfoDDLCatalog + const SqlInfoDDLSchema + const SqlInfoDDLTable + const SqlInfoDataDefinitionCausesTransactionCommit + const SqlInfoDataDefinitionsInTransactionsIgnored + const SqlInfoDateTimeFunctions + const SqlInfoDefaultTransactionIsolation + const SqlInfoExtraNameChars + const SqlInfoFlightSqlServerArrowVersion + const SqlInfoFlightSqlServerBulkIngestion + const SqlInfoFlightSqlServerCancel + const SqlInfoFlightSqlServerIngestTransactionsSupported + const SqlInfoFlightSqlServerName + const SqlInfoFlightSqlServerReadOnly + const SqlInfoFlightSqlServerSql + const SqlInfoFlightSqlServerStatementTimeout + const SqlInfoFlightSqlServerSubstrait + const SqlInfoFlightSqlServerSubstraitMaxVersion + const SqlInfoFlightSqlServerSubstraitMinVersion + const SqlInfoFlightSqlServerTransaction + const SqlInfoFlightSqlServerTransactionTimeout + const SqlInfoFlightSqlServerVersion + const SqlInfoIdentifierCase + const SqlInfoIdentifierQuoteChar + const SqlInfoKeywords + const SqlInfoLocatorsUpdateCopy + const SqlInfoMaxBinaryLiteralLen + const SqlInfoMaxCatalogNameLen + const SqlInfoMaxCharLiteralLen + const SqlInfoMaxColumnNameLen + const SqlInfoMaxColumnsInGroupBy + const SqlInfoMaxColumnsInIndex + const SqlInfoMaxColumnsInOrderBy + const SqlInfoMaxColumnsInSelect + const SqlInfoMaxColumnsInTable + const SqlInfoMaxConnections + const SqlInfoMaxCursorNameLen + const SqlInfoMaxIndexLen + const SqlInfoMaxProcedureNameLen + const SqlInfoMaxRowSize + const SqlInfoMaxRowSizeIncludesBlobs + const SqlInfoMaxStatementLen + const SqlInfoMaxStatements + const SqlInfoMaxTableNameLen + const SqlInfoMaxTablesInSelect + const SqlInfoMaxUsernameLen + const SqlInfoNamedParametersSupported + const SqlInfoNullOrdering + const SqlInfoNullPlusNullIsNull + const SqlInfoNumericFunctions + const SqlInfoOuterJoinsSupportLevel + const SqlInfoProcedureTerm + const SqlInfoQuotedIdentifierCase + const SqlInfoSavePointsSupported + const SqlInfoSchemaTerm + const SqlInfoSchemasSupportedActions + const SqlInfoSearchStringEscape + const SqlInfoSelectForUpdateSupported + const SqlInfoStoredFunctionsUsingCallSyntaxSupported + const SqlInfoStoredProceduresSupported + const SqlInfoStringFunctions + const SqlInfoSupportedConcurrenciesForResultSetForwardOnly + const SqlInfoSupportedConcurrenciesForResultSetScrollInsensitive + const SqlInfoSupportedConcurrenciesForResultSetScrollSensitive + const SqlInfoSupportedConcurrenciesForResultSetUnspecified + const SqlInfoSupportedGrammar + const SqlInfoSupportedGroupBy + const SqlInfoSupportedPositionedCommands + const SqlInfoSupportedResultSetTypes + const SqlInfoSupportedSubqueries + const SqlInfoSupportedTransactionsIsolationlevels + const SqlInfoSupportedUnions + const SqlInfoSupportsColumnAliasing + const SqlInfoSupportsConvert + const SqlInfoSupportsDifferentTableCorrelationNames + const SqlInfoSupportsExpressionsInOrderBy + const SqlInfoSupportsIntegrityEnhancementFacility + const SqlInfoSupportsLikeEscapeClause + const SqlInfoSupportsNonNullableColumns + const SqlInfoSupportsOrderByUnrelated + const SqlInfoSupportsTableCorrelationNames + const SqlInfoSystemFunctions + const SqlInfoTransactionsSupported + const SqlNullOrderingSortAtEnd + const SqlNullOrderingSortAtStart + const SqlNullOrderingSortHigh + const SqlNullOrderingSortLow + const SqlTransactionNone + const SqlTransactionSavepoint + const SqlTransactionTransaction + const TableDefinitionOptionsTableExistsOptionAppend + const TableDefinitionOptionsTableExistsOptionFail + const TableDefinitionOptionsTableExistsOptionReplace + const TableDefinitionOptionsTableExistsOptionUnspecified + const TableDefinitionOptionsTableNotExistOptionCreate + const TableDefinitionOptionsTableNotExistOptionFail + const TableDefinitionOptionsTableNotExistOptionUnspecified + const TableNameKey + const TypeNameKey + var ErrBadServerSavepoint = fmt.Errorf("%w: server returned an empty savepoint ID", arrow.ErrInvalid) + var ErrBadServerTxn = fmt.Errorf("%w: server returned an empty transaction ID", arrow.ErrInvalid) + var ErrInvalidSavepoint = fmt.Errorf("%w: missing a valid savepoint", arrow.ErrInvalid) + var ErrInvalidTxn = fmt.Errorf("%w: missing a valid transaction", arrow.ErrInvalid) + func CreateStatementQueryTicket(handle []byte) ([]byte, error) + func NewFlightServer(srv Server) flight.FlightServer + func NewFlightServerWithAllocator(srv Server, mem memory.Allocator) flight.FlightServer + type ActionBeginSavepointRequest interface + GetName func() string + GetTransactionId func() []byte + type ActionBeginSavepointResult interface + GetSavepointId func() []byte + type ActionBeginTransactionRequest interface + type ActionBeginTransactionResult interface + GetTransactionId func() []byte + type ActionCancelQueryRequest interface + GetInfo func() *flight.FlightInfo + type ActionClosePreparedStatementRequest interface + GetPreparedStatementHandle func() []byte + type ActionCreatePreparedStatementRequest interface + GetQuery func() string + GetTransactionId func() []byte + type ActionCreatePreparedStatementResult struct + DatasetSchema *arrow.Schema + Handle []byte + ParameterSchema *arrow.Schema + type ActionCreatePreparedSubstraitPlanRequest interface + GetPlan func() SubstraitPlan + GetTransactionId func() []byte + type ActionEndSavepointRequest interface + GetAction func() EndSavepointRequestType + GetSavepointId func() []byte + type ActionEndTransactionRequest interface + GetAction func() EndTransactionRequestType + GetTransactionId func() []byte + type BaseServer struct + Alloc memory.Allocator + func (BaseServer) BeginSavepoint(context.Context, ActionBeginSavepointRequest) ([]byte, error) + func (BaseServer) BeginTransaction(context.Context, ActionBeginTransactionRequest) ([]byte, error) + func (BaseServer) CancelFlightInfo(context.Context, *flight.CancelFlightInfoRequest) (flight.CancelFlightInfoResult, error) + func (BaseServer) ClosePreparedStatement(context.Context, ActionClosePreparedStatementRequest) error + func (BaseServer) CloseSession(context.Context, *flight.CloseSessionRequest) (*flight.CloseSessionResult, error) + func (BaseServer) CreatePreparedStatement(context.Context, ActionCreatePreparedStatementRequest) (res ActionCreatePreparedStatementResult, err error) + func (BaseServer) CreatePreparedSubstraitPlan(context.Context, ActionCreatePreparedSubstraitPlanRequest) (res ActionCreatePreparedStatementResult, err error) + func (BaseServer) DoGetCatalogs(context.Context) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetCrossReference(context.Context, CrossTableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetDBSchemas(context.Context, GetDBSchemas) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetExportedKeys(context.Context, TableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetImportedKeys(context.Context, TableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetPreparedStatement(context.Context, PreparedStatementQuery) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetPrimaryKeys(context.Context, TableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetStatement(context.Context, StatementQueryTicket) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetTableTypes(context.Context) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetTables(context.Context, GetTables) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoGetXdbcTypeInfo(context.Context, GetXdbcTypeInfo) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (BaseServer) DoPutCommandStatementIngest(context.Context, StatementIngest, flight.MessageReader) (int64, error) + func (BaseServer) DoPutCommandStatementUpdate(context.Context, StatementUpdate) (int64, error) + func (BaseServer) DoPutCommandSubstraitPlan(context.Context, StatementSubstraitPlan) (int64, error) + func (BaseServer) DoPutPreparedStatementQuery(context.Context, PreparedStatementQuery, flight.MessageReader, ...) ([]byte, error) + func (BaseServer) DoPutPreparedStatementUpdate(context.Context, PreparedStatementUpdate, flight.MessageReader) (int64, error) + func (BaseServer) EndSavepoint(context.Context, ActionEndSavepointRequest) error + func (BaseServer) EndTransaction(context.Context, ActionEndTransactionRequest) error + func (BaseServer) GetFlightInfoCatalogs(context.Context, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoCrossReference(context.Context, CrossTableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoExportedKeys(context.Context, TableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoImportedKeys(context.Context, TableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoPreparedStatement(context.Context, PreparedStatementQuery, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoPrimaryKeys(context.Context, TableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoSchemas(context.Context, GetDBSchemas, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoStatement(context.Context, StatementQuery, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoSubstraitPlan(context.Context, StatementSubstraitPlan, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoTableTypes(context.Context, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoTables(context.Context, GetTables, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetFlightInfoXdbcTypeInfo(context.Context, GetXdbcTypeInfo, *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (BaseServer) GetSchemaPreparedStatement(context.Context, PreparedStatementQuery, *flight.FlightDescriptor) (*flight.SchemaResult, error) + func (BaseServer) GetSchemaStatement(context.Context, StatementQuery, *flight.FlightDescriptor) (*flight.SchemaResult, error) + func (BaseServer) GetSchemaSubstraitPlan(context.Context, StatementSubstraitPlan, *flight.FlightDescriptor) (*flight.SchemaResult, error) + func (BaseServer) GetSessionOptions(context.Context, *flight.GetSessionOptionsRequest) (*flight.GetSessionOptionsResult, error) + func (BaseServer) PollFlightInfo(context.Context, *flight.FlightDescriptor) (*flight.PollInfo, error) + func (BaseServer) PollFlightInfoPreparedStatement(context.Context, PreparedStatementQuery, *flight.FlightDescriptor) (*flight.PollInfo, error) + func (BaseServer) PollFlightInfoStatement(context.Context, StatementQuery, *flight.FlightDescriptor) (*flight.PollInfo, error) + func (BaseServer) PollFlightInfoSubstraitPlan(context.Context, StatementSubstraitPlan, *flight.FlightDescriptor) (*flight.PollInfo, error) + func (BaseServer) RenewFlightEndpoint(context.Context, *flight.RenewFlightEndpointRequest) (*flight.FlightEndpoint, error) + func (BaseServer) SetSessionOptions(context.Context, *flight.SetSessionOptionsRequest) (*flight.SetSessionOptionsResult, error) + func (b *BaseServer) DoGetSqlInfo(_ context.Context, cmd GetSqlInfo) (*arrow.Schema, <-chan flight.StreamChunk, error) + func (b *BaseServer) GetFlightInfoSqlInfo(_ context.Context, _ GetSqlInfo, desc *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (b *BaseServer) RegisterSqlInfo(id SqlInfo, result interface{}) error + type CancelResult = pb.ActionCancelQueryResult_CancelResult + type Client struct + Alloc memory.Allocator + Client flight.Client + func NewClient(addr string, auth flight.ClientAuthHandler, ...) (*Client, error) + func NewClientCtx(ctx context.Context, addr string, auth flight.ClientAuthHandler, ...) (*Client, error) + func (c *Client) BeginTransaction(ctx context.Context, opts ...grpc.CallOption) (*Txn, error) + func (c *Client) CancelFlightInfo(ctx context.Context, request *flight.CancelFlightInfoRequest, ...) (*flight.CancelFlightInfoResult, error) + func (c *Client) CancelQuery(ctx context.Context, info *flight.FlightInfo, opts ...grpc.CallOption) (cancelResult CancelResult, err error) + func (c *Client) Close() error + func (c *Client) CloseSession(ctx context.Context, request *flight.CloseSessionRequest, ...) (*flight.CloseSessionResult, error) + func (c *Client) DoGet(ctx context.Context, in *flight.Ticket, opts ...grpc.CallOption) (*flight.Reader, error) + func (c *Client) Execute(ctx context.Context, query string, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) ExecuteIngest(ctx context.Context, rdr array.RecordReader, reqOptions *ExecuteIngestOpts, ...) (int64, error) + func (c *Client) ExecutePoll(ctx context.Context, query string, retryDescriptor *flight.FlightDescriptor, ...) (*flight.PollInfo, error) + func (c *Client) ExecuteSubstrait(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) ExecuteSubstraitPoll(ctx context.Context, plan SubstraitPlan, ...) (*flight.PollInfo, error) + func (c *Client) ExecuteSubstraitUpdate(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (n int64, err error) + func (c *Client) ExecuteUpdate(ctx context.Context, query string, opts ...grpc.CallOption) (n int64, err error) + func (c *Client) GetCatalogs(ctx context.Context, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetCatalogsSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetCrossReference(ctx context.Context, pkTable, fkTable TableRef, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetCrossReferenceSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetDBSchemas(ctx context.Context, cmdOpts *GetDBSchemasOpts, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetDBSchemasSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetExecuteSchema(ctx context.Context, query string, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetExecuteSubstraitSchema(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetExportedKeys(ctx context.Context, ref TableRef, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetExportedKeysSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetImportedKeys(ctx context.Context, ref TableRef, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetImportedKeysSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetPrimaryKeys(ctx context.Context, ref TableRef, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetPrimaryKeysSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetSessionOptions(ctx context.Context, request *flight.GetSessionOptionsRequest, ...) (*flight.GetSessionOptionsResult, error) + func (c *Client) GetSqlInfo(ctx context.Context, info []SqlInfo, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetSqlInfoSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetTableTypes(ctx context.Context, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetTableTypesSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetTables(ctx context.Context, reqOptions *GetTablesOpts, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetTablesSchema(ctx context.Context, reqOptions *GetTablesOpts, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) GetXdbcTypeInfo(ctx context.Context, dataType *int32, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (c *Client) GetXdbcTypeInfoSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (c *Client) LoadPreparedStatementFromResult(result *CreatePreparedStatementResult) (*PreparedStatement, error) + func (c *Client) Prepare(ctx context.Context, query string, opts ...grpc.CallOption) (prep *PreparedStatement, err error) + func (c *Client) PrepareSubstrait(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (stmt *PreparedStatement, err error) + func (c *Client) RenewFlightEndpoint(ctx context.Context, request *flight.RenewFlightEndpointRequest, ...) (*flight.FlightEndpoint, error) + func (c *Client) SetSessionOptions(ctx context.Context, request *flight.SetSessionOptionsRequest, ...) (*flight.SetSessionOptionsResult, error) + type ColumnMetadata struct + Data *arrow.Metadata + func (c *ColumnMetadata) CatalogName() (string, bool) + func (c *ColumnMetadata) IsAutoIncrement() (bool, bool) + func (c *ColumnMetadata) IsCaseSensitive() (bool, bool) + func (c *ColumnMetadata) IsReadOnly() (bool, bool) + func (c *ColumnMetadata) IsSearchable() (bool, bool) + func (c *ColumnMetadata) Precision() (int32, bool) + func (c *ColumnMetadata) Scale() (int32, bool) + func (c *ColumnMetadata) SchemaName() (string, bool) + func (c *ColumnMetadata) TableName() (string, bool) + func (c *ColumnMetadata) TypeName() (string, bool) + type ColumnMetadataBuilder struct + func NewColumnMetadataBuilder() *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) Build() ColumnMetadata + func (c *ColumnMetadataBuilder) CatalogName(name string) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) Clear() + func (c *ColumnMetadataBuilder) IsAutoIncrement(v bool) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) IsCaseSensitive(v bool) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) IsReadOnly(v bool) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) IsSearchable(v bool) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) Metadata() arrow.Metadata + func (c *ColumnMetadataBuilder) Precision(prec int32) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) Scale(prec int32) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) SchemaName(name string) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) TableName(name string) *ColumnMetadataBuilder + func (c *ColumnMetadataBuilder) TypeName(name string) *ColumnMetadataBuilder + type CreatePreparedStatementResult = pb.ActionCreatePreparedStatementResult + type CrossTableRef struct + FKRef TableRef + PKRef TableRef + type EndSavepointRequestType = pb.ActionEndSavepointRequest_EndSavepoint + type EndTransactionRequestType = pb.ActionEndTransactionRequest_EndTransaction + type ExecuteIngestOpts pb.CommandStatementIngest + type GetDBSchemas interface + GetCatalog func() *string + GetDBSchemaFilterPattern func() *string + type GetDBSchemasOpts pb.CommandGetDbSchemas + type GetSqlInfo interface + GetInfo func() []uint32 + type GetTables interface + GetCatalog func() *string + GetDBSchemaFilterPattern func() *string + GetIncludeSchema func() bool + GetTableNameFilterPattern func() *string + GetTableTypes func() []string + type GetTablesOpts pb.CommandGetTables + type GetXdbcTypeInfo interface + GetDataType func() *int32 + type PreparedStatement struct + func (p *PreparedStatement) Close(ctx context.Context, opts ...grpc.CallOption) error + func (p *PreparedStatement) DatasetSchema() *arrow.Schema + func (p *PreparedStatement) Execute(ctx context.Context, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (p *PreparedStatement) ExecutePoll(ctx context.Context, retryDescriptor *flight.FlightDescriptor, ...) (*flight.PollInfo, error) + func (p *PreparedStatement) ExecutePut(ctx context.Context, opts ...grpc.CallOption) error + func (p *PreparedStatement) ExecuteUpdate(ctx context.Context, opts ...grpc.CallOption) (nrecords int64, err error) + func (p *PreparedStatement) GetSchema(ctx context.Context, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (p *PreparedStatement) Handle() []byte + func (p *PreparedStatement) ParameterSchema() *arrow.Schema + func (p *PreparedStatement) SetParameters(binding arrow.Record) + func (p *PreparedStatement) SetRecordReader(binding array.RecordReader) + type PreparedStatementQuery interface + GetPreparedStatementHandle func() []byte + type PreparedStatementUpdate interface + GetPreparedStatementHandle func() []byte + type Savepoint []byte + func (sp Savepoint) IsValid() bool + type Server interface + BeginSavepoint func(context.Context, ActionBeginSavepointRequest) (id []byte, err error) + BeginTransaction func(context.Context, ActionBeginTransactionRequest) (id []byte, err error) + CancelFlightInfo func(context.Context, *flight.CancelFlightInfoRequest) (flight.CancelFlightInfoResult, error) + ClosePreparedStatement func(context.Context, ActionClosePreparedStatementRequest) error + CloseSession func(context.Context, *flight.CloseSessionRequest) (*flight.CloseSessionResult, error) + CreatePreparedStatement func(context.Context, ActionCreatePreparedStatementRequest) (ActionCreatePreparedStatementResult, error) + CreatePreparedSubstraitPlan func(context.Context, ActionCreatePreparedSubstraitPlanRequest) (ActionCreatePreparedStatementResult, error) + DoGetCatalogs func(context.Context) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetCrossReference func(context.Context, CrossTableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetDBSchemas func(context.Context, GetDBSchemas) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetExportedKeys func(context.Context, TableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetImportedKeys func(context.Context, TableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetPreparedStatement func(context.Context, PreparedStatementQuery) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetPrimaryKeys func(context.Context, TableRef) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetSqlInfo func(context.Context, GetSqlInfo) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetStatement func(context.Context, StatementQueryTicket) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetTableTypes func(context.Context) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetTables func(context.Context, GetTables) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoGetXdbcTypeInfo func(context.Context, GetXdbcTypeInfo) (*arrow.Schema, <-chan flight.StreamChunk, error) + DoPutCommandStatementIngest func(context.Context, StatementIngest, flight.MessageReader) (int64, error) + DoPutCommandStatementUpdate func(context.Context, StatementUpdate) (int64, error) + DoPutCommandSubstraitPlan func(context.Context, StatementSubstraitPlan) (int64, error) + DoPutPreparedStatementQuery func(context.Context, PreparedStatementQuery, flight.MessageReader, ...) ([]byte, error) + DoPutPreparedStatementUpdate func(context.Context, PreparedStatementUpdate, flight.MessageReader) (int64, error) + EndSavepoint func(context.Context, ActionEndSavepointRequest) error + EndTransaction func(context.Context, ActionEndTransactionRequest) error + GetFlightInfoCatalogs func(context.Context, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoCrossReference func(context.Context, CrossTableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoExportedKeys func(context.Context, TableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoImportedKeys func(context.Context, TableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoPreparedStatement func(context.Context, PreparedStatementQuery, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoPrimaryKeys func(context.Context, TableRef, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoSchemas func(context.Context, GetDBSchemas, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoSqlInfo func(context.Context, GetSqlInfo, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoStatement func(context.Context, StatementQuery, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoSubstraitPlan func(context.Context, StatementSubstraitPlan, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoTableTypes func(context.Context, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoTables func(context.Context, GetTables, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetFlightInfoXdbcTypeInfo func(context.Context, GetXdbcTypeInfo, *flight.FlightDescriptor) (*flight.FlightInfo, error) + GetSchemaPreparedStatement func(context.Context, PreparedStatementQuery, *flight.FlightDescriptor) (*flight.SchemaResult, error) + GetSchemaStatement func(context.Context, StatementQuery, *flight.FlightDescriptor) (*flight.SchemaResult, error) + GetSchemaSubstraitPlan func(context.Context, StatementSubstraitPlan, *flight.FlightDescriptor) (*flight.SchemaResult, error) + GetSessionOptions func(context.Context, *flight.GetSessionOptionsRequest) (*flight.GetSessionOptionsResult, error) + PollFlightInfo func(context.Context, *flight.FlightDescriptor) (*flight.PollInfo, error) + PollFlightInfoPreparedStatement func(context.Context, PreparedStatementQuery, *flight.FlightDescriptor) (*flight.PollInfo, error) + PollFlightInfoStatement func(context.Context, StatementQuery, *flight.FlightDescriptor) (*flight.PollInfo, error) + PollFlightInfoSubstraitPlan func(context.Context, StatementSubstraitPlan, *flight.FlightDescriptor) (*flight.PollInfo, error) + RenewFlightEndpoint func(context.Context, *flight.RenewFlightEndpointRequest) (*flight.FlightEndpoint, error) + SetSessionOptions func(context.Context, *flight.SetSessionOptionsRequest) (*flight.SetSessionOptionsResult, error) + type SqlInfo uint32 + func (s SqlInfo) String() string + type SqlInfoResultMap map[uint32]interface + type SqlNullOrdering = pb.SqlNullOrdering + type SqlSupportedCaseSensitivity = pb.SqlSupportedCaseSensitivity + type SqlSupportedTransaction = pb.SqlSupportedTransaction + type SqlSupportsConvert = pb.SqlSupportsConvert + type StatementIngest interface + GetCatalog func() string + GetOptions func() map[string]string + GetSchema func() string + GetTable func() string + GetTableDefinitionOptions func() *TableDefinitionOptions + GetTemporary func() bool + GetTransactionId func() []byte + type StatementQuery interface + GetQuery func() string + GetTransactionId func() []byte + type StatementQueryTicket interface + GetStatementHandle func() []byte + func GetStatementQueryTicket(ticket *flight.Ticket) (result StatementQueryTicket, err error) + type StatementSubstraitPlan interface + GetPlan func() SubstraitPlan + GetTransactionId func() []byte + type StatementUpdate interface + GetQuery func() string + GetTransactionId func() []byte + type SubstraitPlan struct + Plan []byte + Version string + type TableDefinitionOptions = pb.CommandStatementIngest_TableDefinitionOptions + type TableDefinitionOptionsTableExistsOption = pb.CommandStatementIngest_TableDefinitionOptions_TableExistsOption + type TableDefinitionOptionsTableNotExistOption = pb.CommandStatementIngest_TableDefinitionOptions_TableNotExistOption + type TableRef struct + Catalog *string + DBSchema *string + Table string + type Transaction []byte + func (tx Transaction) IsValid() bool + type Txn struct + func (tx *Txn) BeginSavepoint(ctx context.Context, name string, opts ...grpc.CallOption) (Savepoint, error) + func (tx *Txn) Commit(ctx context.Context, opts ...grpc.CallOption) error + func (tx *Txn) Execute(ctx context.Context, query string, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (tx *Txn) ExecutePoll(ctx context.Context, query string, retryDescriptor *flight.FlightDescriptor, ...) (*flight.PollInfo, error) + func (tx *Txn) ExecuteSubstrait(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (*flight.FlightInfo, error) + func (tx *Txn) ExecuteSubstraitPoll(ctx context.Context, plan SubstraitPlan, ...) (*flight.PollInfo, error) + func (tx *Txn) ExecuteSubstraitUpdate(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (n int64, err error) + func (tx *Txn) ExecuteUpdate(ctx context.Context, query string, opts ...grpc.CallOption) (n int64, err error) + func (tx *Txn) GetExecuteSchema(ctx context.Context, query string, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (tx *Txn) GetExecuteSubstraitSchema(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (*flight.SchemaResult, error) + func (tx *Txn) ID() Transaction + func (tx *Txn) Prepare(ctx context.Context, query string, opts ...grpc.CallOption) (prep *PreparedStatement, err error) + func (tx *Txn) PrepareSubstrait(ctx context.Context, plan SubstraitPlan, opts ...grpc.CallOption) (stmt *PreparedStatement, err error) + func (tx *Txn) ReleaseSavepoint(ctx context.Context, sp Savepoint, opts ...grpc.CallOption) error + func (tx *Txn) Rollback(ctx context.Context, opts ...grpc.CallOption) error + func (tx *Txn) RollbackSavepoint(ctx context.Context, sp Savepoint, opts ...grpc.CallOption) error
Go to main page