rows

package
v1.6.2 Latest Latest
Warning

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

Go to latest
Published: Mar 14, 2025 License: Apache-2.0 Imports: 21 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 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 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