query

package

v0.0.2 Latest Latest Go to latest Published: Nov 12, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/adwski/ydb-go-query

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Ctx
- func NewCtx(logger logger.Logger, qSvc *query.Service, ...) *Ctx
type Query
type Result
type Transaction
type TxQuery

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrPartStatus = errors.New("result part status error")
	ErrStream     = errors.New("result stream error")
	ErrIssues     = errors.New("query result has issues")
)

View Source

var (
	ErrResult = errors.New("result fetch error")
)

View Source

var (
	ErrTxFinished = errors.New("transaction already finished")
)

Functions ¶

This section is empty.

Types ¶

type Ctx ¶

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

func NewCtx ¶

func NewCtx(
	logger logger.Logger,
	qSvc *query.Service,
	txSet *Ydb_Query.TransactionSettings,
	timeout time.Duration,
) *Ctx

func (*Ctx) Exec ¶

func (qc *Ctx) Exec(ctx context.Context, queryContent string) (*Result, error)

func (*Ctx) OnlineReadOnly ¶

func (qc *Ctx) OnlineReadOnly() *Ctx

func (*Ctx) OnlineReadOnlyInconsistent ¶

func (qc *Ctx) OnlineReadOnlyInconsistent() *Ctx

func (*Ctx) Query ¶

func (qc *Ctx) Query(queryContent string) *Query

func (*Ctx) SerializableReadWrite ¶

func (qc *Ctx) SerializableReadWrite() *Ctx

func (*Ctx) SnapshotReadOnly ¶

func (qc *Ctx) SnapshotReadOnly() *Ctx

func (*Ctx) StaleReadOnly ¶

func (qc *Ctx) StaleReadOnly() *Ctx

func (*Ctx) Tx ¶

func (qc *Ctx) Tx(ctx context.Context) (*Transaction, error)

type Query ¶

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

func (*Query) Collect ¶

func (q *Query) Collect(collectRowsFunc func([]*Ydb.Value) error) *Query

func (*Query) Exec ¶

func (q *Query) Exec(ctx context.Context) (*Result, error)

func (*Query) Param ¶

func (q *Query) Param(name string, val *Ydb.TypedValue) *Query

func (*Query) Params ¶

func (q *Query) Params(params map[string]*Ydb.TypedValue) *Query

func (*Query) Timeout ¶ added in v0.0.1

func (q *Query) Timeout(timeout time.Duration) *Query

type Result ¶

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

func (*Result) Cols ¶

func (r *Result) Cols() []*Ydb.Column

func (*Result) Err ¶

func (r *Result) Err() error

func (*Result) Issues ¶

func (r *Result) Issues() []*Ydb_Issue.IssueMessage

func (*Result) Rows ¶

func (r *Result) Rows() []*Ydb.Value

func (*Result) Stats ¶

func (r *Result) Stats() *Ydb_TableStats.QueryStats

func (*Result) TxID ¶

func (r *Result) TxID() string

type Transaction ¶

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

func (*Transaction) Commit ¶

func (tx *Transaction) Commit(ctx context.Context) error

func (*Transaction) Query ¶

func (tx *Transaction) Query(queryContent string) *TxQuery

func (*Transaction) Rollback ¶

func (tx *Transaction) Rollback(ctx context.Context) error

type TxQuery ¶

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

func (*TxQuery) Collect ¶ added in v0.0.1

func (q *TxQuery) Collect(collectRowsFunc func([]*Ydb.Value) error) *TxQuery

func (*TxQuery) Commit ¶

func (q *TxQuery) Commit() *TxQuery

func (*TxQuery) Exec ¶

func (q *TxQuery) Exec(ctx context.Context) (*Result, error)

func (*TxQuery) Param ¶ added in v0.0.1

func (q *TxQuery) Param(name string, val *Ydb.TypedValue) *TxQuery

func (*TxQuery) Params ¶ added in v0.0.1

func (q *TxQuery) Params(params map[string]*Ydb.TypedValue) *TxQuery

func (*TxQuery) Timeout ¶ added in v0.0.1

func (q *TxQuery) Timeout(timeout time.Duration) *TxQuery

Source Files ¶

View all Source files

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