Documentation
¶
Index ¶
- type Connection
- func (conn *Connection) Close()
- func (conn *Connection) DeregisterTable(name string) error
- func (conn *Connection) Prepare(query string) (*Statement, error)
- func (conn *Connection) RegisterArrowIPC(name string, data []byte) error
- func (conn *Connection) RegisterArrowReaderZeroCopy(name string, reader array.RecordReader) error
- func (conn *Connection) RegisterFFITableProvider(name string, provider unsafe.Pointer, providerDataFusionVersion string) error
- type Database
- type DateParameter
- type DecimalParameter
- type DurationParameter
- type Error
- type NullParameter
- type ParameterType
- type RecordReader
- type Statement
- type TimeParameter
- type TimestampParameter
- type UInt64Parameter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func (*Connection) Close ¶
func (conn *Connection) Close()
func (*Connection) DeregisterTable ¶ added in v0.530100.2
func (conn *Connection) DeregisterTable(name string) error
DeregisterTable removes a table previously registered on the connection's session. Removing a name that is not registered is not an error.
func (*Connection) RegisterArrowIPC ¶
func (conn *Connection) RegisterArrowIPC(name string, data []byte) error
func (*Connection) RegisterArrowReaderZeroCopy ¶
func (conn *Connection) RegisterArrowReaderZeroCopy(name string, reader array.RecordReader) error
func (*Connection) RegisterFFITableProvider ¶ added in v0.530100.2
func (conn *Connection) RegisterFFITableProvider(name string, provider unsafe.Pointer, providerDataFusionVersion string) error
RegisterFFITableProvider registers a foreign datafusion-ffi FFI_TableProvider (produced by another library) under name. provider must point to a valid FFI_TableProvider; the callee clones it, so the caller retains ownership of the pointer. providerDataFusionVersion is the datafusion version the producing library reports, checked before the provider is dereferenced. The producing library must outlive every registration, dependent query/view, stream, and returned batch, which may retain foreign callbacks after deregistration. See datafusion.RegisterFFITableProvider for the full contract.
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func OpenDatabase ¶
type DateParameter ¶
type DateParameter struct {
Days int32
}
type DecimalParameter ¶
type DurationParameter ¶
type DurationParameter struct {
Nanoseconds int64
}
type Error ¶
func (*Error) NativeErrorKind ¶
type NullParameter ¶
type NullParameter struct {
Type ParameterType
Precision uint8
Scale int8
TimeZone string
}
type ParameterType ¶
type ParameterType int32
const ( ParameterBool ParameterType = iota + 1 ParameterInt64 ParameterUInt64 ParameterFloat64 ParameterString ParameterBinary ParameterDate ParameterTime ParameterTimestamp ParameterDuration ParameterDecimal )
type RecordReader ¶ added in v0.550000.2
RecordReader owns a native result stream. Its schema is available before the first read, including for empty results. Close is idempotent and cancels work. Each returned batch has its own reference and must be released by the caller.
type Statement ¶
type Statement struct {
// contains filtered or unexported fields
}
func (*Statement) ExecuteArrow ¶
func (stmt *Statement) ExecuteArrow(ctx context.Context, args []driver.NamedValue) (RecordReader, error)
func (*Statement) Serializes ¶
type TimeParameter ¶
type TimeParameter struct {
Nanoseconds int64
}
type TimestampParameter ¶
type UInt64Parameter ¶
type UInt64Parameter struct {
Value uint64
}
Source Files