rows

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ParseTimestampTz

func ParseTimestampTz(value string) (driver.Value, error)

Types

type ColumnReader

type ColumnReader struct {
	// contains filtered or unexported fields
}

func (*ColumnReader) ColumnTypeDatabaseTypeName

func (r *ColumnReader) ColumnTypeDatabaseTypeName(index int) string

func (*ColumnReader) ColumnTypeLength

func (r *ColumnReader) ColumnTypeLength(index int) (length int64, ok bool)

func (*ColumnReader) ColumnTypeNullable

func (r *ColumnReader) ColumnTypeNullable(index int) (nullable, ok bool)

func (*ColumnReader) ColumnTypePrecisionScale

func (r *ColumnReader) ColumnTypePrecisionScale(index int) (precision, scale int64, ok bool)

func (*ColumnReader) ColumnTypeScanType

func (r *ColumnReader) ColumnTypeScanType(index int) reflect.Type

func (*ColumnReader) Columns

func (r *ColumnReader) Columns() []string

Columns returns a list of column names in the current row set

type ExtendableRows

type ExtendableRows interface {
	driver.Rows
	ProcessAndAppendResponse(response *client.Response) error
}

type FireboltArray added in v1.7.0

type FireboltArray []interface{}

func (*FireboltArray) Scan added in v1.7.0

func (fa *FireboltArray) Scan(src interface{}) error

Scan implements the sql.Scanner interface.

type FireboltDecimal added in v1.7.0

type FireboltDecimal struct {
	decimal.Decimal
}

func (*FireboltDecimal) Compose added in v1.7.0

func (fd *FireboltDecimal) Compose(form byte, negative bool, coefficient []byte, exponent int32) error

Compose constructs an ExtendedDecimal from the given form, sign, coefficient, and exponent.

func (*FireboltDecimal) Decompose added in v1.7.0

func (fd *FireboltDecimal) Decompose(buf []byte) (byte, bool, []byte, int32)

Decompose extracts the decimal value into form, sign, coefficient, and exponent.

type FireboltNullArray added in v1.7.0

type FireboltNullArray struct {
	Array FireboltArray
	Valid bool
}

func (*FireboltNullArray) Scan added in v1.7.0

func (fna *FireboltNullArray) Scan(src interface{}) error

Scan implements the sql.Scanner interface.

type FireboltNullDecimal added in v1.7.0

type FireboltNullDecimal struct {
	decimal.NullDecimal
}

func (*FireboltNullDecimal) Compose added in v1.7.0

func (fnd *FireboltNullDecimal) Compose(form byte, negative bool, coefficient []byte, exponent int32) error

Compose constructs an ExtendedDecimal from the given form, sign, coefficient, and exponent.

func (*FireboltNullDecimal) Decompose added in v1.7.0

func (fnd *FireboltNullDecimal) Decompose(buf []byte) (byte, bool, []byte, int32)

Decompose extracts the decimal value into form, sign, coefficient, and exponent.

func (FireboltNullDecimal) GetDecimal added in v1.7.0

func (fnd FireboltNullDecimal) GetDecimal() *decimal.Decimal

GetDecimal returns the decimal value if it is valid, otherwise returns nil.

type FireboltNullStruct added in v1.7.0

type FireboltNullStruct struct {
	Struct FireboltStruct
	Valid  bool
}

func (*FireboltNullStruct) Scan added in v1.7.0

func (fns *FireboltNullStruct) Scan(src interface{}) error

type FireboltStruct added in v1.7.0

type FireboltStruct map[string]interface{}

func (*FireboltStruct) Scan added in v1.7.0

func (fs *FireboltStruct) Scan(src interface{}) error

type InMemoryRows

type InMemoryRows struct {
	ColumnReader
	// contains filtered or unexported fields
}

func (*InMemoryRows) Close

func (r *InMemoryRows) Close() error

Close makes the rows unusable

func (*InMemoryRows) HasNextResultSet

func (r *InMemoryRows) HasNextResultSet() bool

HasNextResultSet reports whether there is another result set available

func (*InMemoryRows) Next

func (r *InMemoryRows) Next(dest []driver.Value) error

Next fetches the values of the next row, returns io.EOF if it was the end

func (*InMemoryRows) NextResultSet

func (r *InMemoryRows) NextResultSet() error

NextResultSet advances to the next result set, if it is available, otherwise returns io.EOF

func (*InMemoryRows) ProcessAndAppendResponse

func (r *InMemoryRows) ProcessAndAppendResponse(response *client.Response) error

AppendResponse appends the response to the InMemoryRows, parsing the response content and checking for errors in the response body

type NullBytes added in v1.7.0

type NullBytes struct {
	Bytes []byte
	Valid bool // Valid is true if Bytes is not NULL
}

NullBytes represents a []byte that may be null. NullBytes implements the Scanner interface so it can be used as a scan destination.

func (*NullBytes) Scan added in v1.7.0

func (n *NullBytes) Scan(value interface{}) error

Scan implements the Scanner interface.

type StreamRows

type StreamRows struct {
	ColumnReader
	// contains filtered or unexported fields
}

func (*StreamRows) Close

func (r *StreamRows) Close() error

Close makes the rows unusable

func (*StreamRows) HasNextResultSet

func (r *StreamRows) HasNextResultSet() bool

HasNextResultSet reports whether there is another result set available

func (*StreamRows) Next

func (r *StreamRows) Next(dest []driver.Value) error

Next fetches the values of the next row, returns io.EOF if it was the end

func (*StreamRows) NextResultSet

func (r *StreamRows) NextResultSet() error

NextResultSet advances to the next result set, if it is available, otherwise returns io.EOF

func (*StreamRows) ProcessAndAppendResponse

func (r *StreamRows) ProcessAndAppendResponse(response *client.Response) error

AppendResponse appends a response to the list of row streams

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL