rows

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 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 AsyncResponse added in v1.11.0 

type AsyncResponse struct {
	Message    string `json:"message"`
	MonitorSql string `json:"monitorSql"`
	Token      string `json:"token"`
}

type AsyncResult added in v1.11.0 

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

func NewAsyncResult added in v1.11.0 

func NewAsyncResult(token string, monitorSQL string) *AsyncResult

func (AsyncResult) GetMonitorSQL added in v1.11.0 

func (r AsyncResult) GetMonitorSQL() string

func (AsyncResult) GetToken added in v1.11.0 

func (r AsyncResult) GetToken() string

func (AsyncResult) IsEmpty added in v1.11.0 

func (r AsyncResult) IsEmpty() bool

func (AsyncResult) LastInsertId added in v1.11.0 

func (r AsyncResult) LastInsertId() (int64, error)

func (AsyncResult) RowsAffected added in v1.11.0 

func (r AsyncResult) RowsAffected() (int64, error)

type AsyncRows added in v1.11.0 

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

func (*AsyncRows) Close added in v1.11.0 

func (r *AsyncRows) Close() error

Close makes the rows unusable

func (*AsyncRows) Columns added in v1.11.0 

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

Columns returns the names of the columns in the result set

func (*AsyncRows) HasNextResultSet added in v1.11.0 

func (r *AsyncRows) HasNextResultSet() bool

HasNextResultSet reports whether there is another result set available

func (*AsyncRows) Next added in v1.11.0 

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

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

func (*AsyncRows) NextResultSet added in v1.11.0 

func (r *AsyncRows) NextResultSet() error

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

func (*AsyncRows) ProcessAndAppendResponse added in v1.11.0 

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

ProcessAndAppendResponse appends a response to the list of row streams

func (*AsyncRows) Result added in v1.11.0 

func (r *AsyncRows) Result() (driver.Result, error)

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 ExtendableRowsWithResult added in v1.11.0 

type ExtendableRowsWithResult interface {
	driver.Rows
	ProcessAndAppendResponse(response *client.Response) error
	Result() (driver.Result, 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 FireboltResult added in v1.11.0 

type FireboltResult struct {
}

func (FireboltResult) LastInsertId added in v1.11.0 

func (r FireboltResult) LastInsertId() (int64, error)

LastInsertId returns last inserted ID, not supported by firebolt

func (FireboltResult) RowsAffected added in v1.11.0 

func (r FireboltResult) RowsAffected() (int64, error)

RowsAffected returns a number of affected rows, not supported by firebolt

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

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

func (*InMemoryRows) Result added in v1.11.0 

func (r *InMemoryRows) Result() (driver.Result, error)

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

ProcessAndAppendResponse appends a response to the list of row streams

func (*StreamRows) Result added in v1.11.0 

func (r *StreamRows) Result() (driver.Result, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.